- 浏览: 255264 次
- 性别:
- 来自: 福州
文章分类
最新评论
-
sflscar:
太好了,我搞了一下午,批量插入,第一个参数个数没对sql批量导 ...
redis pipe大数据量导入 -
赵青青:
那 entity.hbm.xml 文件中的主健策略怎么配置 ...
Hibernate 和 Access -
GapStar:
换成flash IconCellRenderer.as应该怎么 ...
DataGrid 中加入图标 -
binbinyouli:
不好意思。我把楼主注释掉得部分打开了。但是我看楼主有传递对象的 ...
Flex Flash 和JAVA 在Socket交互 -
binbinyouli:
不知道前两位评论人时怎么做得。我再做这个例子的时候出现了安全沙 ...
Flex Flash 和JAVA 在Socket交互
javax.sql.rowset 自 JDK 1.4 引入,从 JDK 5.0 开始提供了参考实现。它主要包括 CachedRowSet,WebRowSet,FilteredRowSet,JoinRowSet 和 JdbcRowSet。 除了 JdbcRowSet 依然保持着与数据源的连接之外,其余四个都是 Disconnected RowSet。
相比较 java.sql.ResultSet 而言,RowSet 的离线操作能够有效的利用计算机越来越充足的内存,减轻数据库服务器的负担,由于数据操作都是在内存中进行然后批量提交到数据源,灵活性和性能都有了很大的提高。RowSet 默认是一个可滚动,可更新,可序列化的结果集,而且它作为 JavaBeans,可以方便地在网络间传输,用于两端的数据同步。
类继承结构
RowSet 继承自 ResultSet,其他五个 RowSet 接口均继承自 RowSet。下图是它们的继承关系。
图 1. 继承结构图
实验环境
本文示例的实验环境如下:
Java 环境:Sun JDK 6.0
数据库:derby-10.3.1.4
数据库名:TESTDB
数据库用户名及密码:均使用 derby 默认用户名和密码。
表及测试数据:创建两个表:CUSTOMERS 和 ORDERS,并分别插入测试数据。
示例代码以附件形式提供 下载。
表 2. 表 CUSTOMERS ID NAME REMARK
1 Tom Tom is VIP
2 Jim null
表 3. 表 ORDERS ID USER_ID PRODUCT
1 1 Book
2 1 Computer
3 2 Phone
使用 CachedRowSet
填充 CachedRowSet 的两种方式
CachedRowSet 提供了两个用来获取数据的方法,一个是 execute(),另一个是 populate(ResultSet)。
使用 execute() 填充 CachedRowSet 时,需要设置数据库连接参数和查询命令 command,如下示例代码:
清单 1. 使用 execute()
cachedRS.setUrl(DBCreator.DERBY_URL); cachedRS.setCommand(DBCreator.SQL_SELECT_CUSTOMERS); // derby 默认用户名和密码都是 "APP",也可以不设置。 cachedRS.setUsername("APP"); //$NON-NLS-1$ cachedRS.setPassword("APP"); //$NON-NLS-1$ cachedRS.execute();
cachedRS 根据设置的 url、username、password 三个参数去创建一个数据库连接,然后执行查询命令 command,用结果集填充 cachedRS,最后关闭数据库连接。execute() 还可以直接接受一个已经打开的数据库连接,假设 conn 为一个已经打开的数据库连接,下段示例代码与上段代码结果一致:
清单 2. 使用 execute(Connection)
cachedRS.execute(conn); cachedRS.setCommand(DBCreator.SQL_SELECT_CUSTOMERS); cachedRS.execute();
填充 CachedRowSet 的第二个方法是使用 populate(ResultSet)。
清单 3. 使用 populate(ResultSet)
ResultSet rs = stmt.executeQueryDBCreator.SQL_SELECT_CUSTOMERS); cachedRS.populate(rs); rs.close();
CachedRowSet 本身也是继承于 ResultSet,因此,也可以用一个有数据的 CachedRowSet 来填充另一个 CachedRowSet。
更新、删除、插入数据
更新数据。先把游标(cursor)移到要更新的行,根据每列的类型调用对应的 updateXXX(index, updateValue),再调用 updateRow() 方法。此时,只是在内存中更新了该行,同步到数据库需要调用方法 acceptChanges() 或 acceptChanges(Connection)。如果 CachedRowSet 中保存着原数据库连接信息,则可以调用 acceptChanges();否则,则应该传入可用的数据库连接或重新设置数据库连接参数。下段示例代码更新第一行的第二列。
清单 4. 更新
cachedRS.first(); cachedRS.updateString(2, "Hello"); //$NON-NLS-1$ cachedRS.updateRow(); cachedRS.acceptChanges();
删除数据。把游标移到要删除的行,调用 deleteRow(),再同步回数据库即可。
清单 5. 删除
cachedRS.last(); cachedRS.deleteRow(); cachedRS.acceptChanges();
在删除数据时,需要注意布尔值 showDeleted 这个属性的使用。CachedRowSet 提供了 getShowDeleted() 和 setShowDeleted(boolean value) 两个方法来读取和设置这个属性。showDeleted 是用来判断被标记为删除且尚未同步到数据库的行在 CachedRowSet 中是否可见。true 为可见,false 为不可见。默认值为 false。
插入数据。插入操作稍微比更新和删除复杂。先看下段示例代码。
清单 6. 新增
cachedRS.last(); cachedRS.moveToInsertRow(); cachedRS.updateInt(1, 3); cachedRS.updateString(2, "Bob"); //$NON-NLS-1$ cachedRS.updateString(3, "A new user"); //$NON-NLS-1$ cachedRS.insertRow(); cachedRS.moveToCurrentRow(); cachedRS.acceptChanges();
新插入的行位于当前游标的下一行。本例中,先把游标移到最后一行,那么在新插入数据后,新插入的行就是最后一行了。在新插入行时,一定要先调用方法 moveToInsertRow(),然后调用 updateXXX() 设置各列值,再调用 insertRow(),最后再把游标移到当前行。注意一定要遵循这个步骤,否则将抛出异常。
冲突处理
当我们使用 CachedRowSet 更新数据库时,有可能因为内存中的数据过期而产生冲突。此时更新数据库的方法 acceptChanges() 会抛出 SyncProviderException,由此我们可以捕获产生冲突的原因并手动进行解决。
清单 7. 冲突
ResultSet rs = stmt.executeQuery(DBCreator.SQL_SELECT_CUSTOMERS); CachedRowSet cachedRS = new CachedRowSetImpl(); cachedRS.populate(rs); cachedRS.setUrl(DBCreator.DERBY_URL); // 修改数据库中的数据 stmt.executeUpdate("UPDATE CUSTOMERS SET NAME = 'Terry' WHERE ID = 1"); // 在 CachedRowSet 中更新同一行 cachedRS.absolute(1); cachedRS.updateString(3, "Tom is not VIP"); cachedRS.updateRow(); SyncResolver resolver = null; try { chedRS.acceptChanges(); } catch (SyncProviderException e) { resolver = e.getSyncResolver(); } while (resolver.nextConflict()) { System.out.println(resolver.getStatus()); }
我们首先填充 cachedRS,然后在数据库中直接修改 ID 为 1 的行,将 NAME 字段设为 "Terry",同时用 cachedRS 修改 ID 为 1 的行的 REMARK 字段,最后使用 acceptChanges 跟数据库进行同步。此时 cachedRS 中记录的原始值与数据库中的值不一致,从而产生冲突,抛出 SyncProviderException,数据也会更新失败。接下来我们通过 SyncProviderException 得到 SyncResolver 实例并遍历了产生的所有冲突。
SyncResolver 继承了 RowSet 接口,我们可以像使用一般 RowSet 一样操作它。SyncResolver 的实例拥有与正在同步的 RowSet 相同的行数和列数。使用 nextConflict() 和 previousConflict() 可以遍历所有产生的冲突,getStatus() 可以获得冲突的类型。在 SyncResolve 中定义了四种类型,分别是:DELETE_ROW_CONFLICT,INSERT_ROW_CONFLICT,NO_ROW_CONFLICT,UPDATE_ROW_CONFLICT。上例中产生的是 UPDATE_ROW_CONFLICT。
注:目前 Sun JDK 对 SyncResolver 的支持非常有限,只实现了 SyncResolver 接口中定义的方法,调用从 RowSet 接口继承的方法都会抛出 UnsupportedOperationException 异常;getConflictValue() 返回都是 null。
事件监听
一个监听器需要实现 RowSetListener 接口。RowSetListener 支持三种事件监听:cursor moved、row changed 和 rowSet changed。假定 Listener 实现了 RowSetListener 接口,看示例代码。
清单 8. 注册事件监听器
Listener listener = new Listener(); cachedRS.addRowSetListener(listener); updateOnRowSet(cachedRS); cachedRS.removeRowSetListener(listener);
updateOnRowSet() 所做的操作就是将游标移到第一行,更新,再同步回数据库。在这个方法中,依次触发了 Listener 的三个事件。下表列出了 CachedRowSet 中会触发监听器的所有方法。
表 4. CachedRowSet 中会触发监听器的方法
cursor moved row changed rowSet changed
absolute() √ relative() √ next() √ previous() √ first() √ last() √ beforeFirst() √ afterLast() √ updateRow() √ deleteRow() √ insertRow() √ undoDelete() √ undoUpdate() √ undoInsert() √ populate() √ acceptChanges() √ acceptChanges(Connection) √ execute() √ execute(Connection) √ nextPage() √ previousPage() √ restoreOriginal() √ release() √
事务
事务对于保证数据的一致性是非常重要的。CachedRowSet 专门提供了处理事务的接口,从而可以保证同步数据的原子性和一致性。CachedRowSet 默认是不使用事务的。
清单 9. 事务代码一
cachedRS.absolute(1); // 第一列不能为 null,更新时将产生冲突 cachedRS.updateNull(1); cachedRS.updateRow(); cachedRS.next(); cachedRS.updateString(2, "Terry"); cachedRS.updateRow(); try { cachedRS.acceptChanges(conn); } catch (SyncProviderException e) { // expected } rs = stmt.executeQuery(DBCreator.SQL_SELECT_CUSTOMERS); cachedRS = new CachedRowSetImpl(); cachedRS.populate(rs); printRowSet(cachedRS);
我们更新了 cachedRS 的第一行和第二行,并将第一行第一列错误的设置为 null。由于 CachedRowSet 默认不使用事务,第一行没有更新,而第二行更新成功。我们也可以手动控制事务的作用范围。
清单 10. 事务代码二
conn.setAutoCommit(true); rs = stmt.executeQuery(DBCreator.SQL_SELECT_CUSTOMERS); cachedRS = new CachedRowSetImpl(); cachedRS.populate(rs); printCachedRowSet(cachedRS);
与前面的例子不同的是,这里我们关闭了自动提交模式,并且在同步失败后回滚了事务,避免了数据不一致的情况。
需要注意的是,如果需要手动控制事务的范围,在调用 execute 或 acceptChanges 时必须传入 Connection,否则再调用 CachedRowSet 的 commit() 或 rollback() 会抛 NullPointerException。实际上 CachedRowSet 依然是通过在内部保存 Connection 的引用来实现事务操作的。
文章出处:http://www.diybl.com/course/3_program/java/javaxl/2008625/128208_4.html
发表评论
-
redis pipe大数据量导入
2015-07-06 18:48 14155由于做性能测试,需要往redis中导出千万 ... -
Tongweb、Tomcat远程调试
2014-04-15 21:01 3550在开发过程中经常需要对布署在远程的程序进行跟踪测 ... -
JAVA中Integer 和 int 的比较
2012-06-17 15:04 803http://topic.csdn.net/u/2012060 ... -
java给图片加水印,文字水印
2010-10-09 10:03 1065package com.newland.bi.tt; i ... -
Struts+jsonplugin
2010-04-19 20:42 1052JSON官方文档 http://www.json.org/j ... -
jsp session 丢失
2010-04-19 20:37 23271.先访问a站点:http://192.168.18.2/te ... -
读取Properties的N种方法
2009-12-14 10:55 910如何读取资源文件:( ... -
Java正则表达式详解(上)
2009-03-28 10:24 916如果你曾经用过Perl或任 ... -
JAVA数据库基本操作指南
2009-03-28 10:04 935转自:http://www.qqread.com/java/2 ... -
不同Web主机上的Servlet之间数据对象的相互传输
2009-03-03 10:48 1241由于数据库服务器A和服务库服务器B之间存在着数据的交换,而WE ... -
与常用支付平台接口
2009-03-03 10:10 1327step-by-step集成阿里巴巴支付宝接口 http:// ... -
Java 6 RowSet 使用完全剖析(3)
2009-03-02 19:31 1159清单 24. 清单 23 中的代码执行结果 1 Tom Tom ... -
Java 6 RowSet 使用完全剖析(2)
2009-03-02 19:19 1938分页 由于 CachedRowSet 是 ... -
关于log4j配置文档详解
2009-02-25 14:39 758一.参数意义说明输出级别的种类ERROR、WARN、INFO、 ... -
Log4j最简入门(很不错的Log4j入门)
2009-02-25 14:34 786<!--[if !supportLists]--> ... -
Java对象的序列化和反序列化实践
2008-12-29 14:38 866引:当两个进程在进行远 ... -
Java语言中的参数传递详解
2008-12-24 08:41 793和其它程序设计语言类 ... -
set map table list总结
2008-10-13 11:39 1373<转自>http://bluefishyong. ... -
多态的运用 实现java 数据类型判断
2008-09-03 12:54 2384package javaBasic;/** *//** * 用 ... -
java关于23种java关于23种设计模式的有趣见解 设计模式的有趣见解
2008-09-03 12:48 1277创建型模式 1、FACTORY— ...
相关推荐
Java 6 RowSet 使用完全剖析
本文内容包括:RowSet简介类继承结构实验环境使用CachedRowSet使用WebRowSet使用FilteredRowSet使用JdbcRowSet使用JoinRowSet结束语下载参考资料C#提供了DataSet,可以将数据源中的数据读取到内存中,进行离线操作,...
jdk虽然定义了jdbc中的rowset接口但是没有实现。如果想使用rowset就要倒入这个包。
sun对Rowset的实现
支持CatchRowSet生成Excel报表
rowset.jar下载rowset.jar下载rowset.jar下载rowset.jar下载rowset.jar下载rowset.jar下载
文档介绍了rowset的详细使用,并附有实例代码。
此处上传可以直接使用的rowset.jar包,直接下载放在包里,就可以使用了.
Java 6 RowSet 使用完全剖析 结合Spring2.0和ActiveMQ进行异步消息调用 struts+hibernate增删改查(一) AXIS 布署问题 struts+hibernate增删改查(二) MySQL中如何实现Top N及M至N段的记录查询?...
sun.jdbc.rowset的jar包,2000年的老包。不过有些老项目需要。 包括sun.jdbc.rowset.CachedRowSet。
sun公司的rowset jar包。操作数据库很酷的
网上找了很多 下载下来都是com.sun.rowset 这个是正确的sun.jdbc.rowset
java.security.interfaces 提供的接口用于生成 RSA Laboratory Technical Note PKCS#1 中定义的 RSA(Rivest、Shamir 和 Adleman AsymmetricCipher 算法)密钥,以及 NIST 的 FIPS-186 中定义的 DSA(数字签名算法)...
在jdk1.5上用spring管理数据,部署到jdk1.4上,说CachedRowSet有问题,寻遍方法,最后得一rowset对jdk1.4里的进行覆盖,得的rowset.jar还需要进行修改,于是修改好,放到项目的lib中,成功!想到需要帮助的人们,...
java.security.interfaces 提供的接口用于生成 RSA Laboratory Technical Note PKCS#1 中定义的 RSA(Rivest、Shamir 和 Adleman AsymmetricCipher 算法)密钥,以及 NIST 的 FIPS-186 中定义的 DSA(数字签名算法)...
java.security.interfaces 提供的接口用于生成 RSA Laboratory Technical Note PKCS#1 中定义的 RSA(Rivest、Shamir 和 Adleman AsymmetricCipher 算法)密钥,以及 NIST 的 FIPS-186 中定义的 DSA(数字签名算法)...
6java异常处理 throw和throws、try和catch;自定义异常类;使用finally;使用异常的技巧和原则; 7 IO输入输出流 获取文件的基本信息;列出指定目录下的文件,并可过滤文件;创建文件和目录;删除文件和目录;移动...
javax.sql.RowSet select(java.lang.String sql, java.util.Map<java.lang.Integer,java.lang.Object> elements) 执行单条查询语句,适用于简单的sql查询语句 javax.sql.RowSet select(java.lang.String sql, ...
必须要时从Java SE API的源代码分析,了解各种语法在Java SE API中如何应用。 《Java JDK 7学习笔记》将IDE操作纳为教学内容之一,使读者能与实践结合,提供的视频教学能更清楚地帮助读者掌握操作步骤。 内容简介 ...