java之BerkeleyDB(二)--绑定(Binding)技术、游标(Cursor)

转自:http://blog.csdn.net/ylf13/article/details/15337957

有几个注意的，在BDB数据库里，默认是不能有重复的两个相同的键，当然可以通过config配置sortedDupli...来设置可以，所以在读取数据库值的时候必须考虑两种情况，是否存在相同的键的记录

JE provides two basic mechanisms for the storage and retrieval of database key/data pairs:

TheDatabase.put()andDatabase.get()methods provide the easiest access for all non-duplicate records in the database. These methods are described in this section.
Cursors provide several methods for putting and getting database records. Cursors and their database access methods are described inUsingCursors.

看完上段OK，如果是设置non-duplicate，那就直接用db.get() db.put()来操作记录。否则就得用Cursor了

Database.put()
Database.putNoOverwrite()
Database.putNoDupData()

Database.get() 这个利用key来找
Database.getSearchBoth() 这个利用Key和value共同找记录

delete函数：如果记录是支持duplicate，则删除所有满足的key的记录，如果想删除某一条，还是得用cursor

上篇我们简单的打开了数据库和进行简单的存储

这个对于我们存储数据的基本类型还行，但是涉及到用户自定义类的时候，单靠之前的转换函数来从string转换程对象是不妨便的，我们来看看BDB为我们准备来什么？

引自使用手册：

DatabaseEntrycan hold any kind of data from simple Java primitive types to complex Java objects so long as that data can be represented as a Javabytearray.Note that due to performance considerations,you should not use Java serialization to convert a Java object to abytearray. Instead,use the Bind APIs to perform this conversion(seeUsingthe BIND APIsfor more information).

看到加粗这段了把，官方推荐我们用Bind

（一）Bind技术

（1）SeriaBinding

先说下序列化的绑定技术，言外之意，我们的数据类型就必须实现Serializable才能进行下面的绑定

Serializing Objects

To store a serializable complex object using the Bind APIs:

Implement java.io.Serializable in the class whose instances that you want to store.
Open (create) your databases. You need two. The first is the database that you use to store your data. The second is used to store the class information.
Instantiate a class catalog. You do this withcom.sleepycat.bind.serial.StoredClassCatalog, and at that time you must provide a handle to an open database that is used to store the class information.
Create an entry binding that usescom.sleepycat.bind.serial.SerialBinding.
Instantiate an instance of the object that you want to store, and place it in aDatabaseEntryusing the entry binding that you created in the previous step.

其实绑定技术就是用了反射。

没看源码，也没什么好展开的，大家就把方法记着吧，以后再一步步来

由于需要用到Class这个类，所以构造函数多了一个value的Class

这样就可以使得我们自己数据完整的存入了

[cpp]viewplaincopy

importjava.io.File;

importjava.io.Serializable;

importjava.io.UnsupportedEncodingException;

importcom.sleepycat.bind.EntryBinding;

importcom.sleepycat.bind.serial.SerialBinding;

importcom.sleepycat.bind.serial.StoredClassCatalog;

importcom.sleepycat.bind.serial.TupleSerialBinding;

importcom.sleepycat.bind.tuple.TupleBase;

importcom.sleepycat.bind.tuple.TupleBinding;

importcom.sleepycat.bind.tuple.TupleTupleBinding;

importcom.sleepycat.je.Database;

importcom.sleepycat.je.DatabaseConfig;

importcom.sleepycat.je.DatabaseEntry;

importcom.sleepycat.je.Environment;

importcom.sleepycat.je.EnvironmentConfig;

importcom.sleepycat.je.LockMode;

importcom.sleepycat.je.OperationStatus;

publicclassMain{

/**

*@paramargs

*/

staticEnvironmentenv=null;

publicstaticvoidmain(String[]args){

BDBUtil<Integer,Student>bDB=newBDBUtil<Integer,Student>("testDB",Student.class);

Students1=newStudent(1,"ylf");

Students2=newStudent(2,"dsb");

Students3=newStudent(3,"dbc");

bDB.put(1,s1);

bDB.put(2,s2);

bDB.put(3,s3);

Students=bDB.get(3);

System.out.println("mynameis"+s.getName()+"nois"+s.getNo());

System.out.println(bDB.size());

bDB.close();

}

}

