JDBC事务控制管理

今天是学习计划的第二天，感觉自己的学习热情还是很高涨的啊，那我们就趁热打铁，开始今天的学习。
今天的学习内容是JDBC的事务控制管理。
首先是概念性的内容
事务指逻辑上的一组操作，组成这组操作的各个单元，要么全部成功，要么全部不成功。这是我对于事务的理解。
举个例子: A转账给B，对应如下的两条sql语句
update from account set money = money - 100 where name = 'A'
update from account set money = money + 100 where name = 'B'
在现实生活中，这两条sql语句要么就应该同时成功，要么就应该同时失败，否则用户的账户就会产生问题。
在MySQL数据库中，默认情况下，一条sql语句就是一个单独的事务，事务是自动提交的
在Oracle数据库中，默认情况下，事务不是自动提交的，所有sql语句都处于一个事务中，需要手动进行事务提交。
数据库事务命令

• start transaction 开启事务
• rollback 回滚事务
• commit 提交事务

我们来操作一个案例感受一下。
首先设置账户表(account)  在表中插入一些初始数据

create table account(
	id int primary key not null auto_increment,
	name varchar(40),
	money double
);

insert into account values(1,'aaa',1000);
insert into account values(2,'bbb',1000);
insert into account values(3,'ccc',1000);

然后打开我们的控制台进入数据库，输入 start transaction;这时候我们去修改数据，输入update account set money = money - 100 where name ='aaa';,然后输入查询语句select * from account;查询

此时说明更新语句成功执行了，但是请注意，我们在更新数据之前使用start transaction语句开启了一个事务，所以如果我们不手动提交，事务是不会被提交的，我们可以打开另一个控制台进入数据库，并查询该表

会发现，名字为aaa账户的余额并没有被改变，这就是事务的状态。
其实，在事务管理中执行sql语句，都会使用数据库内的临时表保存，在没有进行事务提交或者回滚的前提下，其它用户是无法看到操作结果的。
回到第二个用户的操作中，当我输入commit;提交事务时，我们再次查询表数据

这个时候第二个用户才能查询到第一个用户更新的数据。
我们继续在第一个用户的数据库中操作，重新开启一个事务，然后输入update account set money = money + 100 where name ='bbb';，查询表数据
bbb账户的金额多了100，此时，我们可以使用回滚操作，通俗地讲，就是撤销上一次的sql语句，输入rollback;然后重新查询表数据

会发现，bbb账户的金额又变为了1000，说明回滚操作生效了。
需要注意的是，sql语言中只有DML才能被事务管理，那什么是DML，DML就是数据操纵语言，是SQL语言中，负责对数据库对象运行数据访问工作的指令集，以INSERT、UPDATE、DELETE三种指令为核心，分别代表插入、更新与删除，所以只有这三个关键字才能被事务管理，其它语句是不能被事务管理的。
这样事务的基本操作都在控制台进行了对应的练习，接下来我们了解一下JDBC在项目中是如何控制事务的。
在MyEclipse中新建一个名为demo的的web项目，然后导入数据库的驱动，这个东西我就不提供了，在官网或者其它地方都能够下载。为了方便接下来的数据库操作，我先写了一个简易的JDBC工具类，新建JDBCUtils.java文件

/**
 * JDBC 工具类，抽取公共方法
 * 
 * @author seawind
 * 
 */
public class JDBCUtils {
	private static final String DRIVERCLASS;
	private static final String URL;
	private static final String USER;
	private static final String PWD;

	static {
		ResourceBundle bundle = ResourceBundle.getBundle("dbconfig");
		DRIVERCLASS = bundle.getString("DRIVERCLASS");
		URL = bundle.getString("URL");
		USER = bundle.getString("USER");
		PWD = bundle.getString("PWD");
	}

	// 建立连接
	public static Connection getConnection() throws Exception {
		loadDriver();
		return DriverManager.getConnection(URL, USER, PWD);
	}

	// 装载驱动
	private static void loadDriver() throws ClassNotFoundException {
		Class.forName(DRIVERCLASS);
	}

