Go语言视频零基础入门到精通

javalearner

如果在开发应用的时候没有使用任何持久层框架，而是直接使用jdbc 的api编程的话，大家最长使用的就是ResultSet接口进行数据的读取了，但是大家也会觉得很不方便，因为ResultSet是在线的数据集，在读取数据的过程中不能断开数据库联接，只有读取数据完成后才能close掉相关对象。

     其实java也提供了离线的数据集，那就是RowSet接口以及相关的 子接口。而且sun在jdk里面提供一个默认的实现，而且象oracle这样比较大型的数据库驱动里面也提供自己的RowSet实现。

     下面以sun的默认 实现来说明离线数据的使用吧，数据库为sql Server 2000，连接的数据库为Northwind。
   
  
   
   
     
   

     
   
  

1. import java.sql.Connection;
   
2. import java.sql.DriverManager;
   
3. import java.sql.ResultSet;
   
4. import java.sql.SQLException;
   
5. import java.sql.Statement;
   
6. import javax.sql.RowSet;
   
7. import com.sun.rowset.CachedRowSetImpl;
   
8. public class RowSetDemo {
   
9.     public static RowSet query(Connection connection, String sql)
   
10.             throws SQLException {
    
11.         //使用sun的默认RowSet实现
    
12.         CachedRowSetImpl rowset = new CachedRowSetImpl();
    
13.         //查询没有任何变化
    
14.         Statement statement = connection.createStatement();
    
15.         ResultSet rs = statement.executeQuery(sql);
    
16.         //这里就是填充离线集
    
17.         rowset.populate(rs);
    
18.         //都可以关闭了，爽吧
    
19.         rs.close();
    
20.         statement.close();
    
21.         return rowset;
    
22.     }
23. 
    
24.     public static void main(String[] args) throws Exception {
    
25.         Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
    
26.         String connectionUrl = "jdbc:sqlserver://127.0.0.1:1433;database=Northwind;user=sa;password=huhuiyu";
    
27.         Connection connection = DriverManager.getConnection(connectionUrl);
    
28.         RowSet rs = query(connection, "select * from Customers order by CustomerID;");
    
29.         //关闭连接也没有关系了。
    
30.         connection.close();
    
31.         //和ResultSet使用一样。
    
32.         while (rs.next()) {
    
33.             System.out.print(rs.getString(1) + " : ");
    
34.             System.out.println(rs.getString("CompanyName"));
    
35.         }
    
36.     }
    
37. }
39. 运行上面的例子就会将Customers的前两列的数据显示出来。其实RowSet还可以完成分页的功能。请看下面的方法。
40. 
    
41. public static RowSet query(Connection connection, String sql, int pageSize,
    
42.             int pageNumber) throws SQLException {
    
43.         CachedRowSetImpl rowset = new CachedRowSetImpl();
    
44.         //要是可以滚动的结果集
    
45.         Statement statement = connection.createStatement(
    
46.                 ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
    
47.         ResultSet rs = statement.executeQuery(sql);
    
48.         //设定分页大小
    
49.         rowset.setPageSize(pageSize);
    
50.         //计算一下开始游标位置
    
51.         int skip=(pageNumber - 1) * pageSize + 1;
    
52.         //可以填充了
    
53.         rowset.populate(rs, skip);
    
54.         rs.close();
    
55.         statement.close();
    
56.         return rowset;
    
57.     }
    
58.     public static void main(String[] args) throws Exception {
    
59.         Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
    
60.         String connectionUrl = "jdbc:sqlserver://127.0.0.1:1433;database=Northwind;user=sa;password=huhuiyu";
    
61.         Connection connection = DriverManager.getConnection(connectionUrl);
    
62.         //分页查询
    
63.         RowSet rs = query(connection, "select * from Customers order by CustomerID;",5,2);
    
64.         //关闭连接也没有关系了。
    
65.         connection.close();
    
66.         //和ResultSet使用一样。
    
67.         while (rs.next()) {
    
68.             System.out.print(rs.getString(1) + " : ");
    
69.             System.out.println(rs.getString("CompanyName"));
    
70.         }
    
71.     }
    
73. 如果你不使用持久层，那么使用离线数据集可以很好的解决分页和数据库连接的问题。
74. 希望这篇入门的教程能够帮助到你。
    

复制代码

  
  
   
   

     
   

     
   
  

复制代码