JDBC自动提交和批处理操作

时间：2023-03-08 20:30:27

今天用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);

        }

    }

}

相关文章