6.3、离线 RowSet 的查询分页

由于 CachedRowSet 会将数据记录直接装载到内存中， 因此如果 SQL 查询返回的记录过大，CachedRowSet 将会占用大量的内存， 在某些极端的情况下， 它甚至会直接导致内存溢出。为了解决该问题， CachedRowSet 提供了分页功能。 所谓分页功能就是一次只装载 ResultSet 里的某几条记录， 这样就可以避免 CachedRowSet 占用内存过大的问题。

CachedRowSet 提供了如下方法来控制分页：

• populate(ResultSet rs, int startRow)： 使用给定的 ResultSet 装填 RowSet， 从 ResultSet 的第 startRow条记录开始装填。
• setPageSize(int pageSize)： 设置 CachedRowSet 每次返回多少条记录。
• previousPage()： 在底层 ResultSet 可用的情况下， 让 CachedRowSet 读取上一页记录。
• nextPage()： 在底层 ResultSet 可用的情况下， 让 CachedRowSet 读取下一页记录。

下面程序示范了 CachedRowSet 的分页支持：

import java.util.*;
import java.io.*;
import java.sql.*;
import javax.sql.*;
import javax.sql.rowset.*;

public class CachedRowSetPage
{
	private String driver;
	private String url;
	private String user;
	private String pass;
	public void initParam(String paramFile)throws Exception
	{
		// 使用Properties类来加载属性文件
		Properties props = new Properties();
		props.load(new FileInputStream(paramFile));
		driver = props.getProperty("driver");
		url = props.getProperty("url");
		user = props.getProperty("user");
		pass = props.getProperty("pass");
	}

	public CachedRowSet query(String sql , int pageSize
		, int page)throws Exception
	{
		// 加载驱动
		Class.forName(driver);
		try(
			// 获取数据库连接
			Connection conn = DriverManager.getConnection(url , user , pass);
			Statement stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(sql))
		{
			// 使用RowSetProvider创建RowSetFactory
			RowSetFactory factory = RowSetProvider.newFactory();
			// 创建默认的CachedRowSet实例
			CachedRowSet cachedRs = factory.createCachedRowSet();
			// 设置每页显示pageSize条记录
			cachedRs.setPageSize(pageSize);
			// 使用ResultSet装填RowSet，设置从第几条记录开始
			cachedRs.populate(rs , (page - 1) * pageSize + 1);
			return cachedRs;
		}
	}
	public static void main(String[] args)throws Exception
	{
		CachedRowSetPage cp = new CachedRowSetPage();
		cp.initParam("mysql.ini");
		CachedRowSet rs = cp.query("select * from student_table" , 3 , 2);   // ①
		// 向后滚动结果集
		while (rs.next())
		{
			System.out.println(rs.getString(1)
				+ "\t" + rs.getString(2)
				+ "\t" + rs.getString(3));
		}
	}
}

7、事务处理

对于任何数据库应用而言， 事务都是非常重要的， 事务是保证底层数据完整的重要手段， 没有事务支持的数据库应用， 那将非常脆弱。

7.1、事务的概念和 MySQL 事务支持

事务是由一步或几步数据库操作序列组成的逻辑执行单元， 这系列操作要么全部执行， 要么全部放弃执行。 程序和事务是两个不同的概念。 一般而言， 一段程序中可能包含多个事务。

事务具备 4 个特性： 原子性（ Atomicity)、 一致性（ Consistency)、 隔离性 (Isolation) 和持续性( Durability)。 这 4 个特性也简称为 ACID 性。

• 原 子 性（Atomicity): 事务是应用中最小的执行单位， 就如原子是自然界的最小颗粒， 具有不可再分的特征一样， 事务是应用中不可再分的最小逻辑执行体。
• 一致性（Consistency): 事务执行的结果， 必须使数据库从一个一致性状态， 变到另一个一致性状态。 当数据库只包含事务成功提交的结果时， 数据库处于一致性状态。 如果系统运行发生中断， 某个事务尚未完成而被迫中断， 而该未完成的事务对数据库所做的修改已被写入数据库，此时， 数据库就处于一种不正确的状态。 比如银行在两个账户之间转账： 从 A 账户向 B 账户转入 1000 元， 系统先减少 A 账户的 1000 元， 然后再为 B 账户增加 1000 元。 如果全部执行成功，数据库处于于一致性状态； 如果仅执行完 A 账户金额的修改， 而没有增加 B 账户的金额， 则数据库就处于不一致性状态； 因此， 一致性是通过原子性来保证的。
• 隔 离 性 (Isolation)： 各个事务的执行互不干扰， 任意一个事务的内部操作对其他并发的事务都是隔离的。 也就是说， 并发执行的事务之间不能看到对方的中间状态， 并发执行的事务之间不能互相影响。
• 持续性（ Durability): 持续性也称为持久性（Persistence), 指事务一旦提交， 对数据所做的任何改变都要记录到永久存储器中， 通常就是保存进物理数据库。

