[Java] 트랜잭션 처리하기

트랜잭션이란?

트랜잭션(Transaction)이란 데이터베이스의 상태를 변환시키는 하나의 논리적 기능을 수행하기 위한 작업의 단위를 말한다.

A가 B에게 만원을 송금한다고 가정한다. 먼저 A의 통장에서 만원을 인출하고, B의 통장에 만원을 입금해야 한다. 이때, 인출과 입금의 두가지 일이 합쳐져 '송금'이라는 하나의 논리적 기능을 이루는 것이다.

 

트랜잭션의 성질(ACID)

원자성(Atomicity)

• 트랜잭션은 데이터베이스에 모두 반영되거나 전혀 반영되지 않아야 한다
• 예) 송금 과정에서 A에게서 만원을 인출했지만 B에게 만원을 입금하지 않는 경우가 발생하면 안된다

일관성(Consistency)

• 트랜잭션이 성공적으로 완료되면 일관적인 데이터를 유지한다

독립성(Isolation)

• 둘 이상의 트랜잭션이 동시에 실행되는 경우 각 트랜잭션은 서로의 연산에 끼어들 수 없다

영구성(Durability)

• 성공적으로 완료된 트랜잭션의 결과는 영구적으로 반영되어야 한다

 

트랜잭션 연산

롤백(Rollback)

• 트랜잭션 작업 도중 오류가 발생하면 트랜잭션 처리를 시작하기 이전의 상태로 되돌린다
• 송금 중 A에게 만원을 인출한 후 B에게 만원을 입금하는 과정에서 오류가 발생했다면? A에게 만원을 인출한 작업이 일어나기 전 상태로 되돌린다

커밋(Commit)

• 트랜잭션 작업을 성공적으로 마치고 데이터 베이스에 영구적으로 반영한다

---

트랜잭션 구현하기

try { 
	conn.setAutoCommit(false); 	// AutoCommit을 false로 변경 
    
    // 송금인의 계좌에 money만큼의 잔액이 있는지 확인 
    boolean checkBalance = Account.checkBalance(conn, money);
    if (!checkBalance) {
    	throw new Exception("돈이 모자라요ㅠㅠ"); 
    } 
    
    // 송금인의 계좌에서 money만큼 인출 
    int updateCount = Account.takeMoney(conn, remitter, money);
    if (updateCount != 1) { 
    	throw new Exception("송금인의 계좌에서 인출하기 실패!"); 
    }
    
    // 수취인의 계좌에 money만큼 입금 
    updateCount = Account.addMoney(conn, remittee, money); 
    if (deleteCount == 1) {
   		conn.commit(); // 작업 내용을 commit 
    } else { 
   		throw new Exception("수취인의 계좌에 입금 실패!"); 
    } 
    
} catch (Throwable e) {     // 작업과정 중 예외가 발생 
    if (conn != null) { 
    try { 
    	conn.rollback();    // 트랜잭션 실행 이전 상태로 되돌리기
    } catch (SQLException e1) {
  	 	e1.printStackTrace(); 
    } 
  } 
  e.printStackTrace();
} finally { 
    try { 
    	conn.setAutoCommit(true); // AutoCommit을 다시 true로 변경 
    } catch (SQLException e2) { 
    	e2.printStackTrace();
    } 
}

 

setAutoCommit()

AutoCommit은 기본 설정이 true이다. AutoCommit이 ture인 상태에선 쿼리문을 한 번 날릴때 마다 commit을 하게 된다. 하지만 트랜잭션은 여러 개의 쿼리를 처리하고 한번에 커밋해야 하므로 AutoCommit을 false로 설정해 준다.
finally에 AutoCommit을 다시 true로 설정하는 구문을 작성하여 트랜잭션 작업 성공여부에 상관없이 다시 원래 설정으로 변경시켜준다.

throw new Exception()

오류를 발생시킨다. if문의 조건을 변경하여 의도적으로 오류를 발생시키면 console창에 내가 작성한 메세지와 함께 오류가 발생한 것을 볼 수 있다.

이 경우 catch에 걸려 해당 트랜잭션 작업이 rollback()된다.

conn.commit()

트랜잭션 작업을 성공적으로 마치면 데이터베이스에 영구적으로 반영한다.

conn.rollback()

트랜잭션 작업도중 오류가 발생하면 앞서 트랜잭션 작업 이전의 상태로 되돌린다.

 

 

---

참고 사이트

• 위키백과 - 데이터베이스 트랜잭션
• 출처: https://sunnyk.tistory.com/15 [오늘 공부]