package com.test.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
 * 事務的基本用法
 *
 */
public class Test {
  public static void main(String[] args) {
    Connection conn = null;
    PreparedStatement ps1 = null;
    PreparedStatement ps2 = null;
    try {
      //加載驅動類
      Class.forName("com.mysql.jdbc.Driver");
      conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","123456");
      conn.setAutoCommit(false); //JDBC中默認是true，自動提交事務
      ps1 = conn.prepareStatement("insert into t_user (username,pwd) values (?,?)");//?是占位符
      ps1.setObject(1, "張三");
      ps1.setObject(2, "666666");
      ps1.execute();
      System.out.println("插入一個用戶張三");
      try {
        Thread.sleep(3000);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      ps2 = conn.prepareStatement("insert into t_user (username,pwd) values (?,?)");
      ps2.setObject(1, "李四");
      ps2.setObject(2, "123456");
      ps2.execute();
      System.out.println("插入一個用戶李四");
      conn.commit();//提交事務
    } catch (ClassNotFoundException e) {
      e.printStackTrace();
      try {
        conn.rollback();//某一條數(shù)據(jù)添加失敗時，回滾
      } catch (SQLException e1) {
        e1.printStackTrace();
      }
    } catch (SQLException e) {
      e.printStackTrace();
    }finally{
      try {
        if(ps1!=null){
          ps1.close();
        }
      } catch (SQLException e) {
        e.printStackTrace();
      }
      try {
        if(conn!=null){
          conn.close();
        }
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }
}

ps2 = conn.prepareStatement("insert into t_user (username,pwd) values (?)");