	// 释放资源
	public static void release(ResultSet rs, Statement stmt, Connection conn) {
		if (rs != null) {
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			rs = null;
		}

		release(stmt, conn);
	}

	public static void release(Statement stmt, Connection conn) {
		if (stmt != null) {
			try {
				stmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			stmt = null;
		}
		if (conn != null) {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
			conn = null;
		}
	}
}

还要有一个配置文件，因为在工具类中我是通过配置文件获取属性值进行数据库连接的
注意，一定要在src目录下新建dbconfig.properties文件

DRIVERCLASS=com.mysql.jdbc.Driver
URL=jdbc:mysql:///test
USER=root
PWD=123456

新建TransferTest.java文件进行测试，我们先不用事务管理来编写一下转账操作

@Test
public void demo1(){
	//模拟转账操作,先不使用事务管理
	Connection conn = null;
	PreparedStatement stmt = null;
	try {
		conn = JDBCUtils.getConnection();
		String sql1 = "update account set money = money - 100 where name = 'aaa'";
		String sql2 = "update account set money = money + 100 where name = 'bbb'";
		
		stmt = conn.prepareStatement(sql1);
		stmt.executeUpdate();
		
		stmt = conn.prepareStatement(sql2);
		stmt.executeUpdate();
	} catch (Exception e) {
		e.printStackTrace();
	}
}

先查询一下数据库表

此时三个用户的账户余额都为1000，现在运行刚才编写的测试代码，然后重新查询表数据

账户余额发生了对应的改变，说明测试代码运行成功了。这里没有使用事务管理，两句sql语句其实就是两个事务，所以如果在两个事务之间出现了一点问题，整个转账的过程就会出现意外，我们可以制造一点问题出来。

@Test
public void demo1(){
	//模拟转账操作,先不使用事务管理
	Connection conn = null;
	PreparedStatement stmt = null;
	try {
		conn = JDBCUtils.getConnection();
		String sql1 = "update account set money = money - 100 where name = 'aaa'";
		String sql2 = "update account set money = money + 100 where name = 'bbb'";
		
		stmt = conn.prepareStatement(sql1);
		stmt.executeUpdate();
		
		//在两个事务中间制造一个异常
		int d = 1 / 0;
		
		stmt = conn.prepareStatement(sql2);
		stmt.executeUpdate();
	} catch (Exception e) {
		e.printStackTrace();
	}
}

我们在两个事务之间加上int d = 1 / 0;的代码，这样就会在执行完第一条事务之后产生异常从而中断程序运行，第二条事务也就得不到执行，看看是不是会发生这样的事情。
我们运行测试代码，程序报错，然后查询一下表数据

会发现，aaa用户的账户余额少了100，而bbb用户的余额并没有被改变，显然这种事情是不能被发生在现实生活中的银行业务中的。在这种情况下，为了保证两条sql语句的一致性，我们需要使用事务管理。在程序代码中，JDBC是会自动提交我们的事务的，我们可以通过Connection类的setAutoCommit(false)方法来关闭自动提交，从而获得控制事务提交的权利。
在TransferTest.java文件中编写第二个测试方法

@Test
public void demo2(){
	//模拟转账操作,使用事务管理
	Connection conn = null;
	PreparedStatement stmt = null;
	try {
		conn = JDBCUtils.getConnection();
		//在连接获得后,开启事务
		conn.setAutoCommit(false);	//关闭自动提交
		String sql1 = "update account set money = money - 100 where name = 'aaa'";
		String sql2 = "update account set money = money + 100 where name = 'bbb'";
		
		stmt = conn.prepareStatement(sql1);
		stmt.executeUpdate();
		
		int d = 1 / 0;
		
		stmt = conn.prepareStatement(sql2);
		stmt.executeUpdate();
		
		//如果程序能走到这一步  说明两句sql都执行成功	提交事务
		conn.commit();
	} catch (Exception e) {
		//表示在执行转账的过程产生了异常	需要将两句sql语句进行回滚
		try {
			conn.rollback();
		} catch (SQLException e1) {
			e1.printStackTrace();
		}
		e.printStackTrace();
	}
}

现在，执行测试代码，程序报错，查询表数据

三个账户的余额均没有发生变化，说明两句sql语句被回滚了，当你删掉错误代码，重新运行，发现表数据被相应地修改了，这样就达到了事务管理的目的。
这是基本的JDBC控制事务的方法了。
再来了解一些高级的事务操作，我们假设，当事务特别复杂的时候，有些情况不会回滚到事务的最开始状态，这时候就需要将事务回滚到指定位置，此时就需要知道 事务回滚点(SavePoint)。
我们先创建一张person表

create table person(
	id int primary key,
	name varchar(40)
);

新建一个测试方法

@Test
	public void demo3(){
		//创建person表	向表中插入两万条数据
		//如果插入过程中	发生错误 要保证插入的条数是1000的整数倍
		Connection conn = null;
		PreparedStatement stmt = null;
		try {
			conn  = JDBCUtils.getConnection();
			String sql = "insert into person values(?,?)";
			//预编译sql
			stmt = conn.prepareStatement(sql);
			for(int i = 0;i <= 20000;i++){
				stmt.setInt(1, i);
				stmt.setString(2, "name" + i);
				//添加到批处理
				stmt.addBatch();
			
			if(i == 4699){
				int d = 1 / 0;
			}
			
			//每隔200次向数据库发送一次
			if(i % 200 == 0){
				stmt.executeBatch();
				stmt.clearBatch();
			}
		}
		
		//为了确保缓存的sql都提交了
		stmt.executeBatch();
	} catch (Exception e) {
		e.printStackTrace();
	}finally{
		JDBCUtils.release(stmt, conn);
	}
}

我们故意在循环内制造一个错误，运行测试代码，程序报错，查询表数据

只有4600条数据，那么该如何获得1000的整数倍的数据记录呢？我们可以在获得连接之后获得一个回滚点，然后在循环中每隔1000条数据就重新保存一下回滚点，然后在异常处理代码块中写conn.rollback(savepoint);回滚到回滚点。具体代码如下:

@Test
public void demo3(){
	//创建person表	向表中插入两万条数据
	//如果插入过程中	发生错误 要保证插入的条数是1000的整数倍
	Connection conn = null;
	PreparedStatement stmt = null;
	Savepoint savepoint = null;
	try {
		conn  = JDBCUtils.getConnection();
		
		//开启事务
		conn.setAutoCommit(false);
		//保存一次回滚点
		savepoint = conn.setSavepoint();
		
		String sql = "insert into person values(?,?)";
		//预编译sql
		stmt = conn.prepareStatement(sql);
		for(int i = 1;i <= 20000;i++){
			stmt.setInt(1, i);
			stmt.setString(2, "name" + i);
			//添加到批处理
			stmt.addBatch();
			
			if(i == 4699){
				int d = 1 / 0;
			}
			
			//每隔200次向数据库发送一次
			if(i % 200 == 0){
				stmt.executeBatch();
				stmt.clearBatch();
			}
			
			if(i % 1000 == 0){//1000的整数倍
				//保存回滚点
				savepoint = conn.setSavepoint();
			}
		}
		
		//为了确保缓存的sql都提交了
		
		//如果执行到这 说明程序没有错误
		conn.commit();
		stmt.executeBatch();
	} catch (Exception e) {
		//回滚事务	回滚到存储点
		try {
			conn.rollback(savepoint);
			conn.commit();
		} catch (SQLException e1) {
			e1.printStackTrace();
		}
		e.printStackTrace();
	}finally{
		JDBCUtils.release(stmt, conn);
	}
}

先在数据库控制台输入truncate person;来清除person表中的所有数据，然后执行测试代码，查询表数据

会发现，当前只有4000条数据了，因为程序出现异常，事务记录了第4000条记录的回滚点，并在出现异常之后回滚到了第4000条数据，至此，我们的目的也就实现了。