13.6.3 离线RowSe的查询分页

• 13.6.3 离线RowSet的查询分页

13.6.3 离线RowSet的查询分页

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

方法	描述
populate(Resultset rs, int startRow)	使用给定的Resultset装填RowSet,从Resultset的第startRow条记录开始装填。
setPageSize(int pageSize)	设置CachedRowSet每次返回多少条记录。
previousPage()	在底层Resultset可用的情况下,让CachedSet读取上一页记录。
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
	{
		// 1.加载驱动
		Class.forName(driver);
		try (
				// 2.获取数据库连接
				Connection conn = DriverManager.getConnection(url, user, pass);
				// 3.创建Statement对象
				Statement stmt = conn.createStatement();
				// 4.使用Statement对象执行SQL语句
				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));
		}
	}
}

CachedRowSet实现分页的关键代码如下:

// 设置每页显示pageSize条记录
cachedRs.setPageSize(pageSize);
// 使用ResultSet装填RowSet，设置从第几条记录开始
cachedRs.populate(rs, (page - 1) * pageSize + 1);

程序中①号代码显示要査询第2页的记录,每页显示3条记录。运行上面程序,可以看到程序只会显示从第4行到第6行的记录,这就实现了分页。

原文链接: 13.6.3 离线RowSe的查询分页