/**

*我们的BDB工具

*目前对外提供添加数据和取得数据,删除数据3个接口

*类似HashMap的使用方法

*注意：

*这里的K和V两个类都必须实现来Serializable

*而且也实现来toString

*使用结束记得调用close()

*@authorylf

*

*版本2：

*采用动态的数据类型绑定，不是利用我们的toString()来转换对象和Entry

*用到EntryBinding和StoredClassCatalog

*以及binding.OnjectToEntry()EntryToObject()

*

*/

classBDBUtil<K,V>{

privateEnvironmentenv=null;

privateEnvironmentConfigenvCfig=null;

privateDatabasedb=null;

privateDatabaseConfigdbCfig=null;

privateDatabaseclassDB=null;

privateStoredClassCatalogclassCatalog=null;

privateEntryBindingvalueBinding=null;

privateFilefile=null;

publicBDBUtil(StringdbName,ClassvalueClass){

envCfig=newEnvironmentConfig();

envCfig.setAllowCreate(true);

file=newFile("./test/");

env=newEnvironment(file,envCfig);

dbCfig=newDatabaseConfig();

dbCfig.setAllowCreate(true);

db=env.openDatabase(null,dbName,dbCfig);

//首先创建一个我们类的数据库

classDB=env.openDatabase(null,"classDB",dbCfig);

//实例化一个Catalog

classCatalog=newStoredClassCatalog(classDB);

//实例化一个binding来转换

valueBinding=newSerialBinding(classCatalog,valueClass);

}

publicbooleanput(Kkey,Vvalue){

DatabaseEntrykeyEntry=newDatabaseEntry(key.toString().getBytes());

DatabaseEntryvalueEntry=newDatabaseEntry();

valueBinding.objectToEntry(value,valueEntry);

db.put(null,keyEntry,valueEntry);

returntrue;

}

publicVget(Kkey){

DatabaseEntrykeyEntry;

Vvalue=null;

try{

keyEntry=newDatabaseEntry(key.toString().getBytes("gb2312"));

DatabaseEntryvalueEntry=newDatabaseEntry();

if(db.get(null,keyEntry,valueEntry,LockMode.DEFAULT)==OperationStatus.SUCCESS){

value=(V)valueBinding.entryToObject(valueEntry);

returnvalue;

}

}catch(UnsupportedEncodingExceptione){

e.printStackTrace();

}

returnvalue;

}

publicbooleandel(KkeyStr){

DatabaseEntrykey;

try{

key=newDatabaseEntry(keyStr.toString().getBytes("gb2312"));

if(OperationStatus.SUCCESS==db.delete(null,key))

returntrue;

}catch(UnsupportedEncodingExceptione){

e.printStackTrace();

}

returnfalse;

}

publiclongsize(){

returndb.count();

}

publicvoidclose(){

db.close();

classDB.close();

env.cleanLog();

env.close();

}

}

/**

*序列化了的类

*实现toString()

*@authorylf

*

*/

classStudentimplementsSerializable{

/**

*

*/

privatestaticfinallongserialVersionUID=7333239714054069867L;

privateStringname;

privateintno;

publicStudent(){

}

publicStudent(intno,Stringname){

this.no=no;

this.name=name;

}

publicStringgetName(){

returnname;

}

publicvoidsetName(Stringname){

this.name=name;

}

publicintgetNo(){

returnno;

}

publicvoidsetNo(intno){

this.no=no;

}

@Override

publicStringtoString(){

return"Student"+no+":"+name;

}

publicvoidfromString(Stringstr){

inti=str.indexOf(':');

StringnoStr=str.substring(7,i);

this.no=Integer.parseInt(noStr);

this.name=str.substring(i+1);

}

}

[cpp]viewplaincopy

mynameisdbcnois3

3

（2）自定义绑定

官方还推荐使用custom tuple binding

就是我们实现TupleBinding，实现里面的objectToEntry() EntryToObject()

这里就不需要维护第二个数据库了，有木有又回到远点的赶脚！！

还不如上一篇里直接在类里实现转换

只不过官方推荐的这种是用字节流来存储，省流量，我们类里也可以利用ArrayByteInputStream好像是这个。。。我忘了，就字节流来实现就好了

（二）游标cursor

游标操作类似数据库的游标。

这里通过getNext() getPrev()来实现遍历

