[Spring] 트랜잭션

Notice

Recent Posts

Recent Comments

Link

« 2025/02 »
일	월	화	수	목	금	토
						1
2	3	4	5	6	7	8
9	10	11	12	13	14	15
16	17	18	19	20	21	22
23	24	25	26	27	28

Tags more

Archives

Today

Total

관리 메뉴

Jam's story

[Spring] 트랜잭션 본문

Spring

[Spring] 트랜잭션

애플쩀 2022. 7. 18. 16:25

📌스프링 컨테이너?

dispatcher-servlet.xml 설정파일을 보고 스프링 빈 객체 생성 + 조립하는 공장

📌 web.xml에 보면 프론트컨트롤러가 등록되어있다. (모든 요청을 받는 컨트롤러 )

<!--   스프링 front-controller등록 -->
  <servlet>
  <servlet-name>dispatcher</servlet-name>
  <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
  <load-on-startup>1</load-on-startup> <!-- 톰캣이 시작될때 서블릿객체 실행  -->
  </servlet>
  <servlet-mapping>
    <servlet-name>dispatcher</servlet-name>
    <url-pattern>*.htm</url-pattern>
  </servlet-mapping>

프론트 컨트롤러는 여러개 있을 수 있다. (관리를 목적 )

예)

관리자요청 스프링 컨트롤러 ,

ajax 요청 스프링 컨트롤러 등등...

📌 스프링 컨테이너 계층구조 (부모-자식 계층 )

스프링 컨테이너 계층구조(부모- 자식 계층 )

📌 지금은 프론트 컨트롤러가 하나이다 (자식 공장이 하나 )

하지만 ,지금 프론트 컨트롤러에 자식공장을 더 추가하겠다는 것!

dispatcher-servlet.xml => 선언된 빈 객체들 중에 DB 연동하는 스프링 빈은 부모공장(Application Context) 그 안에서 생성하도록 코딩

1️⃣dispatcher-service.xml 파일 생성 -스프링 빈을 관리를 목적으로 설정파일 분리

dispatcher-servlet.xml ( 이 자체가 서블릿이기 때문에 한 개 이상의 dispatcher-servlet을 설정할 수 있다. )

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
            xmlns:context="http://www.springframework.org/schema/context"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://www.springframework.org/schema/context
           http://www.springframework.org/schema/context/spring-context.xsd">

<context:component-scan base-package="newlecture.dao, controllers"></context:component-scan>

<!-- 파일업로드를 위한  -->
<bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
    <property name="maxUploadSize" value="-1"></property>
</bean>

</beans>

dispatcher-service.xml (나누어주었다. )

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
            xmlns:context="http://www.springframework.org/schema/context"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://www.springframework.org/schema/context
           http://www.springframework.org/schema/context/spring-context.xsd">
           
           
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"></property>
    <property name="url" value="jdbc:oracle:thin:@localhost:1521:xe"></property>
    <property name="username" value="scott"></property>
    <property name="password" value="tiger"></property>
</bean>

<!-- NamedParameterJddbcTemplate 템플릿 클래스 사용 -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
    <constructor-arg ref="dataSource"/>
</bean>
</beans>

📌이렇게하면 dispatcher-servlet.xml(수정된) 만 실행이 되므로 데이터관련 빈 객체들은 생성되지 않는다.

서비스에 설정된 빈 객체를 생성할 수 있도록 web.xml을 수정해주어야한다.

p373- ContextLoaderListener를 등록하여 공통으로 사용될 빈을 설정해준다.

web.xml - 디스패처 서블릿을 여러개만들기 위해서,( 부모공장과 자식공장들을 만드는데,) 부모공장을 만들겠다는 소리

   <!-- p.371 WebApplicationContext 계층 -->
<context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>/WEB-INF/dispatcher-service.xml</param-value>
</context-param>

<listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

springJDBC02 복사해서 -> springTransaction 프로젝트 생성

컨텍스트 root 바꾸고 , add and remove에서 springTransaction 이것만 올리고, 서버 스탑, 후 클린 후 재시작

점심시간동안 p505~536 읽어보기

1️⃣HomeController 생성

@Controller 
@RequestMapping("/")
public class HomeController {
	
	public HomeController() {
		super();
		// TODO Auto-generated constructor stub
	}
}

index.htm 생성

index.htm 요청이왔을때 메인페이지로 돌려주는 메소드를 만들자

HomeController.java



@Controller 
@RequestMapping("/")
public class HomeController {
	
	public HomeController() {
		super();
		// TODO Auto-generated constructor stub
	}
	@RequestMapping("index.htm")
	public String home() throws Exception{
		return "index.jsp";
	}
	
}

JoinController.java



