개요
데이터베이스 트랜잭션은 데이터를 일관되고 안전하게 처리하기 위해 필요한 기능입니다. 자바에서는 클래스와 객체를 활용하여 데이터베이스 트랜잭션을 다루는 것이 가능합니다. 이 글에서는 자바를 사용하여 데이터베이스 트랜잭션을 다루는 방법에 대해 설명하겠습니다.
데이터베이스 연결 및 트랜잭션 객체 생성
데이터베이스 트랜잭션을 다루기 위해서는 먼저 데이터베이스에 연결해야 합니다. 자바에서는 java.sql.Connection 클래스를 사용하여 데이터베이스에 연결할 수 있습니다. 연결이 성공하면 Connection 객체를 생성합니다.
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DatabaseManager {
private Connection connection;
public DatabaseManager(String url, String username, String password) {
try {
connection = DriverManager.getConnection(url, username, password);
} catch (SQLException e) {
e.printStackTrace();
}
}
// ...
}
트랜잭션 시작 및 종료
트랜잭션을 시작하고 종료하는 메서드를 구현해야 합니다. Connection 객체의 setAutoCommit(false) 메서드를 호출하여 자동 커밋을 비활성화하고, commit() 메서드를 호출하여 작업을 커밋하거나 rollback() 메서드를 호출하여 작업을 롤백할 수 있습니다.
public class DatabaseManager {
// ...
public void startTransaction() {
try {
connection.setAutoCommit(false);
} catch (SQLException e) {
e.printStackTrace();
}
}
public void commitTransaction() {
try {
connection.commit();
connection.setAutoCommit(true);
} catch (SQLException e) {
e.printStackTrace();
}
}
public void rollbackTransaction() {
try {
connection.rollback();
connection.setAutoCommit(true);
} catch (SQLException e) {
e.printStackTrace();
}
}
}
트랜잭션 실행 예시
위에서 구현한 클래스와 메서드를 사용하여 트랜잭션을 실행하는 예시를 살펴보겠습니다.
public class Main {
public static void main(String[] args) {
DatabaseManager databaseManager = new DatabaseManager("jdbc:mysql://localhost:3306/mydb", "username", "password");
try {
databaseManager.startTransaction();
// 트랜잭션 작업
// ...
databaseManager.commitTransaction();
} catch (Exception e) {
databaseManager.rollbackTransaction();
e.printStackTrace();
}
}
}
위 예시에서는 databaseManager.startTransaction() 메서드를 호출하여 트랜잭션을 시작하고, 트랜잭션 작업을 수행한 다음 databaseManager.commitTransaction() 메서드를 호출하여 작업을 커밋합니다. 만약 예외가 발생하면 databaseManager.rollbackTransaction() 메서드를 호출하여 작업을 롤백합니다.
결론
이렇게 자바에서 클래스와 객체를 사용하여 데이터베이스 트랜잭션을 다룰 수 있습니다. 트랜잭션을 시작하고 종료하는 메서드를 구현하고, 트랜잭션 작업을 수행한 후 커밋 또는 롤백하는 방식으로 안전하고 일관된 데이터 처리가 가능합니다.