[Java] 119. 트랜잭션과 배치 처리

[Java] 119. 트랜잭션과 배치 처리 

1. 배치 처리란?

2. 코드 예제 : PreparedStatement를 사용한 배치 처리

---

1. 배치 처리란?

(1) 배치 처리의 개념: 배치 처리(Batch Processing)란 데이터를일괄적으로 모아서 한 번에 처리하는 방법을 말한다. 배치 처리는 대량의 데이터를 처리하거나, 주기적으로 실행되는 작업을 자동화하는 데 사용된다. 일반적으로 대화형 사용자 입력 없이 실행되며, 백그라운드에서 작업이 수행된다. 

 

(2) 배치 처리의 특징:

-배치 처리(Batch Processing)은 여러 SQL문을 한 번에 실행하여 성능을 향상시키는 방법이다.

-여러 SQL문을 하나의 배치로 묶어서 데이터 베이스에 전송하고 실행한다.

-(1) Statement 및 (2) PreparedStatement를 이용한 배치 처리가 존재한다.

 

*대화형 처리: 사용자와 컴퓨터가 지속적인 상호작용을 통하여 대화식으로 문제를 해결하는 처리방식

*일괄 처리 ＝ 배치 처리

*@Scheduler:일정한 시간간격／일정한 시각에 특정 로직을 돌리기 위해서 사용하는 것。

대화형 처리의 예시 : 뉴스 사이트

 

(3) 배치 처리의 측성

-자동화: 주기적으로 실행되며, 인간의 개입 없이도 일정한 시간에 자동으로 수행된다.

-대량 처리: 대량의 데이터를 한 번에 처리할 수 있다.

-비실시간: 실시간으로 사용자와 상호작용하지 않고, 정해진 시간에 실행된다.

-신뢰성: 정해진 규칙에 따라 안정적으로 데이터를 처리한다.

 

(4) 배치 처리의 예시

-급여 계산: 회사

-데이터 마이그레이션: 한 시스템에서 다른 시스템으로 대량의 데이터를 이전하는 작업.

-로그 분석: 서버 로그 파일을 모아서 주기적으로 분석하고, 보고서를 생성하는 작업.

---

2. 코드 예제 : PreparedStatement를 사용한 배치 처리

 

package ch05;

import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Connection;

public class BatchExample {

	public static void main(String[] args) {

		String url = "jdbc:mysql://localhost:3306/demo3?serverTimezone=Asia/Seoul";
		String user = "root";
		String password = "asd123";
		Connection conn = null;

		try {
			// MySQL Driver 로드
			Class.forName("com.mysql.cj.jdbc.Driver");

			// 자바 표준 API
			conn = DriverManager.getConnection(url, user, password);

			// 트랜잭션 처리
			conn.setAutoCommit(false); // 수동 커밋으로 변경한다.

			// 배치 처리 --> User 테이블에 한 번 사용자를 3명을 넣어보자.
			String sql = "INSERT INTO users(name,email) VALUES(?,?) ";
			PreparedStatement psmt = conn.prepareStatement(sql);

			// 3번 사용자 처리
			psmt.setString(1, "유저3");
			psmt.setString(2, "유저3@nate.com");
			psmt.addBatch();
			// psmt.executeUpdate();
			// 배치 처리 하기 위해 호출할 메서드가 필요

			// 4번 사용자 처리
			psmt.setString(1, "유저4");
			psmt.setString(2, "유저4@nate.com");
			psmt.addBatch();

			// 5번 사용자 처리
			psmt.setString(1, "유저5");
			psmt.setString(2, "유저5@nate.com");
			psmt.addBatch();

			int[] rowCounts = psmt.executeBatch();

			conn.commit(); // 물리적인 저장장치에 영구히 반영
			System.out.println("배치 처리 완료 : "+rowCounts.length);

		} catch (Exception e) {
			e.printStackTrace();
			try {
				conn.rollback();
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
		} finally {
			try {
				if (conn != null) {
					conn.close();
				}
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}

	} // end of main
} // end of class