@Controller 
@RequestMapping("/joinus/*")
public class JoinController {
	
	public JoinController() {
		super();
		// TODO Auto-generated constructor stub
	}
	private MemberDao memberDao=null;
	
	@RequestMapping(value= {"join.htm"}, method=RequestMethod.GET)
	public String join() throws Exception{
		return "redirect:../index.htm";
		//joinus가 붙어있기 때문에 ../ 추가 
	}
	@RequestMapping(value= {"login.htm"}, method=RequestMethod.POST)
	public String login(Member member) throws Exception{
		this.memberDao.insert(member); //회원 insert
		return "login.jsp";
	}
}

notice.jsp -htm 으로 수정

	<ul id="loginmenu" class="block_hlist">
					<li>
						<a href="../index.htm">HOME</a>
					</li>
					<li>
						<a href="../joinus/login..htm">로그인</a>
					</li>
					<li>
						<a href="../joinus/join.htm">회원가입</a>
					</li>
				</ul>

-507p

dispatcher-servlet.xml

    <!-- 스프링 트랜잭션을 처리할 트랜잭션 메니져 등록 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>

6. 스프링 트랜잭션 처리 3가지 방법

1)코드 기반 처리: 개발자 직접 코딩 . 트랜잭션 매니져, 트랜잭션 템플릿 클래스 이용

2)선언적 트랜잭션 처리 방법 xml설정

3)어노테이션 기반 @어노테이션

트랜잭션 실습

트랜잭션 처리 실습

1)공지사항 새글작성 +

notice테이블 insert

2)point칼럼값은 <3 체크제약조건 설정

3)notice테이블 pk 제약조건 설정

4)notice 테이블의 title 칼럼값은 unique 제약조건 설정

1️⃣SQL

ALTER TABLE member
ADD ( point number(10) default(0) );

ALTER TABLE member
ADD CONSTRAINT ck_member_point CHECK( point < 3 );


ALTER TABLE notices
ADD CONSTRAINT pk_notice_seq   PRIMARY KEY( seq );


 ALTER TABLE notices
  ADD CONSTRAINT uk_notice_title unique( title);

2️⃣Member.java

	//트랙잭션 처리 체크위해서 point 칼럼 추가 
	private int point;
	
	public int getPoint() {
		return point;
	}
	public void setPoint(int point) {
		this.point = point;
	}

3️⃣join.jsp

// action="join.htm"
<div class="top-wrapper clear">
<div id="content">
<form action="join.htm" method="post">
<h2>회원가입</h2>


//form 태그 안에 가입버튼 넣기 
<div id="buttonLine">
<input class="btn-okay button" type="submit" value="가입" />
</div>
</form>

4️⃣

우선 처리할 것이 새글(insert)+ 작성자의 point 칼럼1증가(update) 트랜잭션 처리 안된 상태

interface NoticeDao에 추가

	//트랜잭션 테스트 용도의 메소드 추가 
	public void insertAndPointUpOfMember(Notice notice, String id) throws ClassNotFoundException, SQLException;

5️⃣NLNoticeDao

@Override
public void insertAndPointUpOfMember(Notice notice, String id) throws ClassNotFoundException, SQLException {
	//새 공지사항 쓰기    
	String sql = "INSERT INTO NOTICES"
		    	+ "(SEQ, TITLE, CONTENT, WRITER, REGDATE, HIT, FILESRC) "
	            + "VALUES"
	            + "( (SELECT MAX(TO_NUMBER(SEQ))+1 FROM NOTICES), :title, :content, :writer, SYSDATE, 0, :filesrc)";
	      
	      SqlParameterSource parameterSource = new BeanPropertySqlParameterSource(notice);
	      
	       this.jdbcTemplate.update(sql, parameterSource);
	    
	      
	      //포인트 1증가
	     sql="UPDATE member"
	     		+ "SET point =point+1"
	     		+ "WHERE id=:id";
	    		 
	    MapSqlParameterSource paramSource2 = new MapSqlParameterSource();
	      paramSource2.addValue("id",id);
	      
	     this.jdbcTemplate.update(sql, paramSource2);
}

