Java JDBC事務

 

JDBC默認是自動提交，事務是關閉的，statement|preparedStatement.executeUpdate()或excute()執行增刪改，執行一次就提交一次（自動同步到數據庫）。

 

JDBC事務示例：

 //從properties文件中加載數據庫配置
        Properties properties = new Properties();
        InputStream inputStream =Class.forName("test.Test").getResourceAsStream("/mysql.properties");
        properties.load(inputStream);

        String driver = properties.getProperty("driver");
        String url = properties.getProperty("url");
        String user = properties.getProperty("user");
        String pwd=properties.getProperty("password");

        Class.forName(driver);
        Connection connection = DriverManager.getConnection(url, user, pwd);
        connection.setAutoCommit(false);   //關閉自動提交，此句代碼會自動開啟事務。默認為true，自動提交。

        String sql1 = "insert into student_tb (name,age,score) values (?,?,?)";
        PreparedStatement preparedStatement1 = connection.prepareStatement(sql1);
        preparedStatement1.setString(1,"chy");
        preparedStatement1.setInt(2,20);
        preparedStatement1.setInt(3,100);
        preparedStatement1.executeUpdate();  //放置到隊列中

        String sql2 = "update student_tb set name=? where id=?";
        PreparedStatement preparedStatement2 = connection.prepareStatement(sql2);
        preparedStatement2.setString(1,"CoCo");
        preparedStatement2.setInt(2,10);
        preparedStatement2.executeUpdate();  //放置到隊列中

        try{
            connection.commit();   //提交事務
        }catch (SQLException e){
            connection.rollback();  //失敗就回滾
        } finally {
            preparedStatement1.close();
            preparedStatement2.close();
            connection.close();
        }