JAVA基礎知識之JDBC——離線RowSet

離線RowSet

如果直接使用ResultSet, 程序在得到ResultSet記錄之后需要立即使用，否則一旦關閉Connection就不再可用，要解決這種情況要么將ResultSet的結果轉換成JavaBean存儲，要么在Connection關閉之前完成所有操作，不過這些辦法都不太方便。

但是通過離線的RowSet卻能很好地解決這個問題。RowSet可以將ResultSet的結果集封裝成RowSet對象，存儲在內存中進行數據操作，而Connection則可以斷開。直到數據操作完成之后，重新再連接數據庫，進行數據同步即可。下面以CachedRowSet為例演示離線RowSet的用法，

package db;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import javax.sql.rowset.CachedRowSet;
import javax.sql.rowset.RowSetFactory;
import javax.sql.rowset.RowSetProvider;

public class CachedRowSetTest {
    private static String driver;
    private static String url;
    private static String user;
    private static String pass;
    public void initParam(String paramFile) throws FileNotFoundException, IOException, ClassNotFoundException {
        //用Properties類加載屬性文件
        Properties prop = new Properties();
        prop.load(new FileInputStream(paramFile));
        driver = prop.getProperty("driver");
        url = prop.getProperty("url");
        user = prop.getProperty("user");
        pass = prop.getProperty("pass");
        Class.forName(driver);
    }
    public CachedRowSet query(String sql) throws SQLException {
        Connection conn = DriverManager.getConnection(url,user,pass);
        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery(sql);
        RowSetFactory factory = RowSetProvider.newFactory();
        CachedRowSet cachedRs = factory.createCachedRowSet();
        //使用ResultSet裝填RowSet
        cachedRs.populate(rs);
        rs.close();
        stmt.close();
        conn.close();
        return cachedRs;
    }
    public static void main(String[] args) throws FileNotFoundException, ClassNotFoundException, IOException, SQLException {
        CachedRowSetTest ct = new CachedRowSetTest();
        ct.initParam("mysql.ini");
        CachedRowSet rs = ct.query("select * from jdbc_test");
        rs.afterLast();
        while (rs.previous()) {
            System.out.println(rs.getInt(1)+"\t"+rs.getString(2)+"\t"+rs.getString(3));
            if (rs.getInt(1) == 3) {
                rs.updateString(3,"小強");
                rs.updateRow();
            }
        }
        //重新后去數據庫連接
        Connection conn = DriverManager.getConnection(url,user,pass);
        conn.setAutoCommit(false);
        rs.acceptChanges(conn);
    }
}

程序執行結果，

27    學生名27    學生名28
26    學生名26    學生名27
25    學生名25    學生名26
24    學生名24    學生名25
23    學生名23    學生名24
22    學生名22    學生名23
21    學生名21    學生名22
20    學生名20    學生名21
19    學生名19    學生名20
18    學生名18    學生名19
17    學生名17    學生名18
16    學生名16    學生名17
15    學生名15    學生名16
14    學生名14    學生名15
13    學生名13    學生名14
12    學生名12    學生名13
11    學生名11    學生名12
10    學生名10    學生名11
9    學生名9    學生名10
8    學生名8    學生名9
7    學生名7    學生名8
6    學生名6    學生名7
5    學生名5    學生名6
4    學生名4    學生名5
3    小明    小強
2    學生名2    學生名3
1    學生名1    學生名2

離線RowSet查詢分頁

所謂分頁，就是一次只裝載ResultSet的某幾條記錄，這樣可以避免CachedRowSet內存占用過大的問題。

CachedRowSet有如下方法控制分頁，

populate(ResultSet rs, int startRow) , 從第startRow行開始裝載

setPageSize(int pageSize), 設置每頁大小

previousPage(); 在底層ResultSet可用情況下，讓CachedRowSet讀取上一頁記錄

nextPage() 在底層ResultSet可用情況下，讓CachedRowSet讀取下一頁記錄

下面演示CachedRowSet分頁用法，

package db;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import javax.sql.rowset.CachedRowSet;
import javax.sql.rowset.RowSetFactory;
import javax.sql.rowset.RowSetProvider;

public class CachedRowSetPage {
    private String driver;
    private String url;
    private String user;
    private String pass;
    public void initParam(String paramFile) throws FileNotFoundException, IOException, ClassNotFoundException {
        //用Properties類加載屬性文件
        Properties prop = new Properties();
        prop.load(new FileInputStream(paramFile));
        driver = prop.getProperty("driver");
        url = prop.getProperty("url");
        user = prop.getProperty("user");
        pass = prop.getProperty("pass");
        Class.forName(driver);
    }

    public CachedRowSet query(String sql, int pageSize, int page)
            throws SQLException {
        try (
                Connection conn = DriverManager.getConnection(url, user, pass);
                Statement stmt = conn.createStatement();
                ResultSet rs = stmt.executeQuery(sql)
                ) {
            RowSetFactory factory = RowSetProvider.newFactory();
            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 FileNotFoundException, ClassNotFoundException, IOException, SQLException {
        CachedRowSetPage cp = new CachedRowSetPage();
        cp.initParam("mysql.ini");
        //設置每頁顯示3條記錄， 讀取第2頁的記錄
        CachedRowSet rs = cp.query("select * from jdbc_test", 3, 2);
        rs.afterLast();
        while (rs.previous()) {
            System.out.println(rs.getInt(1)+"\t"+rs.getString(2)+"\t"+rs.getString(3));
        }
    }
}

執行結果，只顯示了第2頁的數據

6    學生名6    學生名7
5    學生名5    學生名6
4    學生名4    學生名5