JDBC板块精华整理20051226

重要提示：本文部分内容是斑竹从网上搜集整理而来，如果您认为该文档的内容侵犯了您的权益，请与整理者(excelarthur@yahoo.com.cn)联系，与ｄｅｖ２ｄｅｖ网站无关。

jdbc3.0的特性

1、jdbc3.0规范中数据库连接池框架
　　jdbc3.0规范中通过提供了一个支持数据库连接池的框架，这个框架仅仅规定了如何支持连接池的实现，而连接池的具体实现jdbc 3.0规范并没有做相关的规定。通过这个框架可以让不同角色的开发人员共同实现数据库连接池。

　　通过jdbc3.0规范可以知道具体数据库连接池的实现可以分为jdbc driver级和application server级。在jdbc driver级的实现中任何相关的工作均由特定数据库厂商的jdbc drvier的开发人员来具体实现，即jdbc driver既需要提供对数据库连接池的支持同时也必须对数据库连接池进行具体实现。而在application server级中数据库连接池的实现中特定数据库厂商的jdbc driver开发人员和application server开发人员来共同实现数据库连接池的实现（但是现在大多数application server厂商实现的连接池的机制和规范中提到有差异），其中特定数据库厂商的jdbc driver提供数据库连接池的支持而特定的application server厂商提供数据库连接池的具体实现。

　　jdbc3.0规范规定了如下的类和接口来支持数据库连接池的实现。

javax.sql.connectionevent 
javax.sql.connectionpooldatasource 
javax.sql.pooledconnection 
javax.sql.connectioneventlistener

　　其中除javax.sql.connectionevent是类，其它的均为接口。

jdbc3.0连接池框架的关系图

　　通过此图可以大概的了解相关接口在一个典型的三层环境中应用程序的位置。

2、检索自动产生的关键字
　　为了解决对获取自动产生的或自动增加的关键字的值的需求，jdbc 3.0 api 现在将获取这种值变得很轻松。要确定任何所产生的关键字的值，只要简单地在语句的 execute() 方法中指定一个可选的标记，表示您有兴趣获取产生的值。您感兴趣的程度可以是 statement.return_generated_keys，也可以是 statement.no_generated_keys。在执行这条语句后，所产生的关键字的值就会通过从 statement 的实例方法 getgeneratedkeys() 来检索 resultset 而获得，resultset 包含了每个所产生的关键字的列，下面的示例创建一个新的作者并返回对应的自动产生的关键字。

……
statement stmt = conn.createstatement(); 
// obtain the generated key that results from the query. 
stmt.executeupdate("insert into authors " + 
"(first_name, last_name) " + 
"values (‘ghq', ‘wxl')", 
statement.return_generated_keys); 
resultset rs = stmt.getgeneratedkeys(); 
if ( rs.next() ) { 
// retrieve the auto generated key(s). 
int key = rs.getint(); 
}
……

3、返回多重结果
　　jdbc 2 规范的一个局限是，在任意时刻，返回多重结果的语句只能打开一个resultset。作为 jdbc 3.0 规范中改变的一个部分，规范将允许 statement 接口支持多重打开的 resultsets。然而，重要的是 execute() 方法仍然会关闭任何以前 execute() 调用中打开的 resultset。所以，要支持多重打开的结果，statement 接口就要加上一个重载的 getmoreresults() 方法。新式的方法会做一个整数标记，在 getresultset() 方法被调用时指定前一次打开的 resultset 的行为。接口将按如下所示定义标记：

　　close_all_results：当调用 getmoreresults() 时，所有以前打开的 resultset 对象都将被关闭。

　　close_current_result：当调用 getmoreresults() 时，当前的 resultset 对象将被关闭。

　　keep_current_result：当调用 getmoreresults() 时，当前的 resultset 对象将不会被关闭。

　　下面展示的是一个处理多重打开结果的示例。

