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);
        }
    }
}