JDBC RowSet的使用

1 什么是JDBC的RowSet？

与ResultSet相比，RowSet默认是可滚动、可更新、可序列化的结果集，而且作为JavaBean使用，因此能方便的在网络上传输，用于同步两端的数据，对于离线RowSet而言，程序在创建RowSet时已经把数据从底层数据库读取到了内存，因此可以充分利用计算机的内存，从而降低数据库服务器的负载，提高程序性能。RowSet接口继承了ResultSet接口。

RowSet接口的实现类如下：

• JdbcRowSet
• CachedRowSet
• WebRowSet
• JoinRowSet
• FilteredRowSet

2 RowSet的好处

使用RowSet的优点如下：

• RowSet扩展了ResultSet接口，因此它的功能比ResultSet更加强大。
• RowSet对表数据的遍历更加灵活，可前后滚动。
• RowSet支持缓存数据，即在Connection关闭后也可以使用。
• RowSet支持新的连接方式，无需Connection即可连接数据库，还支持读取XML数据源。
• RowSet支持Filter（过滤数据）。
• RowSet还支持表的Join操作。

3 RowSet核心代码示例

JdbcRowSet rowSet = RowSetProvider.newFactory().createJdbcRowSet();
rowSet.setUrl("jdbc:mysql://localhost:3306/test");
rowSet.setUsername("root");
rowSet.setPassword("root");

rowSet.setCommand("select * from t_user");
rowSet.execute();

4 没有事件监听的RowSet示例

4.1 编写测试类

NoListenerRowSetDemo：

package com.yiidian;

import javax.sql.rowset.JdbcRowSet;
import javax.sql.rowset.RowSetProvider;
import java.io.*;
import java.sql.*;

/**
 * 一点教程网 - http://www.yiidian.com
 */
public class NoListenerRowSetDemo {
    public static void main(String args[])throws Exception {
        Class.forName("com.mysql.jdbc.Driver");

        JdbcRowSet rowSet = RowSetProvider.newFactory().createJdbcRowSet();
        rowSet.setUrl("jdbc:mysql://localhost:3306/test");
        rowSet.setUsername("root");
        rowSet.setPassword("root");

        rowSet.setCommand("select * from t_user");
        rowSet.execute();

        //移动光标，获取记录
        while (rowSet.next()) {
            System.out.print("编号: " + rowSet.getInt(1)+"\t");
            System.out.print("名称: " + rowSet.getString(2)+"\t");
            System.out.print("密码: " + rowSet.getString(3));
            System.out.println();
        }

    }
}

4.2 运行测试

5 有事件监听的RowSet示例

要使用JdbcRowSet执行事件处理，您需要在JdbcRowSet的addRowSetListener() 方法中添加RowSetListener的实例。

RowSetListener接口提供3种必须实现的方法：

1. public void cursorMoved(RowSetEvent event);
2. public void rowChanged(RowSetEvent event);
3. public void rowSetChanged(RowSetEvent event);

5.1 编写测试类

HasListenerRowSetDemo：

package com.yiidian;

import javax.sql.RowSetEvent;
import javax.sql.RowSetListener;
import javax.sql.rowset.JdbcRowSet;
import javax.sql.rowset.RowSetProvider;
import java.io.*;
import java.sql.*;

/**
 * 一点教程网 - http://www.yiidian.com
 */
public class HasListenerRowSetDemo {
    public static void main(String args[])throws Exception {
        Class.forName("com.mysql.jdbc.Driver");

        JdbcRowSet rowSet = RowSetProvider.newFactory().createJdbcRowSet();
        rowSet.setUrl("jdbc:mysql://localhost:3306/test");
        rowSet.setUsername("root");
        rowSet.setPassword("root");

        rowSet.setCommand("select * from t_user");
        rowSet.execute();

        //给RowSet添加事件监听处理
        rowSet.addRowSetListener(new MyListener());

        //移动光标，获取记录
        while (rowSet.next()) {
            System.out.print("编号: " + rowSet.getInt(1)+"\t");
            System.out.print("名称: " + rowSet.getString(2)+"\t");
            System.out.print("密码: " + rowSet.getString(3));
            System.out.println();
        }

    }
}

//事件监听处理类
class MyListener implements RowSetListener {
    public void cursorMoved(RowSetEvent event) {
        System.out.println("光标移动...");
    }
    public void rowChanged(RowSetEvent event) {
        System.out.println("光标改变...");
    }
    public void rowSetChanged(RowSetEvent event) {
        System.out.println("RowSet改变...");
    }
}

5.2 运行测试