…… 
string proccall; 
// set the value of proccall to call a stored procedure. 
// … 
callablestatement cstmt = connection.preparecall(proccall); 
int retval = cstmt.execute(); 
if (retval == false) { 
// the statement returned an update count, so handle it. 
// … 
} else { // resultset 
resultset rs1 = cstmt.getresultset(); 
// … 
retval = cstmt.getmoreresults(statement.keep_current_result); 
if (retval == true) { 
resultset rs2 = cstmt.getresultset(); 
// both resultsets are open and ready for use. 
rs2.next(); 
rs1.next(); 
// … 
 } 
}
……

4、在事务中使用 savepoint
　　也许在 jdbc 3.0 中最令人兴奋的附加特点就是 savepoint 了。jdbc 2 中的事务支持让开发人员可以控制对数据的并发访问，从而保证持续数据总是保持一致的状态。可惜的是，有时候需要的是对事务多一点的控制，而不是在当前的事务中简单地对每一个改变进行回滚。在jdbc 3.0 下，可以通过 savepoint 获得这种控制。savepoint 接口允许您将事务分割为各个逻辑断点，以控制有多少事务需要回滚。下图将说明如何在事务中运用 savepoint。

savepoint 的直观表示
　　你或许不是经常需要使用 savepoint。然而，在一种普遍的情况下 savepoint 会发挥作用，那就是您需要作一系列的改变，但是在知道所有的结果之前不能确定应该保留这些改变的哪一部分。下面的代码示例说明了如何使用 savepoint 接口。

......
conn.setautocommit(false); 
// set a conservative transaction isolation level. 
conn.settransactionisolation(connection.transaction_serializable); 
statement stmt = conn.createstatement(); 
int rows = stmt.executeupdate( "insert into authors " + 
" (first_name, last_name) values " + 
" ('ghq', 'wxl')"); 
// set a named savepoint. 
savepoint svpt = conn.setsavepoint("newauthor"); 
// … 
rows = stmt.executeupdate( "update authors set type = 'fiction' " + 
"where last_name = 'wxl'"); 
// … 
conn.rollback(svpt); 
// … 
// the author has been added, but not updated. 
conn.commit(); 
......

5、其他的特性
　　1）元数据 api
　　元数据 api 已经得到更新，databasemetadata 接口现在可以检索 sql 类型的层次结构，一种新的 parametermetadata 接口可以描述 preparedstatement 对象中参数的类型和属性。

　　2）callablestatements 中已命名的参数
　　在 jdbc 3.0 之前，设置一个存储过程中的一个参数要指定它的索引值，而不是它的名称。 callablestatement 接口已经被更新了，现在您可以用名称来指定参数。

　　3）数据类型的改变
　　jdbc 所支持的数据类型作了几个改变，其中之一是增加了两种新的数据类型。

　　为了便于修改 clob（character large object，字符型巨对象）、blob（binary large object，二进制巨对象）和 ref（sql 结构）类型的值，同名的数据类型接口都被更新了。接下来的是，因为我们现在能够更新这些数据类型的值，所以 resultset 接口也被修改了，以支持对这些数据类型的列的更新，也包括对 array 类型的更新。增加的两种新的数据类型是 java.sql.types.datalink 和 java.sql.types.boolean。新增的数据类型指的是同名的 sql 类型。datalink 提供对外部资源的访问或 url，而 boolean 类型在逻辑上和 bit 类型是等同的，只是增加了在语义上的含义。datalink 列值是通过使用新的 geturl() 方法从 resultset 的一个实例中检索到的，而 boolean 类型是通过使用 getboolean() 来检索的。

二进制大对象blob
　　blob对象是sql blob的java语言映射。sql blob是一个内置类型，它可以将一个二进制大对象保存在数据库中。接口resultset、callablestatement和preparedstatement中的方法允许程序员使用与访问sql 92内置类型同样的方式来访问sql 99类型blob。

　　在标准实现中，jdbc驱动程序在后台使用sql类型locator(blob)来实现blob接口。locator(blob)指向保存在数据库服务器上的sql blob值，而且这些操作作用在这个locator（定位器）上与作用在blob值本身有同样的结果。这意味着用户可以在一个blob实例上执行操作而不必将这个blob数据物化到用户上，这将显著的提高性能。因为驱动程序在后台使用locator(blob),所以它的使用对程序员是完全透明的。

