[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
'Java > 네트워크 통신' 카테고리의 다른 글
[Java] 121. JDBC를 활용한 CRUD와 SOLID 원칙 (2) (0) | 2024.06.14 |
---|---|
[Java] 120. JDBC를 활용한 CRUD와 SOLID 원칙 (1) (0) | 2024.06.14 |
[Java] 118. 코드 예제 : 트랜잭션을 이용해 MySQL 쿼리 내부에 데이터 생성하기 (0) | 2024.06.12 |
[Java] 117. 트랜잭션의 개념과 트랜잭션 관리 (0) | 2024.06.12 |
[Java] 115. 코드 예제: JDBC를 활용하여 CRUD 해보기 (0) | 2024.06.11 |