jdbcrowsetexample.java

来自「此程序都是企业级 的数据库开发程序 全面揭示了JAVA对数据库的操作」· Java 代码 · 共 57 行

//  com/wrox/rowset/JdbcRowSetExample.java
package com.wrox.rowset;

import java.io.*;
import java.sql.*;
import javax.sql.*;
import sun.jdbc.rowset.*;

public class JdbcRowSetExample {
  JdbcRowSet jdbcRs;

  public static void main(String[] args) {
    JdbcRowSetExample jrse = new JdbcRowSetExample();
    try {
      jrse.populateRowSet();
      jrse.createEvents();
    } catch (SQLException e) {
      e.printStackTrace();
      while ((e = e.getNextException()) != null) {
	e.printStackTrace();
      }
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try { jrse.jdbcRs.close(); } 
      catch (Exception ignored) {}
    }
  }

  void populateRowSet() throws ClassNotFoundException, 
    SQLException
  {
    Class.forName("COM.cloudscape.core.JDBCDriver");
    String url = "jdbc:cloudscape:c:/wrox/database/Wrox4370.db";
    String username = "wrox";
    String password = "jdbc";

    jdbcRs = new JdbcRowSet();
    jdbcRs.setType(ResultSet.TYPE_SCROLL_INSENSITIVE);
    String sql = "SELECT * FROM stores ORDER BY storeid";
    jdbcRs.setCommand(sql);
    jdbcRs.setUrl(url);
    jdbcRs.setUsername(username);
    jdbcRs.setPassword(password);
    jdbcRs.execute();
    jdbcRs.addRowSetListener(new ExampleListener());
  }

  void createEvents() throws SQLException,
    ClassNotFoundException
  {
    while (jdbcRs.next()) {
      //each call to next, generates a cursorMoved event
    }
  }
}