同时，cursor还提供了查找和插入数据的功能，我这里就不再一一写出来了，具体用到的时候在设计吧，现在全部封装一遍也不见得很好。。

[cpp]viewplaincopy

interfaceBDBIterator{

publicObjectcurrentValue();

publicObjectcurrentKey();

publicbooleanhasNext();

publicbooleanhasPrev();

publicvoidclose();

}

这里迭代器实现的是BDBUtil的内部类，迭代器的实现大家可以参考Java的迭代器实现方法。

[cpp]viewplaincopy

publicBDBIteratorgetIterator(){

IteratorImplit=newIteratorImpl();

returnit;

}

/**

*这个内部类模拟iterator遍历器

*@authorylf

*迭代器使用方法

*首先利用BDBUtil获得迭代器

*hasNext()如果下一个元素存在，游标下移动，值通过currentKeycurrentValue获取

*hasPrev()向前移动

*最后记得close()虽然我这里已经通过null来保证自动close()但不是线程安全的

*

*/

classIteratorImplimplementsBDBIterator{

KcurrentKey=null;

VcurrentValue=null;

DatabaseEntrykeyEntry=null;

DatabaseEntryvalueEntry=null;

publicIteratorImpl(){

if(cursor!=null){

cursor.close();

cursor=null;

}

cursor=db.openCursor(null,null);//这里不配值CursorConfig了

}

@Override

publicvoidclose(){

cursor.close();

cursor=null;

}

@Override

publicObjectcurrentKey(){

returncurrentKey;

}

@Override

publicObjectcurrentValue(){

returncurrentValue;

}

@Override

publicbooleanhasNext(){

keyEntry=newDatabaseEntry();

valueEntry=newDatabaseEntry();

cursor.getNext(keyEntry,valueEntry,LockMode.DEFAULT);

returnhas();

}

@Override

publicbooleanhasPrev(){

keyEntry=newDatabaseEntry();

valueEntry=newDatabaseEntry();

cursor.getPrev(keyEntry,valueEntry,LockMode.DEFAULT);

returnhas();

}

publicbooleanhas(){

if(keyEntry.getData()==null)

returnfalse;

try{

currentKey=(K)newString(keyEntry.getData(),"gb2312");

currentValue=(V)valueBinding.entryToObject(valueEntry);

if(currentValue!=null)

returntrue;

}catch(UnsupportedEncodingExceptione){

e.printStackTrace();

}

returnfalse;

}

}

调用方式如下：主要还是这个Iterator迭代器的实现遍历看下吧

[cpp]viewplaincopy

publicstaticvoidmain(String[]args){

BDBUtil<Integer,Student>bDB=newBDBUtil<Integer,Student>("testDB",Student.class);

Students1=newStudent(1,"ylf");

Students2=newStudent(2,"dsb");

Students3=newStudent(3,"dbc");

bDB.put(1,s1);

bDB.put(2,s2);

bDB.put(3,s3);

BDBIteratorit=bDB.getIterator();

Students=null;

intno=0;

while(it.hasNext()){

s=(Student)it.currentValue();

no=Integer.parseInt((String)it.currentKey());

System.out.println("mynameis"+s.getName()+"nois"+s.getNo()+""+no);

}

while(it.hasPrev()){

s=(Student)it.currentValue();

no=Integer.parseInt((String)it.currentKey());

System.out.println("mynameis"+s.getName()+"nois"+s.getNo()+""+no);

}

it.close();

BDBIteratorit2=bDB.getIterator();

while(it2.hasNext()){

s=(Student)it2.currentValue();

no=Integer.parseInt((String)it2.currentKey());

System.out.println("mynameis"+s.getName()+"nois"+s.getNo()+""+no);

}

it2.close();

System.out.println(bDB.size());

s=bDB.find(2);

System.out.println("findmynameis"+s.getName());

bDB.close();

}

查看全文
如若内容造成侵权/违法违规/事实不符，请联系编程学习网邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！

