Transaction(트랜잭션)

트랜잭션 

데이터베이스의 상태를 변환시키는 하나의 논리적 기능을 수행하기 위한 작업 단위 또는 한 번에 모두 수행되어야 할 일련의 연산 

데이터베이스 시스템에서 병행 제어 및 회복 작업 시 처리되는 논리적 단위

사용자가 시스템에 대한 서비스 요구 시 시스템이 응답하기 위한 상태 변환 과정의 작업 단위 

 

트랜잭션의 특징(ACID)

1) 원자성(Atomic) 

ALL OR NOTHING

- 트랜잭션은 한 개 이상의 동작을 논리적으로 한 개의 작업 단위로 묶음

- 원자성은 트랜잭션 범위에 있는 모든 동작이 모두 실행되거나 모둗 실행이 취소됨을 보장

 

2) 일관성 (Consistent)

트랜잭션이 종룓되면, 시스템은 비즈니스에서 기대하는 상태가 됨

예를 들어, 서적 구매 트랜잭션이 성공적으로 실행되면 결제내역, 구매내역, 잔고 정보가 비즈니스에 맞게 저장되고 변경됨.

3) 고립성(Isolated)

- 트랜잭션은 다른 트랜잭션과 독립적으로 실행되어야 하며, 서로 다른 트랜잭션이 동일한 데이터에 동시에 접근 할 경우 알맞게 동시 접근을제어.

- 동시 접근 제어는 설정한 격리 레벨에 따라 달라짐.

 

4) 지속성(Durable)

- 트랜잭션이 완료되면, 그 결과는 지속적으로 유지되어야 함.
- 현재의 어플리케이션이 변경되거나 없어지더라도 데이터는 유지됨.
- 일반적으로 데이터베이스나 다른 물리적인 저장소를 통해서 트랜잭션 결과가 저장됨

 

트랜잭션 시작 및 종료

1) 트랜잭션 시작

실행 가능한 SQL문장이 가장 먼저 실행될 때

 

2) 트랜잭션 종료

- COMMIT(트랜잭션 완료) 이나 ROLLBACK(트랜잭션 취소) 실행

- DDL이나 DCL문장의 실행(자동 COMMIT)
- 기계 장애 또는 시스템 충돌(crash)
- Deadlock 발생

-정상종료

 

트랜잭션의 자동 COMMIT 및 자동 ROLLBACK

1) 자동 COMMIT

- DDL,DCL문장이 완료 될 때

- 명시적인 COMMIT이나 ROLLBACK없이 SQL*Plus를 정상 종료 했을 경우

 

2) 자동 ROLLBACK

- SQL*Plus를 비정상 종료 했을 경우

-비정상적인종료등

 

 

트랜잭션 처리 예시

한 메서드 안에 두 개 이상의 sql 쿼리문을 실행해야 할 때,

하나가 처리 되지 않으면 다른 하나도 처리 되지 않도록 rollback 해주기 위해 사용

 

conn.setAutoCommit(false);

자바에서 DML 쿼리를 실행하면 기본적으로 COMMIT 된다.

Connection 객체 conn을 자동 커밋되지 않도록 설정

 

conn.commit();

 예외가 발생하지 않았다면 커밋.

 

예외가 발생했다면 rollback하기 위해 예외 처리 문에 rollback을 사용한다.

 

 

트랜잭션 코드 예시

세개의 테이블이 모두 등록되거나, 하나의 테이블이라도 등록되지 않으면 모두 등록되지 않도록 코딩
전화번호 입력하지 않고 엔터 치면 모든 테이블이 등록되지 않음

package db.ch5;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import db.util.DBConn;

public class Ex_Transaction {
	public static void main(String[] args) {
		// 트랜잭션 예제
		BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

		Connection conn = DBConn.getConnection();

		PreparedStatement pstmt = null;

		String sql;
		String id, name, birth, tel;

		try {
			System.out.println("아이디?");
			id = br.readLine();

			System.out.println("이름?");
			name = br.readLine();

			System.out.println("생년월일?");
			birth = br.readLine();

			System.out.println("전화번호?");
			tel = br.readLine();

			conn.setAutoCommit(false);

			sql = "INSERT INTO test1(id, name) VALUES(?,?)";
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, id);
			pstmt.setString(2, name);
			pstmt.executeUpdate();
			pstmt.close();
			pstmt = null;

			sql = "INSERT INTO test2(id, birth) VALUES(?,?)";
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, id);
			pstmt.setString(2, birth);
			pstmt.executeUpdate();
			pstmt.close();
			pstmt = null;

			sql = "INSERT INTO test3(id, tel) VALUES(?,?)";
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, id);
			pstmt.setString(2, tel);
			pstmt.executeUpdate();
			pstmt.close();
			pstmt = null;

			// 커밋
			conn.commit();

			System.out.println("데이터 추가 성공 ");

		} catch (SQLException e) {
			// 롤백
			try {
				conn.rollback();
			} catch (Exception e2) {

			}
			System.out.println("데이터 추가 실패");
		} catch (Exception e2) {
			e2.printStackTrace();
		} finally {

			if (pstmt != null) {
				try {
					pstmt.close();
				} catch (Exception e2) {

				}

			}
			try {
				// 다시 커밋되도록 설정
				conn.setAutoCommit(true);
			} catch (Exception e) {
				// TODO: handle exception
			}

			DBConn.close();
		}
	}
}