日期:2014-05-16 浏览次数:20519 次
??? 在前面的两篇文章中,第一篇主要是讲了在jdbc编程中容易碰到的几个问题,以及大致的解决方法。第二篇从代码上实现了第一篇的一些方法,并且对批处理进行了一些描述。在批处理的过程中,我并没有和事务的概念放在一起,因为我发现,这两个概念往往会引起混淆。因为jdbc的批处理是jdbc层面上的,而事务是数据库层面上的,如果写一个存储过程的话,这两者是一样的,即到了一批再commit,而在jdbc编程就是两个层面了。比如下面的代码:
public void addEmployees(Connection conn, List<Employee> empList, int batchSize) throws SQLException { long bt = System.currentTimeMillis(); PreparedStatement stmt = null; try { // 设置conn自动提交为false,而由程序在需要的地方进行commit或者rollback conn.setAutoCommit(false); String sql = SqlParser.getInstance().getSql("Employee.insert"); stmt = conn.prepareStatement(sql); int count = 0; for (Employee emp : empList) { stmt.setInt(1, emp.getId()); stmt.setString(2, emp.getName()); stmt.setInt(3, emp.getDepartment().getId()); stmt.setString(4, emp.getDescription()); stmt.addBatch(); count++; if (count % batchSize == 0) { stmt.executeBatch(); // 注意,如果不加conn.commit()方法,即使我用stmt.executeBatch(),也不会真正提交到数据库 // conn.commit(); } } stmt.executeBatch(); // 虽然我在上面多次调用executeBatch(),但都没有真正提交到数据库,只有在conn.commit()之后才算真正提交 conn.commit(); } catch (SQLException e) { conn.rollback(); } finally { long et = System.currentTimeMillis(); System.out.println(String.format("用时%dms", et - bt)); DBUtil.close(stmt); DBUtil.close(conn); } }
?
? ? 需要注意的是:
1. conn.setAutoCommit(false)
??? 这里就是让Connection不自动commit,而由程序来调用。
2. 在我使用stmt.executeBatch()方法之后,如果不使用conn.commit()方法的话,数据并没有真正提交到数据库。
?
??? 通过上面的代码,我们已经开始使用事务了,还记得上一篇中结束的时候,我提供了测试的速度,现在再来看一下
?
??? 是不是觉得有点问题?速度好像比较慢,这是怎么回事?原来我没有将conn.setAutoCommit(false)之前,每次stmt的操作都是新开一个事务的,1000条数据,开1000次事务,能不慢吗?现在换上新的代码,再来测试一下:
?
?
??? 是不是快了许多呢。
?
??? 言归正传,说到事务,我觉得有必要把事务的特性说一下,这是很基本的东西,但是很多人包括我自己有时也不太容易讲清楚。
??? 说到原子性和持久性,这两个比较好理解,对于一致性和隔离性,有必要好好想一想。
?
??? 对于一致性,我的理解有两个层面:
1. 完整性约束,比如员工表和部门表,员工所属的部门必须是部门表的数据
2. 读一致性,比如读取员工表,本来是可以读1000员工,但读的过程可能有一点长,在此过程中,另外一个事务删除了一些员工数据,但读的事务应该仍然能读到1000名员工。
?
??? 对于隔离性,我觉得多个事务之间不能相互干扰,应该是事务隔离机制里最严格的Serialiable(序列化)级别,关于事务的隔离级别,我写了一篇《图说事务隔离级别 》,可以参考。
?
??? 对于事务的特性的讨论暂时到此,现在来看一下,使用jdbc如何进行事务?接着我之前的例子,即删除部门的时候,会把员工所属于的部门设置为空,那就是删除部门有两个操作,一是删除部门表数据,二是更新员工表数据,这两个操作应该在一个事务里。代码如下:
public void deleteDepartmentTrans(Connection conn, Department dept) throws SQLException { try { conn.setAutoCommit(false); this.deleteDepartment(conn, dept); this.updateEmpDeptNull(conn, dept); conn.commit(); } catch (SQLException e) { conn.rollback(); } } private void deleteDepartment(Connection conn, Department dept) throws SQLException { PreparedStatement stmt = null; try { String sql = SqlParser.getInstance().getSql("Department.delete"); stmt = conn.prepareStatement(sql); stmt.setInt(1, dept.getId()); stmt.execute(); } finally { DBUtil.close(stmt); DBUtil.close(conn); } } private void updateEmpDeptNull(Connection conn, Department dept) throws SQLException { PreparedStatement stmt = null; try { String sql = SqlParser.getInstance().getSql( "Employee.departmentisnull"); stmt = conn.prep