컨트롤러에 noticeReg 메소드

	마지막에 이부분 추가 
    	this.noticeDao.insertAndPointUpOfMember(notice, "kenik");
		return "redirect:notice.htm";
    
    
    
    //글쓰기+첨부된 파일 
	@RequestMapping( value = {"noticeReg.htm"}, method = RequestMethod.POST )
    public String noticeReg(Notice notice ,HttpServletRequest request ) throws Exception {
        //1 첨부된 파일의 유무 확인 후에 파일저장 
		CommonsMultipartFile multipartFile= notice.getFile();
		
		String uploadRealPath=null;
		
		if(!multipartFile.isEmpty()) { //첨부된 파일이 있다면 
			uploadRealPath =request.getServletContext().getRealPath("/customer/upload");
			System.out.println("uplaodRealPath:"+uploadRealPath);
			
			String originalFilename=multipartFile.getOriginalFilename(); //오천 "a.txt" ->"a_1.txt"
			//이렇게 인덱스를 붙이는 함수 (이미 존재할 수 도 있으니까)
		    String filesystemName = getFileNameCheck(uploadRealPath, originalFilename);
			File dest=new File(uploadRealPath,filesystemName);
			multipartFile.transferTo(dest); //실질적으로 파일을 저장 
			
			//originalFilename ,  filesystemName Notices 테이블의 칼럼이 2개 존재 
			String filesrc=filesystemName; //저장하고자하는 파일 
			notice.setFilesrc(filesrc);
		}
		//2.Notices 테이블에 공지사항 INSERT
		notice.setWriter("kenik");
/*         int rowCount = this.noticeDao.insert(notice);
         if (rowCount==1) { 
            return "redirect:notice.htm";         
         }else { 
            return "redirect:noticeReg.jsp?error"; 
         }*/
		
		this.noticeDao.insertAndPointUpOfMember(notice, "kenik");
		return "redirect:notice.htm";
   } // noticeReg

이제부터 스프링으로 트랜잭션 처리 -2)선언적 트랜잭션 처리 방법 xml설정

1️⃣web.xml에 추가

    <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
    <property name="transactionManager" ref="transactionManager"/>
</bean>

전체코드

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
            xmlns:context="http://www.springframework.org/schema/context"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://www.springframework.org/schema/context
           http://www.springframework.org/schema/context/spring-context.xsd">
           
           
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"></property>
    <property name="url" value="jdbc:oracle:thin:@localhost:1521:xe"></property>
    <property name="username" value="scott"></property>
    <property name="password" value="tiger"></property>
</bean>

<!-- NamedParameterJddbcTemplate 템플릿 클래스 사용 -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
    <constructor-arg ref="dataSource"/>
</bean>
    <!-- p507 스프링 트랜잭션을 처리할 트랜잭션 메니져 등록 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>
    
    <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
    <property name="transactionManager" ref="transactionManager"/>
</bean>
</beans>

2️⃣NLNoticeDao.java에 추가

   
   @Autowired
   private TransactionTemplate transactionTemplate;

3️⃣p516

트랜잭션처리가 필요한 장소(메소드)

NLNoticeDao.java - insertAndPointUpOfMember()

//트랜잭션 매니저를 사용해서 트랜잭션처리 
@Override
public void insertAndPointUpOfMember(Notice notice, String id) throws ClassNotFoundException, SQLException {
	//새 공지사항 쓰기    
	String sql = " INSERT INTO NOTICES"
		    	+ " (SEQ, TITLE, CONTENT, WRITER, REGDATE, HIT, FILESRC) "
	            + " VALUES"
	            + " ( (SELECT MAX(TO_NUMBER(SEQ))+1 FROM NOTICES), :title, :content, :writer, SYSDATE, 0, :filesrc)";
   
    //포인트 1증가
  String sql2=" UPDATE member"
	     		+ " SET point =point+1"
	     		+ " WHERE id=:id";
	    
	    /// TransactionCallback+ WithoutResult 
	    //처리하고 난담에 반환할 결과값이 없을경우 
	    this.transactionTemplate.execute(new TransactionCallbackWithoutResult() {

			@Override
			protected void doInTransactionWithoutResult(TransactionStatus ts) {
				  SqlParameterSource parameterSource = new BeanPropertySqlParameterSource(notice);
			      //이 안에서 this라고 쓰면 안된다. TransactionCallbackWithoutResult() 의 this 라는 뜻이어서 
				  // this.jdbcTemplate.update(sql, parameterSource);
				  jdbcTemplate.update(sql, parameterSource);
			       MapSqlParameterSource paramSource2 = new MapSqlParameterSource();
				      paramSource2.addValue("id",id);
				    jdbcTemplate.update(sql2, paramSource2);
			}
	    	
	    });
	 
}

글을쓰니

하지만 또 한번 글을 쓰려고 하니 에러발생 - > 그래서 프로젝트 새로 생성 해서 선언적방법 시도

springTransaction03

선언적 트랜잭션 처리

선언적 트랜잭션 ? 트랜잭션 매니저 객체
트랜잭션 템플릿 클래스 객체 생성 springTransaction X
트랜잭션 처리를 코드에서 직접 수행하지 않고
1. xml 설정파일 - springTransaction02
  - <tx:advice> 태그이용 - 트랜잭션 속성 정의하는 태그
  - <aop:config> 태그 - 트랜잭션도 내부적으로 AOP 를 사용한다.
