`
landy
  • 浏览: 8311 次
最近访客 更多访客>>
文章分类
社区版块
存档分类
最新评论

用 Java 5 RowSet 新特性访问 IBM DB2 数据库

IBMJavaDB2SQLXML 
阅读更多

2006 年 4 月 10 日

Java 5 在 Java Database Connectivity (JDBC) 方面加强了支持，其中加入了新的包 javax.sql.rowset，javax.sql.rowset.serial，javax.sql.rowset.spi。本文将通过实例来演示这些新的特性。

RowSet 新特性简介

Java 5在Java Database Connectivity (JDBC)方面加强了支持，其中加入了新的包javax.sql.rowset，javax.sql.rowset.serial，javax.sql.rowset.spi。从RowSet接口继承规定了五个新的接口：

1. CachedRowSet： CachedRowset可以不用与数据源建立长期的连接，只有当从数据库读取数据或是往数据库写入数据的时候才会与数据库建立连接，它提供了一种轻量级的访问数据库的方式，其数据均存在内存中。

2. JdbcRowSet：对ResultSet的对象进行包装，使得可以将ResultSet对象做为一个JavaBeans ™ 组件。

3. FilteredRowSet：继承自CachedRowSet，可以根据设置条件得到数据的子集。

4. JoinRowSet：继承自CachedRowSet，可以将多个RowSet对象进行SQL Join语句的合并。

5. WebRowSet：继承自CachedRowSet，可以将WebRowSet对象输出成XML格式。

下面分别演示如何使用这五个新接口。

实验环境

IBM DB2 Universal 8.1
数据库名：DemoDB
数据库用户名：db2admin
数据库密码：password


回页首


CachedRowSet

CachedRowSet可以通过调用populate(ResuletSet rs)来生成数据，一旦获得数据，CachedRowSet就可以断开与数据库的连接，直到往数据库写入数据的时候才需建立连接。

可以使用自己扩展的或是使用Reference Implement的实现类进行访问数据库。下面的代码演示了如何根据ResultSet建立一个CachedRowSet对象，在中断与数据库连接的情况下，读取数据，并做更新，最后再获取数据库连接，将更新落实到数据库中。


                        
                            public static void testCachedRowSet(){
  Connection conn = null;
  try {
    // 获得数据库连接
      conn= DriverManager.getConnection(DB2URL, DB2USER, DB2PASSWORD);
      Statement stmt = conn.createStatement();
      // 查询数据库，获得表数据
      ResultSet rs = stmt.executeQuery("select * from student");//$NON-NLS-1$
      // 根据ResultSet对象生成CachedRowSet类型的对象
      CachedRowSetImpl crs = new CachedRowSetImpl();
      crs.populate(rs);
      // 关闭ResultSet
    rs.close();
      // 关闭数据库的连接
      conn.close();
      // 在中断与数据库连接的情况下，对CachedRowSet进行操作
      operateOnRowSet(crs);
      // 重新获取与数据库的连接
      conn= DriverManager.getConnection(DB2URL, DB2USER, DB2PASSWORD);
      // 将CachedRowSet的内容更新到数据库
      crs.acceptChanges(conn);
      // 关闭CachedRowSet
      crs.close();
      // 关闭数据库连接
      conn.close();
  } catch (InstantiationException e) {
      System.out.println("Andrew: InstantiationException!");//$NON-NLS-1$
  } catch (IllegalAccessException e) {
      System.out.println("Andrew: IllegalAccessException!");//$NON-NLS-1$
  } catch (ClassNotFoundException e) {
      System.out.println("Andrew: ClassNotFoundException!");//$NON-NLS-1$
  }catch (SQLException e) {
      System.out.println("Andrew: SQLException!");//$NON-NLS-1$
    e.printStackTrace();
  }  
}

其中operateOnRowSet方法遍历读取RowSet中的元素，并将id值加1。RowSet允许注册监听器，可以在光标移动，RowSet发生改变时触发。其具体代码如下：


                        
                            public static void operateOnRowSet(RowSet rs){
  // 为RowSet注册监听器
  MyRowsetListener myListener = new MyRowsetListener();
    rs.addRowSetListener(myListener);
    // 操作RowSet数据
  try{
    // 遍历读取数据
    while (rs.next()) {
      String id = rs.getString("ID");//$NON-NLS-1$
          String name = rs.getString("NAME");//$NON-NLS-1$
          System.out.println("ID="+id+",NAME="+name);//$NON-NLS-1$
          //在id最末位连接"1"
          rs.updateString(1, id+"1");
      }
  }catch (SQLException e) {
      System.out.println("Andrew: SQLException!");//$NON-NLS-1$
    e.printStackTrace();
  }
}
class MyRowsetListener implements RowSetListener{
  // 光标发生移动
  public void cursorMoved(RowSetEvent event) {
    System.out.println("cursor moved");
  }
  // row发生改变
  public void rowChanged(RowSetEvent event) {
    System.out.println("row changed");
  }
  // RowSet发生改变
  public void rowSetChanged(RowSetEvent event) {
    System.out.println("row set changed");
  }
}
public static void main(String[] args) {
  try {
    Class.forName(DB2DRIVER).newInstance();
  } catch (InstantiationException e) {
    System.out.println("Andrew: InstantiationException!");//$NON-NLS-1$
  } catch (IllegalAccessException e) {
    System.out.println("Andrew: IllegalAccessException!");//$NON-NLS-1$
  } catch (ClassNotFoundException e) {
    System.out.println("Andrew: ClassNotFoundException!");//$NON-NLS-1$
  }
  testCachedRowSet();
}

上面的程序的运行结果如下：


                        
                            cursor moved
ID=001,NAME=zhou
cursor moved
ID=002,NAME=zhang
cursor moved
cursor moved
cursor moved
cursor moved
cursor moved
cursor moved
row set changed

并且数据库中的id更新为0011，0021。


回页首


JdbcRowSet

JdbcRowSet功能与ResultSet类似，与CachedRowSet不同，JdbcRowSet在操作时保持与数据库的连接。可以将与数据库连接的URL，用户名，密码以及执行的SQL语句通过setXXX形式绑定。另外，JdbcRowSet返回的结果默认是可以上下滚动和可更新的，当然这需要数据库厂商提供的JDBC Driver支持。下面的代码演示了如何通过set方法设定数据库连接参数，以及如何操作JdbcRowSet对象。


                        
                            public static void testJdbcRowSet() {
  JdbcRowSetImpl jrs = new JdbcRowSetImpl();
  try {
    // 设置连接数据库的URL
    jrs.setUrl(DB2URL);
    // 设置连接数据库的用户名
    jrs.setUsername(DB2USER);
    // 设置连接数据库的密码
    jrs.setPassword(DB2PASSWORD);
    // 设置执行数据库的SQL语句
    jrs.setCommand("select * from student");
    // 执行操作
    jrs.execute();
    // 对获得的JdbcRowSet进行操作
    operateOnRowSet(jrs);
    // 关闭JdbcRowset
    jrs.close();
  } catch (SQLException e) {
    System.out.println("Andrew: SQLException!");//$NON-NLS-1$
    e.printStackTrace();
  }
}

public static void operateOnRowSet(RowSet rs) {
  // 为RowSet注册监听器
  MyRowsetListener myListener = new MyRowsetListener();
  rs.addRowSetListener(myListener);
  // 操作RowSet数据
  try {
    // 遍历读取数据
    while (rs.next()) {
      String id = rs.getString("ID");//$NON-NLS-1$
      String name = rs.getString("NAME");//$NON-NLS-1$
      System.out.println("ID=" + id + ",NAME=" + name);//$NON-NLS-1$
    }
  } catch (SQLException e) {
    System.out.println("Andrew: SQLException!");//$NON-NLS-1$
    e.printStackTrace();
  }
}

其运行结果如下：


                        
                            cursor moved
ID=0011,NAME=zhou
cursor moved
ID=0021,NAME=zhang
cursor moved





回页首


FilteredRowSet

FilteredRowSet接口中规定了可以设定过滤器，其过滤接口为Predicate接口，必须实现Predicate接口中的evaluate方法。具体的代码如下：


                        
                            public static void testFilteredRowSet() {
  try {
    // 获得数据库连接
    Connection conn = DriverManager.getConnection(DB2URL, DB2USER,
      DB2PASSWORD);
    Statement stmt = conn.createStatement();
    // 查询数据库，获得表数据
    ResultSet rs = stmt.executeQuery("select * from student");//$NON-NLS-1$
    FilteredRowSet frs = new FilteredRowSetImpl();
    frs.populate(rs);
    // 设置过滤器
    MyDBFilter filter = new MyDBFilter(11, 100);
    frs.setFilter(filter);
    operateOnRowSet(frs);
    // 关闭FilteredRowSet
    frs.close();
    // 关闭与数据库的连接
    conn.close();
  } catch (SQLException e) {
    System.out.println("Andrew: SQLException!");//$NON-NLS-1$
    e.printStackTrace();
  }
}

public static void operateOnRowSet(RowSet rs) {
  // 为RowSet注册监听器
  System.out.println("operateOnRowSet!");//$NON-NLS-1$
  MyRowsetListener myListener = new MyRowsetListener();
  rs.addRowSetListener(myListener);
  // 操作RowSet数据
  try {
    // 遍历读取数据
    while (rs.next()) {
      String id = rs.getString("ID");//$NON-NLS-1$
      String name = rs.getString("NAME");//$NON-NLS-1$
      System.out.println("ID=" + id + ",NAME=" + name);//$NON-NLS-1$
    }
  } catch (SQLException e) {
    System.out.println("Andrew: SQLException!");//$NON-NLS-1$
    e.printStackTrace();
  }
}

public static void main(String[] args) {
  try {
    Class.forName(DB2DRIVER).newInstance();
  } catch (InstantiationException e) {
    System.out.println("Andrew: InstantiationException!");//$NON-NLS-1$
  } catch (IllegalAccessException e) {
    System.out.println("Andrew: IllegalAccessException!");//$NON-NLS-1$
  } catch (ClassNotFoundException e) {
    System.out.println("Andrew: ClassNotFoundException!");//$NON-NLS-1$
  }
  testFilteredRowSet();
}

其中MyDBFilter实现了Predicate接口，其实现代码如下：


                        
                            class MyDBFilter implements Predicate {
  private int low;
  private int high;
  public MyDBFilter(int low, int high) {
    this.low = low;
    this.high = high;
  }
  public boolean evaluate(RowSet rs) {
    CachedRowSet crs=(CachedRowSet)rs;
    //如果id在low和high之间返回真
    try {
      String id = (String) crs.getString("id");
      int idValue = Integer.parseInt(id);
      if (low < idValue && idValue < high) {
        return true;
      }
    } catch (SQLException e) {
      
    }
    return false;
  }
  public boolean evaluate(Object arg0, int arg1) throws SQLException {
    return false;
  }

  public boolean evaluate(Object arg0, String arg1) throws SQLException {
    return false;
  }
}

其运行结果如下：


                        
                            cursor moved
ID=0021,NAME=zhang
cursor moved





回页首


JoinRowSet

JoinRowSet可以将多个RowSet对象进行join合并，Join的列可以通过每个RowSet通过调用setMatchColumn方法来设置。setMatchColumn方式是Joinable接口定义的方法，五种类型的RowSet规定都需要实现该接口。下面的代码演示将student表和intern表中id相同的数据进行join操作。JoinRowSet不需要保持与数据库的连接。


                        
                            public static void testJoinRowSet(){
  Connection conn = null;
  try {
    JoinRowSet jrs = new JoinRowSetImpl();
    // 获得数据库连接
    conn = DriverManager.getConnection(DB2URL, DB2USER, DB2PASSWORD);
    Statement stmt = conn.createStatement();
    // 查询数据库，获得表数据
    ResultSet rs1 = stmt.executeQuery("select id,name from student");//$NON-NLS-1$
    // 根据ResultSet对象生成CachedRowSet类型的对象
    CachedRowSetImpl crs1 = new CachedRowSetImpl();
    crs1.populate(rs1);
    crs1.setMatchColumn(1);
    // 关闭ResultSet
    jrs.addRowSet(crs1);
    rs1.close();
    
    // 查询数据库，获得表数据
    ResultSet rs2 = stmt.executeQuery("select id,company from intern");//$NON-NLS-1$
    // 根据ResultSet对象生成CachedRowSet类型的对象
    CachedRowSetImpl crs2 = new CachedRowSetImpl();
    crs2.populate(rs2);
    crs2.setMatchColumn(1);
    // 关闭ResultSet
    rs2.close();
    // 将Result2放入JoinRowSet中进行Join操作
    jrs.addRowSet(crs2);
    // 关闭数据库连接
    conn.close();
    
    while (jrs.next()) {
      String id = jrs.getString(1);
      String name = jrs.getString(2);
      String company = jrs.getString(3);
      //$NON-NLS-1$
      System.out.println("ID=" + id + ",NAME=" + name+",COMPNAY="+company);
    }
  } catch (SQLException e) {
    System.out.println("Andrew: SQLException!");//$NON-NLS-1$
    e.printStackTrace();
  }
}

其输出结果为


                        
                            ID=001111,NAME=zhou,COMPNAY=companyA





回页首


WebRowSet

WebRowSet继承自CachedRowSet，支持XML格式的查询，更新等操作，下面的代码将WebRowSet对象输出成XML格式到文件。


                        
                            public static void testWebRowSet(){
  try {
    // 获得数据库连接
    Connection conn = DriverManager.getConnection(DB2URL, DB2USER,
        DB2PASSWORD);
    Statement stmt = conn.createStatement();
    // 查询数据库，获得表数据
    ResultSet rs = stmt.executeQuery("select * from student");//$NON-NLS-1$
    WebRowSetImpl wrs = new WebRowSetImpl();
    wrs.populate(rs);
    FileOutputStream out = new FileOutputStream("data.xml");
    wrs.writeXml(out);
    wrs.close();
    // 关闭与数据库的连接
    conn.close();
  } catch (SQLException e) {
    System.out.println("Andrew: SQLException!");//$NON-NLS-1$
    e.printStackTrace();
  } catch(IOException e){
    System.out.println("Andrew: IOException!");//$NON-NLS-1$
    e.printStackTrace();
  }
}

其运行结果data.xml大致如下：


                        
                            <?xml version="1.0"?>
XML文件属性格式 
……
<metadata>
    <column-count>2</column-count>
    <column-definition>
      <column-index>1</column-index>
      <auto-increment>false</auto-increment>
      <case-sensitive>true</case-sensitive>
      <currency>false</currency>
      <nullable>0</nullable>
      <signed>false</signed>
      <searchable>true</searchable>
      <column-display-size>10</column-display-size>
      <column-label>ID</column-label>
      <column-name>ID</column-name>
      <schema-name>ZHOUDP  </schema-name>
      <column-precision>10</column-precision>
      <column-scale>0</column-scale>
      <table-name>STUDENT</table-name>
      <catalog-name>TEST</catalog-name>
      <column-type>12</column-type>
      <column-type-name>VARCHAR</column-type-name>
    </column-definition>
    <column-definition>
      <column-index>2</column-index>
      <auto-increment>false</auto-increment>
      <case-sensitive>true</case-sensitive>
      <currency>false</currency>
      <nullable>1</nullable>
      <signed>false</signed>
      <searchable>true</searchable>
      <column-display-size>50</column-display-size>
      <column-label>NAME</column-label>
      <column-name>NAME</column-name>
      <schema-name>ZHOUDP  </schema-name>
      <column-precision>50</column-precision>
      <column-scale>0</column-scale>
      <table-name>STUDENT</table-name>
      <catalog-name>TEST</catalog-name>
      <column-type>12</column-type>
      <column-type-name>VARCHAR</column-type-name>
    </column-definition>
  </metadata>
  <data>
    <currentRow>
      <columnValue>0011</columnValue>
      <columnValue>zhou</columnValue>
    </currentRow>
    <currentRow>
      <columnValue>0021</columnValue>
      <columnValue>zhang</columnValue>
    </currentRow>
  </data>
</webRowSet>



独孤过客 2006-06-10 19:43 发表评论
分享到：
| 小谈SDO
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    java的rowset工具包

    Java的RowSet工具包是Java数据库连接（JDBC）API的一部分，它提供了一种更为灵活的方式来处理数据库数据。RowSet接口及其相关实现是基于JavaBeans组件模型，允许数据在不直接连接到数据库的情况下进行操作，这被称为...

    Java 6 RowSet 使用完全剖析

    Java 6 RowSet 使用完全剖析

    RowSetDemo.zip java 5新特性

    `RowSet`是Java数据库连接（JDBC）API的一部分，它为处理和缓存数据库数据提供了离线、滚动和可更新的能力。下面将详细介绍`RowSet`以及Java 5中其他关键的新特性。 1. **类型安全的枚举（Enums）** 在Java 5之前...

    rowset

    Rowset是Java数据库连接（JDBC）中的一个重要概念，它是一种可以脱离数据库连接的数据集合，允许程序员在不保持与数据库的持续连接的情况下处理数据。在Java中，Rowset是由Sun Microsystems（现已被Oracle公司收购）...

    ROWSET介绍加实例

    ROWSET是Java数据库连接（JDBC）中的一个重要概念，它是一种可以存储结果集的数据结构，类似于ResultSet，但具有更高级别的功能和效率。在Java编程中，ROWSET允许程序员在离线环境中处理数据库数据，这意味着它可以...

    com.sun.rowset.jar.zip

    在Java世界里，数据访问是核心任务之一，而Sun公司的RowSet技术则是Java数据库连接（JDBC）的重要组成部分，它为开发者提供了高效、灵活的数据库操作手段。本文将深入探讨`com.sun.rowset.jar.zip`这个压缩包中的`...

    浅谈Java技术中的数据库应用

    总的来说，Java通过JDBC为开发者提供了强大而灵活的数据库访问能力，使得在构建分布式、跨平台的数据库应用时，可以充分利用Java的特性，实现高效、稳定的数据库交互。随着Java技术的不断演进，JDBC也在不断地完善，...

    java-JDBC学习笔记(java连接数据库编程)

    2. `javax.sql`包：在J2EE环境中使用，提供了如`DataSource`、`PooledConnection`和`RowSet`等高级特性，增强了JDBC的功能。 在使用JDBC时，我们需要通过URL来指定要连接的数据库。URL的格式通常为`jdbc:protocol:...

    Java数据库技术详解 DOC简版

    第1章 Java和数据库 1.1 Java概述 1.2 Java的开发和运行环境 1.3 数据库概述 1.4 数据持久层 1.5 本章小结 第2章 SQL语句基础之DDL 2.1 DDL基础 2.2 DDL操作视图 2.3 本章小结 第3章 SQL语句...

    JDBC新特性，JAVA

    Java数据库连接（JDBC）是Java编程语言...了解并熟练掌握这些JDBC的新特性，将有助于你编写更高效、更安全的Java数据库应用程序。在实际项目中，根据需求选择合适的特性，并结合最佳实践，可以大大提升代码质量和性能。

    Java 数据库接口

    Java数据库接口，简称JDBC（Java Database Connectivity），是Java编程语言中用来规范客户端程序如何访问数据库的应用程序接口，由Sun Microsystems公司（现已被Oracle收购）最初设计并提供。JDBC作为一个标准，允许...

    Java数据库编程宝典4

    第5章 使用JDBC和SQL创建表 5.1 创建数据库 5.2 使用表 5.2.1 记录和字段、行和列 5.2.2 SQL数据类型 5.2.3 完整性约束 5.3 创建表 5.4 使用JDBC创建表 5.4.1 DriverManager 5.4.2 驱动程序 5.4.3 连接 ...

    Java数据库编程宝典3

    第5章 使用JDBC和SQL创建表 5.1 创建数据库 5.2 使用表 5.2.1 记录和字段、行和列 5.2.2 SQL数据类型 5.2.3 完整性约束 5.3 创建表 5.4 使用JDBC创建表 5.4.1 DriverManager 5.4.2 驱动程序 5.4.3 连接 ...

    <<Java数据库高级编程宝典>>配套光盘

    《Java数据库高级编程宝典》是一本专注于Java数据库交互技术的专著，其配套光盘包含了一系列丰富的资源，旨在帮助读者深入理解和实践Java数据库编程。本文将详细解析这些资源及其背后蕴含的知识点。 首先，...

    java各种JDBC数据库驱动文件

    Java JDBC（Java Database Connectivity）是Java编程语言中用于与各种数据库进行交互的一组接口和类。JDBC提供了一种标准的API，使得开发者无需关心数据库的特定语法，就能通过Java程序进行数据操作。这个压缩包文件...

    java 数据库编程

    ### Java数据库编程知识点详解 #### 一、Java在企业级应用中的角色 - **企业级应用的特点**：企业级应用通常具有高度复杂性、高可用性、安全性等特性。它们通常涉及多用户环境下的数据处理任务，如事务管理、安全...

    rowset.jar

    支持CatchRowSet生成Excel报表

    jdbc_rowset

    JDBC RowSet是Java数据库连接（JDBC）规范的一部分，它提供了一种高效且灵活的方式来处理数据库查询结果。RowSet对象是一个可滚动、可更新的数据集，它可以独立于底层数据库连接存在，这意味着即使在关闭了数据库...

    JDBC与Java数据库程序设计

    **JDBC与Java数据库程序设计** Java Database Connectivity (JDBC) 是Java平台中用于与各种类型数据库交互的一组API，它是Java开发人员连接和操作数据库的核心技术。通过JDBC，开发者可以编写数据库独立的Java应用...

Magicbox
Global site tag (gtag.js) - Google Analytics