数据库的事务由下列语句组成：

• 一组 DML 语句， 经过这组 DML 语句修改后的数据将保持较好的一致性。
• 一条 DDL 语句。
• 一条 DCL 语句。

DDL 和 DCL 语句最多只能有一条， 因为 DDL 和 DCL 语句都会导致事务立即提交。
当事务所包含的全部数据库操作都成功执行后， 应该提交（ commit) 事务， 使这些修改永久生效。

事务提交有两种方式： 显式提交和自动提交。

• 显式提交： 使用 commit()
• 自动提交： 执行 DDL 或 DCL 语句， 或者程序正常退出。

当事务所包含的任意一个数据库操作执行失败后， 应该回滚 （ rollback) 事务， 使该事务中所做的修改全部失效。 事务回滚有两种方式： 显式回滚和自动回滚。

• 显式回滚： 使用 rollbacko
• 自动回滚： 系统错误或者强行退出。

MySQL 默认关闭事务（ 即打开自动提交)， 在默认情况下， 用户在 MySQL 控制台输入一条 DML 语句， 这条 DML 语句将会立即保存到数据库里。 为了幵启 MySQL 的事务支持， 可以显式调用如下命令:

SET AUTOCOMMIT = {0 1 1} o 为关闭自动提交， 即开启事务

一旦在 MySQL 的命令行窗口中输入 set autocommit=0 开启了事务， 该命令行窗口里的所有 DML语句都不会立即生效， 上一个事务结束后第一条 DML 语句将开始一个新的事务， 而后续执行的所有 SQL语句都处于该事务中， 除非显式使用 commit 来提交事务， 或者正常退出， 或者运行 DDL、 DCL 语句导致事务隐式提交。 当然， 也可以使用 rollback 回滚来结束事务， 使用 rollback 结束事务将导致本次事务中 DML 语句所做的修改全部失效。

除此之外， 如果不想关闭整个命令行窗口的自动提交， 而只是想临时性地幵始事务， 则可以使用MySQL 提供的 start transaction 或 begin 两个命令， 它们都表示临时性地开始一次事务， 处于 start transaction 或 begin 后的 DML 语句不会立即生效， 除非使用 commit 显式提交事务， 或者执行 DDL、DCL 语者来隐式提交事务。 如下 SQL 代码将不会对数据库有任何影响。

# 临时开始事务
begin;
# 向 student_table 表中插入 3 条记录
insert into student_table
values(null , ‘xx‘ , 1);
insert into student_table
values(null ,‘yy‘ , 1);
insert into student table
values(null ,‘zz‘,1)
# 查询 student_table 表的记录
select * from student table;
# ①
# 回滚事务
rollback;
# 再次查询
select from student table; # ②

执行上面 SQL 语句中的第①条查询语句将会看到刚刚插入的 3 条记录， 如果打开 MySQL 的其他命令行窗口将看不到这 3 条记录一一这正体现了事务的隔离性。 接着程序 rollback 了事务中的全部修改，执行第②条查询语句时将看到数据库又恢复到事务开始前的状态。

提交， 不管是显式提交还是隐式提交， 都会结束当前事务； 回滚， 不管是显式回滚还是隐式回滚,都会结束当前事务。

除此之外， MySQL 还提供了 savepoint 来设置事务的中间点， 通过使用savepoint 设置事务的中间点可以让事务回滚到指定中间点， 而不是回滚全部事务。 如下 SQL 语句设置了一个中间点：

savepoint a;

一旦设置了中间点后， 就可以使用 rollback 回滚到指定中间点， 回滚到指定中间点的代码如下:

rollback to a;

7.1、JDBC 的事务支持

JDBC 连接也提供了事务支持， JDBC 连接的事务支持由 Connection 提供， Connection 默认打开自动提交， 即关闭事务， 在这种情况下， 每条 SQL 语句一旦执行， 便会立即提交到数据库， 永久生效，无法对其进行回滚操作。

可以调用 Connection 的 setAutoCommit()方法来关闭自动提交， 开启事务， 如下代码所示：

// 关闭自动提交， 开启事务
conn.setAutoCommit(false);

程序中还可调用 Connection 提供的 getAutoCommit()方法来返回该连接的自动提交模式。一旦事务开始之后， 程序可以像平常一样创建 Statement 对象， 创建了 Statement 对象之后， 可以执行任意多条 DML 语句， 如下代码所示：