世界名著100部简介
01、傲慢与偏见 02、孤星血泪 03、雾都孤儿　　04、唐吉诃德　　05、安娜卡列尼娜 06、飘 07、简爱　　08、悲惨世界　　09、茶花女 10、基督山恩仇记 11、童年　　12、这里的黎明静悄悄　　13、钢铁是怎样炼成的 …...
2024/4/14 21:29:34
最佳开源应用程序：CAD软件
本文主要罗列了一些开源的CAD软件，这类开源软件提供了专业级功能特性，又没有大公司才负担得起的价位，却又能实现相同的效果。Archimedes Archimedes是一款基于eclipse开发的免费开源的CAD（计算机辅助设计）软件，适合一些学生和建筑师。虽然，它的功能不如AutoCAD和VectorD…...
2024/4/28 1:48:00
利用redis(订阅模式)+swoole实现实时推送
目录前言直接上代码注意前言一直在做swoole的websocket,之前是利用swoole的client->send()来使用,后来一直想用redis的订阅模式来实现(其实早就有人做了),今天来实现以下方法. 直接上代码 socket.php的核心文件 <?phpuse socket\Predis;require Predis.php;class jies…...
2024/4/14 21:29:32
linux rvm 安装、更新证书密钥、更新ruby
rvm 官网 http://rvm.io安装更新密钥，执行过程有些慢 [root@yaliangdembp ~]# gpg --keyserver hkp://keys.gnupg.net --recv-keys 409B6B1796C275462A1703113804BB82D39DC0E3 7D2BAF1CF37B13E2069D6956105BD0E739499BDB [root@yaliangdembp ~]# \curl -sSL https://get.rvm.i…...
2024/4/14 21:29:30
熊猫烧香病毒
1月15日，国内计算机反病毒软件厂商江民科技继去年12月27日发布“熊猫烧香”病毒紧急警报后，再次发布该病毒警报。据江民反病毒中心监测发现，“熊猫烧香”病毒近期正在加速传播，多家IT门户以及专业网站被种植该病毒，IE浏览器存在漏洞的用户浏览网页即会“中招”。由于被种植…...
2024/4/28 0:45:37
后端队列系统列表
web后端有很多队列系统，队列是非常好的解耦合的交互方式。新浪的Memcacheq，项目网址：http://memcachedb.org/memcacheq,生产案例：新浪微博的队列服务，基于bdb和libeventhttpsqs（http simple queue service）是一款基于http get/post协议的轻量级开源简单消息队列服务，使…...
2024/4/18 8:40:54
TFS Build 2010 生成版本号
TFS Build 2010生成构建之 dll、exe文件的版本TFS Build 2010的生成服务十分的强大，以前的版本号插件现在已经不需要了，直接在生成定义里面做就可以了（参考"TFS 2010 Build中，版本号的定义"，具体版本号定义可参考 "软件项目版本号的命名规则及格式介绍（转…...
2024/4/14 21:29:27
最牛、最全“熊猫烧香”整体解决方案
“熊猫烧香”病毒无疑成了近期互联网最热门的关键字了，网上也能找到很多个有关熊猫烧香病毒的解决办法，这些方法都显得不尽完美，再加上熊猫的变种很多，有效性就更加大打折扣了。金山毒霸反病毒专家为广大感染熊猫烧香的用户提供了一个相对完整的解决方案供大家参考。病毒…...
2024/4/28 4:03:42
Swoole入门到实战（三）：图文直播和聊天室模块、系统监控和性能优化模块、负载均衡 - 完结篇
一、直播、聊天1.1 图文直播（Redis）在线用户处理：方案（一）：https://wiki.swoole.com/wiki/...（推荐）方案（二）redis方案，无序集合Set 方案（三）swoole-table /*** 监听ws连接事件* @param $ws* @param $request*/public function onOpen($ws, $re…...
2024/4/28 1:39:29
安装体验开源车载系统Automotive Grade Linux
安装体验开源车载系统Automotive Grade LinuxLinux基金会和他的合作伙伴本周发布了Automotive Grade Linux的第一个版本，这是一个在连网汽车内部使用的开源平台。随着本周 Automotive Grade Linux(AGL)的第一个版本的发布，这个在物联网时代专为汽车定制的Linux发行版将转变为…...
2024/4/24 22:53:41
php berkeley db 安装
bdb安装程序：1、安装Berkeley DB# cd /usr/local/src # wget http://download.oracle.com/berkeley-db/db-4.6.21.tar.gz # tar -zxvf db-4.6.21.tar.gz # cd db-4.6.21 # cd build_unixBerkeley DB默认是安装在/usr/local/BerkeleyDB.4.6目录下，其中4.6就是版本号，你也可以…...
2024/4/24 22:53:43
聊天中的内涵分析
聊天是一件小事，但是也有技巧，在此分享给大家一篇关于聊天的经验之谈，原文地址不便写出，但您的支持就是我的动力。 1.下意识的语言模式影响着我们的聊天，先看两组追女孩时的常见对话。对话一男：周末打算怎么过？女：在家休息。男：这么好的天气应该出门呀，我和朋友们…...
2024/4/24 22:53:42
[人物]发明了自我的人--卡帕(外二篇)
转载题记：仅以此文,纪念罗伯特卡帕逝去55周年. ChneChen于2009/05/25..罗伯特卡帕只活了41岁，短暂的一生中参加了五次战争。“人过七十古来稀”，即使以70年计，365天70年也不过25550天，短得让人害怕。人总有一死，无法控制生命的长度，可读书走路可以体验人生的深度和厚度…...
2024/4/24 22:53:41
熊猫烧香真的那么厉害吗?我看是你们的安全意识太差了吧!
熊猫烧香真的那么厉害吗?我看是你们的安全意识太差了吧! 前几天一个朋友的电脑感染了病毒让我帮忙查杀,我大概看了一下,这个朋友的电脑admin没有密码,所有盘默认共享,因为我不是一个研究安全的专业人士,所以也看不出系统都有什么漏洞,只知道XP没有补丁,我告诉他电脑基本上是对…...
2024/4/27 11:14:27
配置TFS 2010出现错误—SQL Server 登录的安全标识符(SID)与某个指定的域或工作组帐户冲突...
我今天在配置TFS 2010是出现了帐户冲突的错误，具体错误如下：错误 [ 配置数据库 ] TF255507: 以下 SQL Server 登录的安全标识符(SID)与某个指定的域或工作组帐户冲突: NEWWEBSRV\Administrator。域或工作组帐户为: TESTWEB\Administrator。选择的用于承载 Team Foundation S…...
2024/4/24 22:53:37
MemcacheQ(消息队列)
原文地址：MemcacheQ(消息队列)作者：邓强memcacheQ 配置什么是memcacheQ ?memcacheQ是一个基于memcache协议、BDB持久数据存储、高性能轻量级队列服务程序。特点是： 1. 简单高效，基于memcache协议，这意味着只要客户端支持memcache协议即可使用。 2. 队列数据存储于BDB, …...
2024/4/24 22:53:35
使用开源软件进行Verilog HDL仿真-安装篇
本系列文章介绍使用开源软件Icarus Verilog和gtkwave进行HDL前端仿真。一、软件简介Icarus Verilog Icarus Verilog 是一款开源的verilog仿真软件，具有一下特点：跨平台，Linux/BSD/AIX/Mac OSX/Windows 编译型仿真软件支持IEEE1364-1995，IEEE1364-2001和IEEE1364-2005标准 …...
2024/4/24 22:53:35
[zz] 我是怎样诱骗漂亮女孩的【完整版】
我是怎样诱骗漂亮女孩的【完整版】我一生中最离奇的经历就是和陈芳一家人的事情。我和陈芳是在一次朋友的婚礼上认识的，那天她是新娘的伴娘，当我第一次看到她时我头就开始发晕，我没有见过这么让我惊讶的女子，她虽然打扮平常，但却异常清纯美丽，当她陪着新娘走下车时…...
2024/4/24 22:53:33
Swoole 如何处理高并发以及异步 I/O 的实现
原文作者: xingguang 原文链接：https://www.tiance.club/post/3001131064.html Swoole 介绍 1.swoole提供了PHP语言的异步多线程服务器，异步TCP/UDP网络客户端，异步MySQL，异步Redis，数据库连接池，AsyncTask，消息队列，毫秒定时器，异步文件读写，异步DNS查询。 Swoole还…...
2024/4/24 22:53:33
十大流行开源软件推荐
对于开源软件来说，相信每个人心中都会有自己的TOP10，尤其是那些开源软件拥趸者眼中的TOP10，可能会与我们所列的TOP10有些不同。不过，这是经过全球很多开源社区高手共同讨论的结果，我们觉得这个版本的TOP10是我们所能做到的最公正、最准确的了。当然如果你不同意这样的TOP1…...
2024/4/24 22:53:33

java之BerkeleyDB(二)--绑定(Binding)技术、游标(Cursor)

Serializing Objects

相关文章

最新文章