JDBC自動提交和批處理操作

今天用JDBC與數據庫進行交互的時候，報錯如下：

*********************************************************************************************
com.ibm.db2.jcc.b.SqlException: [jcc][t4][10251][10308][3.53.70] 正在連接上執行事務時，請求了 java.sql.Connection.close()。
事務仍然保持活動狀態，不能關閉連接。 ERRORCODE=-4471, SQLSTATE=null
at com.ibm.db2.jcc.b.bd.a(bd.java:660)
at com.ibm.db2.jcc.b.bd.a(bd.java:60)
at com.ibm.db2.jcc.b.bd.a(bd.java:120)
at com.ibm.db2.jcc.b.jb.t(jb.java:1105)
at com.ibm.db2.jcc.b.jb.w(jb.java:1128)
at com.ibm.db2.jcc.b.jb.u(jb.java:1114)
at com.ibm.db2.jcc.b.jb.close(jb.java:1098)
at com.softtone.excution.Odb.close(Odb.java:192)
at com.softtone.excution.Odb.main(Odb.java:219)
************************************************************************************************ 

總結如下:

1.JDBC默認是自動提交的，對於查詢可以不用修改設置

2.JDBC中對於增、刪、改、查的修改操作，為保持數據的完整性，一般都是把修改操作組裝成一個事務。需要在修改之前調用connection對象的setAutoCommit(false)這個方法，在調用完statement對象的executeBatch()批量修改方法后，后面需要跟一個connection對象的commit()方法。否則，在最后調用conn.close()方法關閉連接會拋出事務正在活動，不能關閉JDBC連接的異常。

注：setAutoCommit(false)放在具體的操作里面，一般是修改操作之前。查詢操作就不用設置。

示例:

public class JdbcTest {
    public void execute(){
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtil.getConnection(Constants.URL, Constants.USERNAME, Constants.PASSWORD);
            String sqlQuery = "select distinct ID from table a";
            stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
            rs = stmt.executeQuery(sqlQuery);
            StringBuffer sb1 = new StringBuffer();
            while(rs.next()){
                sb1.append("'"+rs.getString(1)+"'");
                if(!rs.isLast()){
                    sb1.append(",");
                }
            }
            rs.close();
            String Id = sb1.toString();
            if(!"".equals(Id)){
                //為保持數據的一致性，把多個對數據庫的刪除操作作為一個事務，禁止自動提交
                conn.setAutoCommit(false);
                String sqlDelete1 = "delete from table1 where ID in (" + Id +")";
                stmt.addBatch(sqlDelete1);
                String sqlDelete2 = "delete from table2 where ID in (" + Id +")";
                stmt.addBatch(sqlDelete2);
                stmt.executeBatch();
                conn.commit();
            }
            stmt.close();
            conn.close();
            
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            JdbcUtil.free(rs, stmt, conn);
        }
    }
}