MVC_Spring - 트랜잭션 기본

MVC_Spring - 트랜잭션 기본

• 트랜잰션이란?
  

• 트랜잭션 간단히 정리
  

간단히 얘기하자면 트랜잭션은 하나의 작업단위이다.

예를들면 쿼리문 insert into ~ 을 실행하는 순간부터

Data Base에 저장이 완료되기까지를

하나의 작업단위라고 생각하면 된다.

• 트랜잭션 오류 처리
  

서로 연관된 2개의 트랜잭션을 처리할때

하나라도 오류가 생긴다면

전부 다 롤백 되어야한다.

• 사용되는 Dependency
  

1. spring-jdbc release 4.1.4

• 사용되는 import
  

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

• 필요한 설정
  

-pom.xml

-servlet-context.xml

//Connection Pull 이용하기 위한 초기화
<beans:bean name="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <beans:property name="driverClassName" value="oracle.jdbc.driver.OracleDriver" />
    <beans:property name="url" value="jdbc:oracle:thin:@localhost:1521:xe" />
    <beans:property name="username" value="scott" />
    <beans:property name="password" value="tiger" />
</beans:bean>
 
//템플릿 객체 초기화 : DataSource(Connection Pull이용)를 넣어준다
<beans:bean name="template" class="org.springframework.jdbc.core.JdbcTemplate">
    <beans:property name="dataSource" ref="dataSource" />
</beans:bean>
 
//트랜젝션매니저 객체 초기화 : DataSource(Connection Pull이용)를 넣어준다
<beans:bean name="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <beans:property name="dataSource" ref="dataSource" />
</beans:bean>
 
//DAO 객체 초기화 : 위에서 만든 template, transactionManager 넣어준다.
<beans:bean name="dao" class="com.javalec.spring_pjt_ex.dao.TicketDao" >
    <beans:property name="template" ref="template" />
    <beans:property name="transactionManager" ref="transactionManager" />
</beans:bean>

• 실습예제
  

실습예제를 보기전에 SQL Template를 잊어버렸다면

참고하세요 ( 링크 :  https://cloud0477.tistory.com/76 )

-TicketDao.java

public class TicketDao {
 
    JdbcTemplate template;
    
    PlatformTransactionManager transactionManager;
    
    public void setTemplate(JdbcTemplate template) {
        this.template = template;
    }
 
    public void setTransactionManager( PlatformTransactionManager transactionManager) {
        this.transactionManager = transactionManager;
    }
 
    public void buyTicket(final TicketDto dto) {
        System.out.println("buyTicket()");
        System.out.println("dto.getConsumerId() : " + dto.getConsumerId());
        System.out.println("dto.getAmount() : " + dto.getAmount());
        
        
        TransactionDefinition definition = new DefaultTransactionDefinition();    //트랜잭션을 구동하기 위한 필요한 객체
        TransactionStatus status = transactionManager.getTransaction(definition); //트랜잭션매니저에서 트랜잭션을 가져온다.
        
        try {
        
            template.update(new PreparedStatementCreator() {
                
                @Override
                public PreparedStatement createPreparedStatement(Connection con)
                        throws SQLException {
                    String query = "insert into card (consumerId, amount) values (?, ?)";
                    PreparedStatement pstmt = con.prepareStatement(query);
                    pstmt.setString(1, dto.getConsumerId());
                    pstmt.setString(2, dto.getAmount());
                    
                    return pstmt;
                }
            });
            
            template.update(new PreparedStatementCreator() {
                
                @Override
                public PreparedStatement createPreparedStatement(Connection con)
                        throws SQLException {
                    String query = "insert into ticket (consumerId, countnum) values (?, ?)";
                    PreparedStatement pstmt = con.prepareStatement(query);
                    pstmt.setString(1, dto.getConsumerId());
                    pstmt.setString(2, dto.getAmount());
                    
                    return pstmt;
                }
            });
        
            transactionManager.commit(status);        //정상적으로 처리가 되었으면 Commit
            
        } catch (Exception e) {
            e.printStackTrace();
            
            transactionManager.rollback(status);    //비정상적으로 에러가 나면 Rollback
        }
    }
 
    
}

-Controller.java

@Controller
public class HomeController {
    
    private TicketDao dao;
    
    @Autowired
    public void setDao(TicketDao dao) {
        this.dao = dao;
    }
    
    private static final Logger logger = LoggerFactory.getLogger(HomeController.class);
    
    @RequestMapping("/buy_ticket")
    public String buy_ticket() {
        return "buy_ticket";
        
    }
    
    @RequestMapping("/buy_ticket_card")
    public String buy_ticket_card(TicketDto ticketDto, Model model) {
        System.out.println( "buy_ticket_card" );
        System.out.println( "ticketDto : " + ticketDto.getConsumerId() );
        System.out.println( "ticketDto : " + ticketDto.getAmount() );
        
        dao.buyTicket(ticketDto);
        
        model.addAttribute("ticketInfo", ticketDto);
        
        return "buy_ticket_end";
    }
}

-TicketDto.java

public class TicketDto {
 
    private String consumerId;
    private String amount;
    
    public String getConsumerId() {
        return consumerId;
    }
    public void setConsumerId(String consumerId) {
        this.consumerId = consumerId;
    }
    public String getAmount() {
        return amount;
    }
    public void setAmount(String amount) {
        this.amount = amount;
    }
    
}

-buy_ticket.jsp

<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Insert title here</title>
</head>
<body>
 
<p>카드 결제</p>
 
<form action="buy_ticket_card">
    고객 아이디 : <input type="text" name="consumerId" > <br />
    티켓 구매수 : <input type="text" name="amount" > <br />
    <input type="submit" value="구매" > <br />
</form>
 
</body>
</html>

-buy_ticket_end.jsp

<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Insert title here</title>
</head>
<body>
 
buy_ticket_end.jsp 입니다. <br />
 
${ticketInfo.consumerId } <br />
${ticketInfo.amount } <br />
 
</body>
</h

※팁

위 소스는 실제 잘 사용을 하지 않습니다.

다음 글에서 참고바랍니다.