普通结果集ResultSet和离线结果集RowSet

Posted myitnews

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了普通结果集ResultSet和离线结果集RowSet相关的知识,希望对你有一定的参考价值。

数据库的查询操作会得到一系列数据,JDBC API也提供了相关对象来接收查询结果集。

一、ResultSet

java.sql.ResultSet接口表示数据库查询的结果集。

JDBC提供以下连接方法来创建具有所需ResultSet的语句:

  • createStatement(int RSType, int RSConcurrency);
  • prepareStatement(String SQL, int RSType, int RSConcurrency);
  • prepareCall(String sql, int RSType, int RSConcurrency);

RSType参数表示ResultSet对象的类型,RSConcurrency是两个ResultSet常量之一,用于指定结果集是只读还是可更新。

1. ResultSet类型

ResultSet.TYPE_FORWARD_ONLY:光标只能在结果集中向前移动。
ResultSet.TYPE_SCROLL_INSENSITIVE:光标可以向前和向后滚动,结果集对创建结果集后发生的数据库所做的更改不敏感。
ResultSet.TYPE_SCROLL_SENSITIVE:光标可以向前和向后滚动,结果集对创建结果集之后发生的其他数据库的更改敏感。

如果不指定任何ResultSet类型,默认是TYPE_FORWARD_ONLY值。

2. ResultSet的并发性

ResultSet.CONCUR_READ_ONLY 创建只读结果集
ResultSet.CONCUR_UPDATABLE 创建可更新的结果集
如果不指定任何并发类型,默认是CONCUR_READ_ONLY值。

3. 查看结果集

ResultSet接口包含数十种获取当前行数据的方法。
每个可能的数据类型都有一个get方法,每个get方法有两个版本,一个是采用列名称,一个是采用列索引(从1开始)。

注意:ResultSet在数据库连接关闭后(close掉)后就不能使用了,必须一直保持连接的状态才能使用,否则需要使用到RowSet离线结果集。

二、RowSet

RowSet接口继承自ResultSet接口。与ResultSet相比,RowSet默认是可滚动、可更新、可序列化的结果集,可以作为JavaBean来方便地在网络上传输,用于同步两端数据。对于离线RowSet而言,程序从创建RowSet时就已经把数据load进内存,因此可以更好地利用内存性能,降低数据库服务器的负载,提高程序性能。

1. 什么是离线结果集

如果直接使用ResultSet, 程序在得到ResultSet记录之后需要立即使用,否则一旦关闭Connection就不再可用,要解决这种情况要么将ResultSet的结果转换成JavaBean存储,要么在Connection关闭之前完成所有操作,不过这些办法都不太方便。

但是通过离线的RowSet却能很好地解决这个问题。RowSet可以将ResultSet的结果集封装成RowSet对象,存储在内存中进行数据操作,而Connection则可以断开。直到数据操作完成之后,重新再连接数据库,进行数据同步即可。

总结起来就是说,RowSet可以把数据库的数据放在内存中进行离线读写操作,操作完成之后再同步到数据库中去。

RowSet接口下包含了JdbcRowSet, CachedRowSet, FilteredRowSet, JoinRowSet, WebRowSet,除了JdbcRowSet之外,后面四个都是离线RowSet。

2. RowSetFactory

在JDK1.6及以前的版本中,如果要使用JdbcRowSet,则必须使用JdbcRowSetImpl的构造器来构造对象,但是在编译的时候会有警告,因此JdbcRowSetImpl是内部专用的API,在未来版本可能会删除。这种获取JdbcRowSet的方式是不推荐的,因为使用内部API,在将来的版本中可能不兼容,而且这样的程序直接与具体的实现类JdbcRowSetImpl耦合,不利于维护和升级。

在JDK1.7中,引入了RowSetFactory和RowSetProvider接口,其中RowSetProvider负责创建RowSetFactory,而RowSetFactory则可以通过以下方法创建RowSet实例。

  • createCachedRowSet()
  • createFilteredRowSet()
  • createJdbcRowSet()
  • createJoinRowSet()
  • createWebRowSet()

创建对象时可以传入ResultSet实例填充RowSet,也可以在创建JdbcRowSet实例之后通过execute(sql)方法得到数据填充RowSet。

//创建RowSetFactory
RowSetFactory rowSetFactory = RowSetProvider.newFactory();
//创建指定的RowSet
CachedRowSet rowSet = rowSetFactory.createCachedRowSet();
//将ResultSet放到RowSet中
rowSet.populate(resultSet);

3. 离线查询分页

所谓分页,就是一次只装载ResultSet的某几条记录,这样可以避免CachedRowSet内存占用过大的问题。

CachedRowSet控制分页的方法:

  • populate(ResultSet rs, int startRow) , 从第startRow行开始装载
  • setPageSize(int pageSize), 设置每页大小
  • previousPage(); 在底层ResultSet可用情况下,让CachedRowSet读取上一页记录
  • nextPage() 在底层ResultSet可用情况下,让CachedRowSet读取下一页记录
import javax.sql.rowset.CachedRowSet;
import javax.sql.rowset.RowSetFactory;
import javax.sql.rowset.RowSetProvider;
import java.sql.*;

public class ConnectionManager {
    private static final String URL = "jdbc:mysql://192.168.178.5:12345/cloudDB01";
    private static final String USER_NAME = "root";
    private static final String PASSWORD = "123456";
    
    
    static{
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            System.out.println("加载MySQL数据库驱动失败");
        }
    }

    public static void main(String[] args) throws Exception{
        String sql = "select * from dept";
        Connection connection = DriverManager.getConnection(URL,USER_NAME, PASSWORD);
        PreparedStatement psmt = connection.prepareStatement(sql);
        ResultSet resultSet = psmt.executeQuery();

        RowSetFactory rowSetFactory = RowSetProvider.newFactory();
        CachedRowSet rowSet = rowSetFactory.createCachedRowSet();
        rowSet.setPageSize(2);
        rowSet.populate(resultSet, 2);//从第二行开始
        while (rowSet.next()){
            System.out.println(rowSet.getString(2));
        }
    }
}

注:CachedRowSet是一次性加载所有数据,是内存分页,并不是物理分页,实际开发中用到的也较少。

 

以上是关于普通结果集ResultSet和离线结果集RowSet的主要内容,如果未能解决你的问题,请参考以下文章

ResultSet 异常 - 在结果集开始之前

JDBC结果集

JDBC——ResultSet结果集对象

Java之判断ResultSet结果集是否为空

使用ResultSet结果集查询数据

junit如何测试ResultSet结果集