stmt.executeUpdate( ...)；
stmt.executeUpdate(...);
stmt.executeUpdate(...);

上面这些 SQL 语句虽然被执行了， 但这些 SQL 语句所做的修改不会生效， 因为事务还没有结束。 如果所有的 SQL 语句都执行成功， 程序可以调用Connection 的 commit()方法来提交事务， 如下代码所示:

// 提交事务
conn.commit();

如果任意一条 SQL 语句执行失败， 则应该用 Connection 的 rollback()方法来回滚事务,如下代码所示:

// 回 滚 事 务
conn.rollback();

下面程序示范了当程序出现未处理的 SQLException 异常时， 系统将自动回滚事务:

import java.sql.*;
import java.io.*;
import java.util.*;

public class TransactionTest
{
	private String driver;
	private String url;
	private String user;
	private String pass;
	public void initParam(String paramFile)throws Exception
	{
		// 使用Properties类来加载属性文件
		Properties props = new Properties();
		props.load(new FileInputStream(paramFile));
		driver = props.getProperty("driver");
		url = props.getProperty("url");
		user = props.getProperty("user");
		pass = props.getProperty("pass");
	}
	public void insertInTransaction(String[] sqls) throws Exception
	{
		// 加载驱动
		Class.forName(driver);
		try(
			Connection conn = DriverManager.getConnection(url , user , pass))
		{
			// 关闭自动提交，开启事务
			conn.setAutoCommit(false);
			try(
				// 使用Connection来创建一个Statment对象
				Statement stmt = conn.createStatement())
			{
				// 循环多次执行SQL语句
				for (String sql : sqls)
				{
					stmt.executeUpdate(sql);
				}
			}
			// 提交事务
			conn.commit();
		}
	}
	public static void main(String[] args) throws Exception
	{
		TransactionTest tt = new TransactionTest();
		tt.initParam("mysql.ini");
		String[] sqls = new String[]{
			"insert into student_table values(null , ‘aaa‘ ,1)",
			"insert into student_table values(null , ‘bbb‘ ,1)",
			"insert into student_table values(null , ‘ccc‘ ,1)",
			// 下面这条SQL语句将会违反外键约束，
			// 因为teacher_table中没有ID为5的记录。
			"insert into student_table values(null , ‘ccc‘ ,5)" //①
		};
		tt.insertInTransaction(sqls);
	}
}

上面程序中的粗体字代码只是开启事务、 提交事务的代码， 并没有回滚事务的代码。 但当程序执行到 第 4 条 SQL 语句（ ①处代码） 时， 这条语句将会引起外键约束异常， 该异常没有得到处理， 引起程序非正常结束， 所以事务自动回滚。

Connection 也提供了设置中间点的方法:setSavepoint(),Connection 提供了两个方法来设置中间点。

• Savepoint setSavepoint(): 在当前事务中创建一个未命名的中间点， 并返回代表该中间点的Savepoint 对象。
• Savepoint setSavepoint(String name)： 在当前事务中创建一个具有指定名称的中间点， 并返回代表该中间点的 Savepoint 对象。

通常来说， 设置中间点时没有太大的必要指定名称， 因为 Connection 回滚到指定中间点时， 并不是根据名字回滚的， 而是根据中间点对象回滚的，Connection 提供了 rollback(Savepoint savepoint)方法回滚到指定中间点。

7.3、Java 8 增强的批量更新

JDBC 还提供了一个批量更新的功能， 使用批量更新时， 多条 SQL 语句将被作为一批操作被同时收集， 并同时提交。

使用批量更新也需要先创建一个 Statement 对象， 然后利用该对象的addBatch()方法将多条 SQL 语句同时收集起来， 最后调用 Java 8 为 Statement 对象新增的 executeLargeBatch()( 或原有的 executeBatch())方法同时执行这些 SQL 语句。 只要批量操作中任何一条 SQL 语句影响的记录条数可能超过Integer.MAX VALUE, 就应该使用 executeLargeBatch()方法， 而不是 executeBatch()方法。

如下代码片段示范了如何执行批量更新：

Statement stmt = conn.createStatement();
// 使用 Statement 同时收集多条 SQL 语句
stmt.addBatch(sqll);
stmt.addBatch(sql2);
stmt.addBatch(sql3);
……
// 同时执行所有的 SQL 语句
stmt.executeLargeBatch();

执行 executeLargeBatch()方法将返回一个 long[]数组， 因为使用 Statement 执行 DDL、 DML 语句都将返回一个 long 值， 而执行多条 DDL、 DML 语句将会返回多个 long 值， 多个 long 值就<