面向对象的数据库db4o- 安装并使用db4o

发布时间:2025-12-09 14:02:28 浏览次数:3

为什么80%的码农都做不了架构师?>>>

下载和安装db4o

db4o 所有最新的版本都可以直接在官方网站上下载,进入 db4o 的下载页面,我们可以看到最新的 for Java 稳定版本,包括 JAR、源代码、入门文档、API 等内容的完整的打包文件只有 6 MB,db4o 还有一个对象数据库管理工具 ObjectManager,目前版本是 1.8。

接着在 Eclipse 中新建 Java 项目,把 db4o 对象数据库引擎包 db4o-8.0.249.16098-all-java5.jar 导入进项目。由于 db4o 支持多种版本的 JDK,除了 for JDK 5.0 的 db4o-8.0.249.16098-all-java5.jar 外,还有 for JDK 1.1、1.2-1.4 的 JAR 包,以适应多种环境。与 Hibernate、iBATIS SQL Maps 相比,db4o 更加自然,无需过多地引用第三方支持库。

db4o的包结构

db4o 怎样进行对象持久化呢?通过浏览目录可以发现,与传统的 RDBMS 一样,db4o 也有自己的数据库文件, 在 db4o 中数据库文件的后缀名是“*.yap”。让我们先来了解一下 db4o 对象数据库引擎的主要包结构:

  • com.db4o
    com.db4o 包含了使用 db4o 时最经常用到的功能。两个最重要的接口是 com.db4o.Db4o 和 com.db4o.ObjectContainer。com.db4o.Db4o 工厂是运行 db4o 的起点,这个类中的静态方法可以开启数据库文件、启动服务器或连接一个已经存在的服务器,还可以在开启数据库之前进行 db4o 环境配置。com.db4o.ObjectContainer 接口很重要,开发过程中 99% 的时间都会用到它,ObjectContainer 可在单用户模式下作为数据库实例,也可作为 db4o 服务器的客户端。每个 ObjectContainer 实例都有自己的事务。所有的操作都有事务保证。当打开 ObjectContainer,就已经进入事务了,commit() 或 rollback() 时,下一个事务立即启动。每个 ObjectContainer 实例维护它自己所管理的已存储和已实例化对象,在需要 ObjectContainer 的时候,它会一直保持开启状态,一旦关闭,内存中数据库所引用的对象将被丢弃。

  • com.db4o.ext
    你也许想知道为什么在 ObjectContainer 中只能看见很少的方法,原因如下:db4o 接口提供了两个途径,分别在 com.db4o 和 com.db4o.ext 包中。这样做首先是为了让开发者能快速上手;其次为了让其他产品能更容易的复制基本的 db4o 接口;开发者从这一点上也能看出 db4o 是相当轻量级的。每个 com.db4o.ObjectContainer 对象也是 com.db4o.ext.ExtObjectContainer 对象。可以转换成 ExtObjectContainer 获得更多高级特性。

  • com.db4o.config
    com.db4o.config 包含了所有配置 db4o 所需的类。

  • com.db4o.query
    com.db4o.query 包包含了构造“原生查询, NQ(Native Queries)”所需的 Predicate 类。NQ 是 db4o 最主要的查询接口。

初始化数据库

db4o 提供两种运行模式,分别是本地模式和服务器模式。本地模式是指直接在程序里打开 db4o 数据库文件进行操作:

Db4oEmbedded.openFile(Db4oEmbedded.newConfiguration(),"auto.yap");

而服务器模式则是客户端通过 IP 地址、端口以及授权口令来访问服务器:

服务器端:

ObjectServerserver=Db4oClientServer.openServer("auto.yap",1212); server.grantAccess("admin","1");

客户端:

//ip为服务器的ip地址 Db4oClientServer.openClient(ip,1212,"admin","1");

需要注意的是db4o会自动创建数据库文件,但是并不会创建数据库文件目录,比如我想创建数据库文件”/export/db4o/auto.yap”,db4o并不会自动创建”/export/db4o”目录 ,所以创建数据库文件时最好初始化下数据库目录:

privatevoidinitDBFile(StringdbName){ Filefile=newFile(dbName); if(file.exists()){ return; } List<File>fList=newArrayList<File>(); FilepFile=file.getParentFile(); while(!pFile.exists()){ fList.add(pFile); pFile=pFile.getParentFile(); } for(inti=fList.size()-1;i>=0;i--){ Filef=fList.get(i); f.mkdir(); } }

使用数据库

上面介绍的两种方式都可以得到 ObjectContainer 实例,就目前Java EE的分布式的应用环境来看,服务器模式更有现实意义;而本地模式更适合于单服务器应用。因为分布式模式比较常用,本文在下面的例子都将采用分布式模式。