　　blob实例的标准行为一直保持有效，直到这个事务（创建一个blob的事务）执行了提交或者回滚操作。

statement stmt = con..createstatement(resultset.type_insensitive,
       resultset.concur_read_only);
resultset rs = stmt.excutequery(“select data from table	1”);
if (rs.next()){
  rs.first();
  blob blob=rs.getblob(“data”);
} 

变量blob包含一个指向blob值的逻辑指针，该blob值保存在结果集rs的第一行的data列中。即使变量blob实际上并不包含blob值中的数值，应用程序在blob上执行操作仍然像在实际的数据上执行一样。即应用程序在blob上所作的任何操作都会对表中的blob值起作用。

 java.io.inputstream in = blob.getbinarystream();
  byte b;
  while((b = in.read()) >-1){
   system.out.println(b);
}

 long len = blob.length();
  byte [] data = blob.getbytes(1,len);
  for(int i=0;i<len;i++){
   byte b = data[i];
   system.out.println(b);
}

preparedstatement的方法setblob。下面的代码就实现了这个功能：
  blob stats = rs.getblob(“stats”);
  preparedstatement pstmt= con.preparedstatement(
“update sightings set meas= ? where area = ‘beijing' ”);
  pstmt.setblob(1,stats);
  pstmt.excuteupdate();

byte [] bytes = blob2.getbytes(1,blob2.length());
  blob.setbytes(1,bytes,0,512);

byte [] bytes={……};
  blob.setbytes(1,bytes,0,512);

byte [] val ={0,1,2,3,4};
  blob data =rs.getblob(“data”);
  int numwritten = data.setbytes(1,val);
  if (dbmd.locatorupdatecopy() == true){
   preparedstatement pstmt= con . preparedstatement(
“update statistics set data = ? where region = ‘beijing' “);
   pstmt.setblob(“data”,data);
   pstmt.executeupdate();
}

字符大对象clob

使用getasiistream把clob值物化为一个包含ascii字节的字符流。
① 使用getasiistream把clob值物化为一个包含ascii字节的字符流。
clob notes = rs.getclob(“notes”);
java.io.inputstream in = notes.getasciistream();
byte b = in.read();


② 使用getcharacterstream把clob值物化为一个unicode字符流。
clob notes = rs.getclob(“notes”);
java.io.reader reader = notes.getcharacterstream();
int c = reader.read();
//


③	使用getsubstring将clob值的全部或者部分化为一个string对象。
clob notes = rs.getclob(4);
string substring= notes.getsubstring(10,5);
或者
long len =notes.length();
string substring = notes.getsubstring(1,(int)len);

元数据接口使用详解
　　三个元数据接口databasemetadata、resultsetmetadata和parametermetadata接口是三个常用的元数据接口。databasemetadata提供与数据库或者dbms相关的信息；resultsetmetadata对象提供与特定resultset实例中与列相关的信息；parametermetadata对象提供与preparedstatement对象的参数有关的信息。本文讨论的内容并不仅限于jdbc的某个版本，而是基于1.0—3.0的规范进行学习。

• resultsetmetadata对象
  　　当在jdbc应用程序中发送select语句时，该操作会返回一个resultset对象，这个resultset对象包含满足条件的数据。通过创建resultmetadata对象和调用该对象的方法，可以获取与这个resultset对象中的列有关的信息。下面的代码段将创建resultset对象rs，然后使用rs来创建resultsetmetadata对象，所创建的resultsetmetadata对象包含与rs中的列有关的信息。

     statement stmt= con . createstatement();
     resultset rs = stmt.executequery(“select * from sales”);
     resultsetmetadata rsmd = rs.getmetadata();
  

  　　现在可以使用rsmd调用resultsetmetadata的方法来访问与rs中的列有关的信息。除了方法getcolumncount给出结果集中总的列数外，所有的resultsetmetadata方法都返回与单个列有关的信息，并都接受一个表示对应列号的参数。
• getcolumncount方法
  　　 这也许是resultsetmetadata中使用最多的方法，该方法返回结果集中列数目　：

  resultset rs = stmt.executequery(“select * from sales”);
  resultsetmetadata rsmd = rs.getmetadata();
  int numberofcolumns = rsmd.getcolumncount();
  while(rs.next()){
   for(int i=1;i<=numberofcolumn;i++){
  string s = rs.getstring(i);
  system.out.println(“column ” +i +”:  ” +s +” ”);
  }
  }
  

  　　需要注意的是，用于检索所有列值的resultset方法是getstring。当不知道每一列的类型，这是比较容易的方法；如果希望能检索所有的数据类型（包括sql 99数据型），则可以使用方法getobject，这是保证能够检索所有列值得唯一方法。
• 获取列类型信息
  　　有两个resultsetmetadata方法可以获取与结果集列的类型有关的信息。这
  两个方法是getcolumntype和getcolumntypename。getcolumntype方法用于确定存储在指定列中的值的jdbc类型。该方法以一个int值来返回jdbc类型。如下面的代码获得rs第二列的jdbc类型：

    resultsetmetadata rsmd = rs.getmetadata();
    int jdbctype = rsmd.getcolumntype(2);
  

• 获取其他信息
  　　另外有几个方法用来提供与存储数值类型的列有关的信息。

  isautoincrement
  iscurrency
  issigned
  getprecision
  getscale
  isnullable
  getcolumndisplaysize

• 使用databasemetadata对象
  　　接口databasemetadata提供了大量的方法取得与数据库相关的信息。一旦获得了打开的连接，就可以创建包含与数据库系统有关的信息的databasemetadata对象。
• databasemetadata方法的类别
  　　按照返回值的类型对databasemetadata的方法进行分类，可以分为4种。
  　　有三种类型返回单一的值，另外一种返回一个结果集，这个结果集包含1～18列的数据。 ① 返回string的方法
  　　最小的类别是指返回string对象的databasemetadata方法。这些方法中的一些方法可以获取与dbms有关的总体信息，包括数据库的url、username、产品名称、驱动程序信息等等。
  ② 返回int的方法
  ③ 返回boolean的方法
  ④返回resultset对象的方法
  　　这些方法可以返回resultset对象，所返回的resultset对象可以包含1到最多18列。
• 获取与主外键有关的信息
  　　返回与主外键有关信息的方法主要有getprimarykeys、getimportedkeys、getexportedkeys以及getcrossreference等。
  　　下面的代码段显示了如果在定义表时指定了主键，则可以调用方法getprimarykeys开获取对于表中主键列的描述。

   import java.sql.*;
     public class static primarykeysexample{
    public static void main(string args[]){
  string url =”jdbc:mysubprotocol:mydatasource”;
  connection con;
  string createstring =”create table supplierspk”+
           “(sup_id integer not null,”+
           “sup_name varchar(40),”+
           “street varchar(40),”+
           “city varchar(20)”+
           “state char(10),”+
           “zip char(10),”+
           “primary key(sup_id))”;
  statement stmt;
  try{
   class.forname(“mydriver.classname”);
  }catch(java.lang.classnotfoundexception e){
   system.err.println(“classnotfoundexception: ”);
   system.err.println(“e.getmessage()”);
  }
  try{
   con =drivermanager.getconnection(url,”username”,”pwd”);
   stmt=con.createstatement;
   stmt.executeupdate(createstring);
   databasemetadata dbmd=con.getmetadata();
   resultset rs= dbmd.getprimarykey(null,null,”suplierspk”);
   while(rs.next()){
   string name =rs.getstring(“table_name”);
   string columnname=rs.getstring(“column_name”);
   string keyseq=rs.getstring(“key_seq”);
   string pkname=rs.getstring(“pk_name”);
   system.out.println(“table name :”+name);
   system.out.println(“column name: ”+columnname);
   system.out.println(“sequence in key:”+keyseq);
   system.out.println(“primary key name:”+pkname);
  }
  rs.close();
  stmt.close();
  con.close();
  }catch(sqlexception ex){
   system.err.println(“sqlexception: ”+ex.getmessage());
  }
  }
  }
  

  　　如果主键多余一列的话，那么方法getprimarykeys等将详细描述每一列。列key_seq中的值表示描述的是哪一列。
• 使用parametermetadata对象
  

  　　可以使用parametermetadata对象来获取与preparedstatement对象或者callablestatement对象有关的信息。这些参数由”?”占位符表示，”?”占位符是提供给connection方法preparestatement和preparecall的sql语句。下面的代码行使用两个参数占位符来创建一个preparedstatement对象。
  　　preparedstatement pstmt=con.preparestatement(“select id from employees where dept=? and salary>?”);
  　　这些参数根据其序号来编号，因此第一个参数编号1，第二个参数编号2，依此类推。在上面的代码行中，参数1是列dept中的一个值，参数2是salary中的一个值。下面的代码段用于找出preparedstatement pstmt有多少个参数。首先创建pstmt并用它来创建parametermetadata对象pmd，这个对象包含与pstmt中的参数有关的信息。接着调用pmd上的方法getcolumncount来找出pstmt有多少参数。

    preparedstatement pstmt=con.preparestatement(
  “update employees set salary =? where level=?”);
    parametermetadata pmd = pstmt.getparametermetadata();
    int count=pmd.getparametercount();
  

  　　变量count的值应该等于2。方法getparametercount不接受参数，因为它返回与preparedstatement对象的所有参数有关的信息。parametermetadata接口中的所有其他方法都接受序号来表示作为要查询的信息的参数。
  
• jdbc 3.0api中新增的方法示例
  　　jdbc 3.0 api引入了这样一种应用功能，即决定在已经调用commit方法来终止事务之后，resultset对象是否仍旧打开。这个功能即为结果集可保持性。resultset中加入了两个域hold_cursors_over_commit和 close_cursors_at_commit，这些域可以用于指定resultset对象的可保持性，这些常量可以提供给创建statement、preparedstatement和callablestatement对象的connection方法，还可以作为提供给databasemetadata方法supportresultsetholdability的可能的参数值。
  
  　　在下面的代码段中，首先判断驱动程序是否支持resultset可保持性，如果支持，则接着创建会生成带有可保持性游标的resultset对象的statement对象，另外此代码还指定了stmt在执行查询时产生的resultset对象的类型和并发模式。

  if (boolean b =dbms.supportsresultsetholdability(
  resultset. hold_cursors_over_commit){
   statement.stmt=con.createstatement(resultset.type_scroll_insensitive,
  resultset.concur_updatable,
  resultset.hold_cursors_over_commit);
  }
  

  　　参考《jdbc api reference》 maydene fisher etc. 著

rowset
　　rowset对象是表格式数据的容器，封装了一组从数据源获取得数据行。在rowset接口的基本实现中是从jdbc数据源中获取数据行。由于行集是可以定制的，所以行集中的数据可以来自电子数据表、flat文件（平面文件？）或者其他任何表格式样的数据源。rowset对象是resultset接口的扩展，这就意味着rowset对象是可滚动的、可更新的，并且能够执行resultset对象可以执行的任何操作。

　　rowset对象不同于resultset对象，它是javabean组件，因此，该对象有javabean属性，并遵循其事件模型。另外rowset对象的属性也允许该对象建立自己的数据库连接，执行自己的查询。此外，rowset可以是disconnected的，也就是说使用行集的过程中，不必一直保持到数据源的打开连接。另外，行集可以串行化，所以可以通过网络把它发送到远程对象中去。

　　通常情况下，jdbc api可以分为两类：rowset部分和驱动程序部分。rowset以及支持它的接口使用其他jdbc api实现。从逻辑上来说，可以把实现rowset接口的类看作是执行在jdbc驱动程序的上一层的软件。

　　现在的j2se 5.0中，可以把jdbc api分为三种类别，除了上面的两类，还有rowset接口的5种标准实现。这些实现提供了一组接口，以扩展基本的rowset接口，通过在这些接口上建立application，可以确保在事件处理、游标控制以及其他操作方面的实现遵循jdbc api。

　　rowset接口提供了一组基本方法，这些方法对于所有行集都是通用的。因为所有的rowset对象都是javabean组件，因此，rowset接口具有添加和删除event listener的方法，也有get/set rowset对象所有属性的方法。rowset对象的大多数属性都支持建立连接或者执行命令。为了执行查询、更新等sql语句，并生成能够从中获取数据的结果集，行集会使用到数据源的连接。

　　若一个组件希望得到在rowset对象上发生的事件的通知，它就应该实现rowsetlistener接口，并向rowset对象进行注册。这就是listener，一个gui组件。这样每当行集产生事件时，listener每次都会得到事件的通知，这样就能够保持它的游标位置和数据与行集的内容一致。

　　rowsetinternal、rowsetreader、和rowsetwriter接口支持行集的reader/weiter工具。reader是一个实现rowsetreader接口的类的实例，用来读取数据并数据插入到行集中。writer是一个实现rowsetwriter接口的类的实例，用来将修改后的数据写回到数据源。reader和writer就像是listener一样，都向行集进行动态注册。

　　调用reader或者writer的rowset对象必须是实现rowsetinternal接口的类的实例。这个接口为reader或者writer提供了附加的方法，用来操作行集的内部状态。例如行集可以跟踪它的初始值，rowsetinternal方法允许writer检测数据源中的相应数据是否已经被其他用户修改。另外，能够使用rowsetinternal方法来获取为行集的命令字符串设置的输入参数，也能够获取传递给行集的连接。最后，rowsetinternal方法允许reader设置新的rowsetmetadata对象，这个对象用来为行集描述reder将要插入到该行集中的数据行。

　　行集可以是connected的，也可以是disconnected的，一个连接的rowset对象，在使用的整个过程中保持到数据源的连接，而一个未连接的行集，只有从数据源读取数据或者将数据写回数据源时才会连接到它的数据源。若行集是未连接的，它就不需要jdbc驱动或者jdbc api的完整实现。这使得它非常小巧，因此也成为发送一组数据到一个thin client的理想的容器。这个客户端可以选择更新数据，并将行集发送回应用服务器。在服务器端，未连接的rowset对象使用它的reader来建立到数据源的连接，并把数据写回数据源。这一操作的具体实现依赖于reader的实现方式。通常reader将建立连接与读/写数据的操作委托给jdbc驱动。

行集的事件模型
　　行集事件模型使得java对象或者组件能够收到rowset对象产生的事件的通知。通知机制的建立包括被通知的组件，也包括rowset对象自身。首先，每一个希望得到事件通知的组件都必须实现rowsetlistener接口。然后，rowset对象必须注册每一个组件，这通过在rowset对象的事件通知组件列表中添加这些组件来完成。在这种情况下，这样的组件是一个listener，它是一个实现rowsetlistener方法的类的实例，并已经向rowset对象进行过注册。

　　在rowset对象中可能发生三种事件：游标移动、数据行发生变化（ins、del、upd）或者该对象的整个内容发生变化。rowsetlistener接口的cursormoved、rowchanged和rowsetchanged方法分别对应与这些事件。当事件发生时，行集将创建一个rowsetevent对象，使用这个对象将该行集标识为事件源。在每一个listener上调用适当的rowsetlistender方法，并向此方法传递一个rowsetevent对象作为输入参数，就将事件通知给行集所有的listener。

rowset属性
　　rowset接口提供了一组javabeans属性，可以配置rowset实例以连接到数据源并获取数据行集合。有些属性可能并不需要，这取决于特定实现。如用url或者数据源名来建立连接，但只要设置了其中一个属性，另一个属性就是可选的。如果设置了两个属性，就会使用最近设置的那个属性。若行集的数据是从不支持名命令的非sql数据源中如电子表格中获取的，那么就不需要设置命令属性。

几个接口的讲解

  joinrowsetimpl jrs=new joinrowsetimpl();
  resultset rs1 = stmt.executequery(“select * from employees”);
  cachedrowsetimpl empl=new cachedrowsetimpl();
  empl.populate(rs1);
  empl.setmatchcolumn(1);
  jrs.addrowset(empl);
  resultset rs2=stmt.executequery(“select * from bonum_plan”);
  cachedrowsetimpl bonums= new cachedrowsetimpl();
  bonus.populate(rs2);
  bonus.setmatchcolumn(1);
  jrs.addrowset(bonus);//已合并