2. @Transaction 어노테이션 - springTransaction03
3. 트랜잭션 처리 범위, 롤백 규칙 등등 정의해서 처리

1️⃣web.xml

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop" 
               xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/aop
https://www.springframework.org/schema/aop/spring-aop-3.0.xsd
            http://www.springframework.org/schema/tx
               http://www.springframework.org/schema/tx/spring-tx.xsd">

2️⃣NLNoticeDao.java

// [3]
   // [tx:advice + aop:config] 선언적 트랜잭션 처리. 
   @Override
   public void insertAndPointUpOfMember(Notice notice, String id) throws ClassNotFoundException, SQLException {
      // 1. 새 공지사항 쓰기
      String sql = "INSERT INTO NOTICES"
            + " ( SEQ, TITLE, CONTENT, WRITER, REGDATE, HIT, FILESRC) "
            + " VALUES"            
            + " ( (SELECT MAX(TO_NUMBER(SEQ))+1 FROM NOTICES), :title, :content, :writer, SYSDATE, 0, :filesrc  )";

      // 2. 포인트 1증가
      String  sql2 = "UPDATE member "
            + " SET point = point + 1 "
            + " WHERE id = :id ";      


      // 1.
      SqlParameterSource paramSource = new BeanPropertySqlParameterSource(notice);  
      jdbcTemplate.update(sql                             ,      paramSource  );      

      // 2
      MapSqlParameterSource paramSource2 = new MapSqlParameterSource();
      paramSource2.addValue("id", id);      
      jdbcTemplate.update(sql2, paramSource2);


   } //  insertAndPointUpOfMember

에러메세지

javax.servlet.ServletException: 서블릿 [dispatcher]을(를) 위한 Servlet.init() 호출이 예외를 발생시켰습니다.

springTransaction04

어노테이션 기반

@transactional 어노테이션을 붙이면 자동적으로 트랜잭션 처리가 된다.

dispatcher-servlet.xml 에서 <tx:annotation> 추가

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-3.0.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd
">

    <context:component-scan base-package="newlecture.dao, controllers" />

    <bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
        <property name="maxUploadSize" value="-1"></property>
    </bean>

    <!-- 추가 -->
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="insertAndPointUpOfMember" 
                isolation="DEFAULT" 
                propagation="REQUIRED"
                read-only="false"
                timeout="-1"
            />
        </tx:attributes>
    </tx:advice>

    <aop:config>
        <aop:pointcut expression="execution(public void insertAndPointUpOfMember(*, *))" id="insertOrM"/>
        <aop:pointcut expression="within(newlecture.dao.*)" id="insertPackage"/>
        <aop:advisor advice-ref="txAdvice" pointcut-ref="insertOrM"/>
    </aop:config>
</beans>

NLNoticeDAO.java

  @Override
   @Transactional(isolation = Isolation.DEFAULT, propagation = Propagation.REQUIRED, timeout = -1)
   public void insertAndPointUpOfMember(Notice notice, String id) throws ClassNotFoundException, SQLException {
      // 1. 새 공지사항 쓰기
      String sql = "INSERT INTO NOTICES"
            + " ( SEQ, TITLE, CONTENT, WRITER, REGDATE, HIT, FILESRC) "
            + " VALUES"            
            + " ( (SELECT MAX(TO_NUMBER(SEQ))+1 FROM NOTICES), :title, :content, :writer, SYSDATE, 0, :filesrc  )";

      // 2. 포인트 1증가
      String  sql2 = "UPDATE member "
            + " SET point = point + 1 "
            + " WHERE id = :id ";      


      // 1.
      SqlParameterSource paramSource = new BeanPropertySqlParameterSource(notice);  
      jdbcTemplate.update(sql                             ,      paramSource  );      

      // 2
      MapSqlParameterSource paramSource2 = new MapSqlParameterSource();
      paramSource2.addValue("id", id);      
      jdbcTemplate.update(sql2, paramSource2);


   } //  insertAndPointUpOfMember

저작자표시

'Spring' 카테고리의 다른 글

[Spring] 스프링 레거시 프로젝트 4.0버전 (0)	2022.07.20
[Spring] 스프링 트랜잭션 격리성 (0)	2022.07.19
[Spring] NamedParameterJdbcTemplate (0)	2022.07.18
[Spring] JDBC (0)	2022.07.17
[Spring] 파일업로드 (0)	2022.07.15

'Spring' Related Articles

Comments

Jam's story

[Spring] 트랜잭션 본문

[Spring] 트랜잭션

'Spring' 카테고리의 다른 글

티스토리툴바