在下面的例子中,会使用一个UserVO对象,然后介绍db4o对该对象的CRUD。

UserVO对象

publicclassUserVOimplementsSerializable{ privatestaticfinallongserialVersionUID=-9129148024922569814L; privateStringuserName; privateStringpassword; publicUserVO(){} publicUserVO(StringuserName,Stringpassword){ this.userName=userName; this.password=password; } publicStringgetPassword(){ returnpassword; } publicvoidsetPassword(Stringpassword){ this.password=password; } publicStringgetUserName(){ returnuserName; } publicvoidsetUserName(StringuserName){ this.userName=userName; } @Override publicbooleanequals(Objectobj){ if(this==obj){ returntrue; } if(!(objinstanceofUserVO)){ returnfalse; } UserVOother=(UserVO)obj; if(!(userName==null?other.userName==null:userName.equals(other.userName))){ returnfalse; } if(!(password==null?other.password==null:password.equals(other.password))){ returnfalse; } returntrue; } @Override publicinthashCode(){ finalintprime=31; intresult=17; result=prime*result+((userName==null)?0:userName.hashCode()); result=prime*result+((password==null)?0:password.hashCode()); returnresult; } @Override publicStringtoString(){ return"UserVO[userName="+userName+",password="+password+"]"; } }

增加(Create)

publicstaticvoidmain(String[]args){ UserVOvo=newUserVO("admin","1"); //打开数据库,ip为服务器ip ObjectContainerdb=Db4oClientServer.openClient(ip,1212,"admin","1"); try{ //存储数据 db.store(vo); //提交事务 db.commit(); }catch(Exceptione){ //出现异常则回滚 db.rollback(); }finally{ //关闭连接 db.close(); } }

读取(Retrieve)

publicstaticvoidmain(String[]args){ //打开数据库 ObjectContainerdb=Db4oClientServer.openClient(ip,1212,"admin","1"); try{ //构造查询对象 Queryquery=db.query(); //设置被约束实例 query.constrain(UserVO.class); //设置被约束实例的字段和约束条件 query.descend("userName").constrain("admin"); //查询对象 ObjectSet<UserVO>list=query.execute(); //dosomethingwithlist }finally{ //关闭连接 db.close(); } }

更新(Update)

publicstaticvoidmain(String[]args){ //打开数据库 ObjectContainerdb=Db4oClientServer.openClient(ip,1212,"admin","1"); try{ ObjectSet<UserVO>result=db.query(newPredicate<UserVO>(){ privatestaticfinallongserialVersionUID=1554763863522546547L; publicbooleanmatch(UserVOvo){ //匹配userName为admin的UserVO returnvo.getUserName().equals("admin"); } }); if(result.size()!=1){ thrownewRuntimeException("sizedoesnotmatched."); } UserVOvo=result.next(); //修改passport vo.setPassword("0"); db.store(vo); db.commit(); }catch(Exceptione){ db.rollback(); }finally{ //关闭连接 db.close(); } }

删除(Delete)

publicstaticvoidmain(String[]args){ UserVOvo=newUserVO("admin","1"); //打开数据库 ObjectContainerdb=Db4oClientServer.openClient(ip,1212,"admin","1"); try{ ObjectSet<UserVO>result=db.query(newPredicate<UserVO>(){ privatestaticfinallongserialVersionUID=-4397123083792023957L; publicbooleanmatch(UserVOvo){ //匹配userName为admin的UserVO returnvo.getUserName().equals("admin"); } }); if(result.size()!=1){ thrownewRuntimeException("sizedoesnotmatched."); } UserVOvo=result.next(); db.delete(vo); db.commit(); }catch(Exceptione){ db.rollback(); }finally{ //关闭连接 db.close(); } }

结论

通过本系列文章,db4o 的优势已经体现得淋漓尽致,它的添加、更新、删除是如此的简单,正如 db4o 的口号那样——“仅需一行代码就能存储复杂结构对象,极大的降低了开发时间和成本,提供高效的性能,无需 DBA 干预”。

如本文有不详尽之处,大家可以参考官方的《用户指南》,db4o 中文社区正在火热成长!

参考资料

学习

  • db4o官方网站。

  • 面向对象数据库 db4o 之旅系列:查看此系列文章完整列表。

  • ODMG 官方网站:了解 ODMG 技术。

获得产品和技术

  • 下载 db4o 免费版。

转载于:https://my.oschina.net/xionghui/blog/489727

需要做网站?需要网络推广?欢迎咨询客户经理 13272073477