JDBC——事物管理

案例：银行转账问题，数据库如下

相关API

setAutoCommit(boolean autoCommit)  将此连接的自动提交模式设置为给定状态。设置事务是否自动提交如果设置为false，表示手动提交事务

setSavepoint() 在当前事务中创建一个未命名的保存点 (savepoint)，并返回表示它的新 Savepoint 对象。

void rollback() ;     回滚（出现异常时候，所有已经执行成功的代码需要回退到事务开始前的状态。）

java.sql接口 Savepoint  public interface Savepoint   保存点的表示形式，保存点是可以从 Connection.rollback 方法引用的当前事务中的点。将事务回滚到保存点时，在该保存点之后所作的全部更改都将被撤消。 

// 1. 转账
	public void trans1() {

		String sql_zs = "UPDATE account SET money=money-1000 WHERE name=‘张三‘;";
		String sql_ls = "UPDATE account SET money=money+1000 WHERE name=‘李四‘;";

		try {
			con = JDBCU.getConnection(); // 默认开启的隐士事务
			con.setAutoCommit(true);//默认值是true，写不写一样

			/*** 第一次执行SQL ***/
			pstmt = con.prepareStatement(sql_zs);
			pstmt.executeUpdate();

			/*** 第二次执行SQL ***/
			pstmt = con.prepareStatement(sql_ls);
			pstmt.executeUpdate();

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			JDBCU.closeAll(con, pstmt, null);
		}

	}

当一方出现问题，这个时候需要管理，除了两者都提交成功外，其他的都回滚原来状态

@Test
	// 2. 转账，使用事务
	public void trans2() {

		String sql_zs = "UPDATE account SET money=money-1000 WHERE name=‘张三‘;";
		//故意出错，数据库会出错。
		String sql_ls = "UPDATE account SET money=money1+1000 WHERE name=‘李四‘;";

		try {
			con = JDBCU.getConnection(); // 默认开启的隐士事务
			// 一、设置事务为手动提交
			con.setAutoCommit(false);

			/*** 第一次执行SQL ***/
			pstmt = con.prepareStatement(sql_zs);
			pstmt.executeUpdate();

			/*** 第二次执行SQL ***/
			pstmt = con.prepareStatement(sql_ls);
			pstmt.executeUpdate();

		} catch (Exception e) {
			try {
				// 二、 出现异常，需要回滚事务
				con.rollback();
			} catch (SQLException e1) {
			}
			e.printStackTrace();
		} finally {
			try {
				// 三、所有的操作执行成功, 提交事务
				con.commit();
				JDBCU.closeAll(con, pstmt, null);
			} catch (SQLException e) {
			}
		}

	}

// 3. 转账，使用事务， 回滚到指定的代码段
	//第一次有错误，而第二次有错误，现在想在第一次和第二次之间设置一个还原点
	@Test
	public void trans() {
		// 定义个标记
		Savepoint sp = null;

		// 第一次转账
		String sql_zs1 = "UPDATE account SET money=money-1000 WHERE accountName=‘张三‘;";
		String sql_ls1 = "UPDATE account SET money=money+1000 WHERE accountName=‘李四‘;";

		// 第二次转账
		String sql_zs2 = "UPDATE account SET money=money-500 WHERE accountName=‘张三‘;";
		String sql_ls2 = "UPDATE1 account SET money=money+500 WHERE accountName=‘李四‘;";

		try {
			con = JDBCU.getConnection(); // 默认开启的隐士事务
			con.setAutoCommit(false);       // 设置事务手动提交

			/*** 第一次转账 ***/
			pstmt = con.prepareStatement(sql_zs1);
			pstmt.executeUpdate();
			pstmt = con.prepareStatement(sql_ls1);
			pstmt.executeUpdate();

			// 回滚到这个位置？
			sp = con.setSavepoint(); 

			/*** 第二次转账 ***/
			pstmt = con.prepareStatement(sql_zs2);
			pstmt.executeUpdate();
			pstmt = con.prepareStatement(sql_ls2);
			pstmt.executeUpdate();

		} catch (Exception e) {
			try {
				// 回滚 (回滚到指定的代码段)
				con.rollback(sp);
			} catch (SQLException e1) {
			}
			e.printStackTrace();
		} finally {
			try {
				// 提交
				con.commit();
			} catch (SQLException e) {
			}
			JDBCU.closeAll(con, pstmt, null);
		}

	}