JDBC事务的使用

系统管理员 2021-09-17 23:50 309阅读 0赞

JDBC是一种可用于执行SQL语句的Java API，是连接数据库和Java应用程序的纽带。

数据库事务(Database Transaction) ，是指作为单个逻辑工作单元执行的一系列操作，要么完全地执行，要么完全地不执行。 事务处理可以确保除非事务性单元内的所有操作都成功完成，否则不会永久更新面向数据的资源。通过将一组相关操作组合为一个要么全部成功要么全部失败的单元，可以简化错误恢复并使应用程序更加可靠。一个逻辑工作单元要成为事务，必须满足所谓的ACID（原子性、一致性、隔离性和持久性）属性。

### 1、Connection接口中事务操作的相关方法 ###

Connection接口代表与特定的数据库的连接。要对数据表中数据进行操作，首先要获取数据库连接。Connection实例就像在应用程序与数据库之间开通了一条渠道。Connection接口中事务操作的相关方法如下：

<table> 
 <thead> 
  <tr> 
   <th>方法</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>setTransactionIsolation(int level)</td> 
   <td>设置 Connection对象的事务隔离级别。</td> 
  </tr> 
  <tr> 
   <td>getTransactionIsolation()</td> 
   <td>获取此 Connection 对象的当前事务隔离级别。</td> 
  </tr> 
  <tr> 
   <td>setAutoCommit(boolean autoCommit)</td> 
   <td>将 Connection对象的自动提交模式设置为给定状态。</td> 
  </tr> 
  <tr> 
   <td>getAutoCommit()</td> 
   <td>获取此 Connection 对象的当前自动提交模式。</td> 
  </tr> 
  <tr> 
   <td>commit()</td> 
   <td>使自上次提交/回滚以来所做的所有更改都将永久性，并释放此 Connection对象当前持有的任何数据库锁。</td> 
  </tr> 
  <tr> 
   <td>rollback()</td> 
   <td>撤消在当前事务中所做的所有更改，并释放此 Connection对象当前持有的任何数据库锁。</td> 
  </tr> 
  <tr> 
   <td>setSavepoint()</td> 
   <td>在当前事务中创建一个未命名的保存点 (savepoint)，并返回表示它的新 Savepoint 对象。</td> 
  </tr> 
  <tr> 
   <td>setSavepoint(String name)</td> 
   <td>在当前事务中创建一个具有给定名称的保存点，并返回表示它的新 Savepoint 对象。</td> 
  </tr> 
  <tr> 
   <td>releaseSavepoint(Savepoint savepoint)</td> 
   <td>从当前事务中移除指定的 Savepoint 和后续 Savepoint 对象。</td> 
  </tr> 
  <tr> 
   <td>close()</td> 
   <td>释放此&nbsp;Connection对象的数据库和JDBC资源，而不是等待它们被自动释放。</td> 
  </tr> 
 </tbody> 
</table>

### 2、JDBC事务的基本操作 ###

（1）connection.setAutCommit(false)：关闭事务自动提交

（2）connection.commit()：手动提交事务

（3）connection.rollback()：事务回滚

补：撤销事务中的部分操作

SavePoint sp = connection.setSavepoint();：设置事务回滚点

connection.rollback(sp);

connection.commit();：最后不要忘了提交事务，否则前面需要提交保存的操作也将不会保存到数据库中

### 3、JDBC事务的使用 ###

**示例：**使用JDBC事务，修改用户登录密码操作。

/**
     * 修改用户登录密码
     * 
     * @author pan_junbiao
     * @param id          用户编号
     * @param newPassword 新密码
     * @return
     */
    public Boolean updateLoginPassword(int id, String newPassword)
    {
    	Boolean result = false;
    	Connection conn = null;
    	PreparedStatement preStmt = null;
    	DBHelper dbHelper = new DBHelper();
    
    	try
    	{
    		// 获取数据库连接对象
    		conn = dbHelper.getConnection();
    
    		// 关闭事务自动提交
    		conn.setAutoCommit(false);
    
    		// 执行操作
    		preStmt = conn.prepareStatement("UPDATE user_info SET login_password = ? WHERE id = ?");
    		preStmt.setString(1, newPassword);
    		preStmt.setInt(2, id);
    		int res = preStmt.executeUpdate();
    		result = res > 0 ? true : false;
    
    		// 提交事务
    		conn.commit();
    
    	} catch (SQLException sqle)
    	{
    		try
    		{
    			// 回滚事务
    			conn.rollback();
    		} catch (SQLException e)
    		{
    			e.printStackTrace();
    		}
    
    		sqle.printStackTrace();
    
    	} finally
    	{
    		// 释放资源
    		dbHelper.closeResource(preStmt, conn);
    	}
    
    	return result;
    }