JDBC 커밋 및 롤백 예제

다음은 예제입니다. 이 예제는 다음을 사용하여 작성되었습니다.commit과rollbackJDBC 트랜잭션 강의에서 설명되었습니다.

이 예제 코드는 전 몇 장의 환경과 데이터베이스 설정에 따라 작성되었습니다.

JDBCExample.java에 다음 예제를 복사하고 붙여넣어 실행하세요.

//단계1. 필요한 소프트웨어 패키지를 가져옵니다.
import java.sql.*;
public class JDBCExample {
　　　//　JDBC 드라이버 이름과 데이터베이스 URL
　　　static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";　　
　　　static final String DB_URL = "jdbc:mysql://localhost/EMP";
　　　//　　데이터베이스 인증 정보
　　　static final String USER = "username";
　　　static final String PASS = "password";
　　　
　public static void main(String[] args) {
　　　Connection conn = null;
　　　Statement stmt = null;
　　　try{
　　　　　　//단계2JDBC 드라이버를 등록합니다.
　　　　　　Class.forName("com.mysql.jdbc.Driver");
　　　　　　//단계3데이터베이스에 연결합니다.
　　　　　　System.out.println("Connecting to database...");
　　　　　　conn = DriverManager.getConnection(DB_URL, USER, PASS);
　　　　　　//단계4자동 커밋을 false로 설정합니다.
　　　　　　conn.setAutoCommit(false);
　　　　　　//단계5데이터베이스 쿼리를 실행하여 명령을 생성합니다.
　　　　　　//　RS 예제의 필수 매개변수.
　　　　　　System.out.println("Creating statement...");
　　　　　　stmt = conn.createStatement();
　　　　　　　　　　　　　　　　　　　　　　　　　　　ResultSet.TYPE_SCROLL_INSENSITIVE,
　　　　　　　　　　　　　　　　　　　　　　　　　　　ResultSet.CONCUR_UPDATABLE);
　　　　　
　　　　　　//단계6데이터베이스 테이블 '员工'에 행을 추가합니다.
　　　　　　System.out.println("Inserting one row....");
　　　　　　String SQL = "INSERT INTO Employees"　+
　　　　　　　　　　　　　　　　　　　　"VALUES (106,　20, 'Rita', 'Tez')";
　　　　　　stmt.executeUpdate(SQL);　　
　　　　　　//단계7데이터베이스 테이블 '员工'에 다른 행을 추가합니다.
　　　　　　SQL = "INSERT INTO Employees"　+
　　　　　　　　　　　　　　　　　　　　"VALUES (107,　22, 'Sita', 'Singh')";
　　　　　　stmt.executeUpdate(SQL);
　　　　　　//단계8데이터를 여기서 제출하십시오。
　　　　　　System.out.println("데이터 커밋 중...");
　　　　　　conn.commit();
	　　
	　　//단계9：모든 사용 가능한 기록을 나열합니다。
　　　　　　String　sql　=　"SELECT　id,　first,　last,　age　FROM　Employees";
　　　　　　ResultSet　rs　=　stmt.executeQuery(sql);
　　　　　　System.out.println("데이터 셋을 참조로列出...");
　　　　　　printRs(rs);
　　　　　　//단계10：환경 정리
　　　　　　rs.close();
　　　　　　stmt.close();
　　　　　　conn.close();
　　　}catch(SQLException　se){
　　　　　　//JDBC 에러 처리
　　　　　　se.printStackTrace();
　　　　　　//　에러가 발생하면 변경을 롤백합니다。
　　　　　　System.out.println("데이터 롤백 중...");
	　　try{
		　if(conn!=null)
　　　　　　　　　　　　conn.rollback();
　　　　　　}catch(SQLException　se2){
　　　　　　　　　se2.printStackTrace();
　　　　　　}//시도 끝
　　　}catch(Exception　e){
　　　　　　//Class.forName的错误 처리
　　　　　　e.printStackTrace();
　　　}finally{
　　　　　　//자원을 닫는 데 사용
　　　　　　try{
　　　　　　　　　if(stmt!=null)
　　　　　　　　　　　　stmt.close();
　　　　　　}catch(SQLException　se2){
　　　　　　
　　　　　　}
　　　　　　try{
　　　　　　　　　if(conn!=null)
　　　　　　　　　　　　conn.close();
　　　　　　}catch(SQLException　se){
　　　　　　　　　se.printStackTrace();
　　　　　　}
　　　}
　　　System.out.println("Goodbye!");
}//main 끝
　　　public　static　void　printRs(ResultSet　rs)　throws　SQLException{
　　　　　　//确保我们从第一行开始
　　　　　　rs.beforeFirst();
　　　　　　while(rs.next()){
　　　　　　　　　//칼럼 이름으로 검색
　　　　　　　　　int　id　　=　rs.getInt("id");
　　　　　　　　　int　age　=　rs.getInt("age");
　　　　　　　　　String　first　=　rs.getString("first");
　　　　　　　　　String　last　=　rs.getString("last");
　　　　　　　　　//표시 값
　　　　　　　　　System.out.print("ID:　"　+　id);
　　　　　　　　　System.out.print(",　Age:　"　+　age);
　　　　　　　　　System.out.print(",　First:　"　+　first);
　　　　　　　　　System.out.println(",　Last:　"　+　last);
　　　　　}
　　　　　System.out.println();
　　　}//printRs() 종료
}//JDBCExample 종료

지금 위의 예제를 컴파일해 보겠습니다:

C:\>javac JDBCExample.java
C:\>

실행 중JDBCExample，그렇게 될 것입니다.-

C:\>java JDBCExample
Connecting to database...
Creating statement...
Inserting one row....
Commiting data here....
List result set for reference....
ID:　10,　Age:　18,　First:　Zara,　Last:　Ali
ID:　101,　Age:　25,　First:　Mahnaz,　Last:　Fatma
ID:　102,　Age:　3,　First:　Zaid,　Last:　Khan
ID:　103,　Age:　28,　First:　Sumit,　Last:　Mittal
ID:　106,　Age:　2,　First:　Rita,　Last:　Tez
ID:　107,　Age:　22,　First:　Sita,　Last:　Singh
안녕히 가세요!
C:\>