android平台db4o使用示例

2022-09-14 21:45:05 浏览数 (1)

大家好,又见面了,我是你们的朋友全栈君。

db4o是一个纯对象的数据库,现支持java和.NET。07年的时候,db4objects宣布db4o已可以顺利运行于Android平台,当时db4objects公司和db4o的爱好者积极推进db4o运行于Google Android平台,以期待让db4o成为Android上的首选数据库平台,但令人遗憾的是google最后选择了sqlite作为作为android平台的数据库。但是没有关系,db4objects有相应的解决方案,db4o可以无缝的运行于Android。

相对于关系型数据库,db4o还显得很年轻。大家对关系型数据库的理念根深蒂固,所以一时很难理解对象型数据库的理论。现在的数据库课程也都是以关系型数据库为示例,对象型数据库都是作为一个新兴的数据库一笔带过。这也导致很多人缺乏对象型数据的理论知识。真的想用好db4o,对象型数据的理论知识是必不可少的。例如对象型数据是没有主键这个概念的,这会让大多数人难以适应。

db4o也发展了几年了,到现在好多人还不知道,网上的资料比较少,也是比较老的版本。现在主流的android应用也都是使用sqlite数据库,这肯定是有原因的。这倒不是性能上的问题。Db4o的速度不见得会比关系型数据库慢。其最大的问题在于理解数据对象的关系和操作。db4o没有看上去那么简单,说实在的,我现在好多东西还没搞明白。比如:

代码语言:javascript复制
class A {
	int id;
	String name;
	List<B> list;
}
存储这种结构的对象,我一直搞不明白A和B的关联情况。对应一些大应用还是建议使用比较成熟的东西。Android平台上大家倒是可以一试,我也分享下自己的学习成果。现在db4o最新是8.x。稳定版本是7.x。本人以7.x演示。要说的是android平台需要的db4o的jar要1M多(8.x版的要1.4M左右,网上说的400k应该是很早的版本了,官网上找不到了)。db4o的官网下载地址http://community.versant.com/Downloads/db4o.aspx。对应android开发只需要核心jar包db4o-7.x-core-java5.jar。在下载的压缩包里还有一个db4o数据库的视图工具OME(ObjectManager Enterprise),这是一个eclipse插件,是一个离线的安装包。
 
Db4o的操作流程很简单:打开数据库文件,通过DAO读写数据,最后关闭数据库,支持事务和并发。
作为对象型数据库是不用写sql的,这点很爽。
 
对于db4o的基本操作不再多说,可以参考文章最后的参考链接。我做了一些封装,并使用泛型来减少Dao的创建。如果不使用本例的泛型的话,你需要对每个bean创建Dao,如UserDao、CacheDao。在关系型数据库中我们通过主键来识别一条记录,但是对象型数据库中没有记录,只有对象。db4o通过序列化java对象并存入文件,它识别是这个还是那个对象用的不是主键,而是UUID,这个UUID只有当一个对象被存入数据库中才会被分配到,未存入数据库的对象是没有UUID的,所以说我们并不能通过UUID来更新一条数据.那怎样更新一条数据?我们只能是先将这个对象查出来,然后修改内容再存入,或者查询到直接删除,然后存入新对象.
Db.java
package com.sljm.lfa.store;import java.io.Serializable;import java.util.ArrayList;import java.util.List;import com.db4o.Db4oEmbedded;import com.db4o.ObjectContainer;import com.db4o.ObjectSet;import com.db4o.config.CommonConfiguration;import com.db4o.config.EmbeddedConfiguration;import com.db4o.query.Query;/** * @author SunnyCoffee * @date 2013-9-7 * @version 1.0 * @desc DB配置和操作接口 */public class Db<T extends Serializable> {	private Class<T> clazz;	private String unique;	private static ObjectContainer db;	/**	 * 这里的unique是class里作为索引的属性	 * 	 * @param clazz	 * @param unique	 */	public Db(Class<T> clazz, String unique) {		this.clazz = clazz;		this.unique = unique;	}	// 打开数据库	private ObjectContainer getDb() {		if (db == null || db.ext().isClosed()) {			db = Db4oEmbedded.openFile(conf(), getDbPath());		}		return db;	}	private String getDbPath() {		return "/mnt/sdcard/lfa.db4o";// 数据库文件的路径	}	// 数据库的参数配置. 数据库配置并没有存储到文件,每次打开数据库执行此方法进行配置	private EmbeddedConfiguration conf() {		EmbeddedConfiguration conf = Db4oEmbedded.newConfiguration();		CommonConfiguration common = conf.common();		if (unique != null) {			common.objectClass(clazz).objectField(unique).indexed(true);		}		common.objectClass(clazz).cascadeOnUpdate(true);		common.objectClass(clazz).cascadeOnActivate(true);		return conf;	}	/**	 * 存储对象	 * 	 * @param obj	 */	public void store(T obj) {		if (obj == null) {			return;		}		getDb().store(obj);	}	public void store(List<T> list) {		if (list == null) {			return;		}		for (T t : list) {			getDb().store(t);		}	}	/**	 * 删除对象	 * 	 * @param obj	 */	public void delete(T obj) {		if (obj == null) {			return;		}		getDb().delete(obj);	}	public void delete(List<T> list) {		if (list == null) {			return;		}		for (T t : list) {			getDb().delete(t);		}	}	/**	 * 查询所有的某一对象	 * 	 * @return	 */	public List<T> queryAll() {		Query query = getDb().query();		query.constrain(clazz);		query.descend(unique).orderAscending();		ObjectSet<T> set = query.execute();		List<T> list = fromObjectSet(set);		return list;	}	/**	 * 根据id查询一个对象	 * 	 * @param field	 *            字段	 * @param id	 *            字段的值	 * @return	 */	public T queryById(Object id) {		List<T> list = queryWhere(unique, id);		if (list.size() == 0) {			return null;		}		return list.get(0);	}	public List<T> queryWhere(String field, Object value) {		Query query = getDb().query();		query.constrain(clazz);		query.descend(field).constrain(value);		ObjectSet<T> set = query.execute();		List<T> list = fromObjectSet(set);		return list;	}	public void close() {		getDb().commit();		if (db != null) {			db.close();			db = null;		}	}	private List<T> fromObjectSet(ObjectSet<T> set) {		List<T> list = new ArrayList<T>();		while (set.hasNext()) {			list.add(set.next());		}		return list;	}}
db4o有3种查询方式,官方一直推荐NQ(Native Queries),也就是原生查询.首先它是类型安全的,其次查询支持本地语言。还有就是QBE(Query by Example)和SODA(Simple Object Database Access)。QBE没有用过,似乎没什么特点。SODA的是最低层的查询方式,速度快、灵活性高,不足之处就是非类型安全的。本例中因为有排序操作,考虑效率和易用性上使用了SODA。
DbApiImpl.java
package com.sljm.lfa.store;import java.util.List;import com.sljm.lfa.bean.Cache;/** * @author SunnyCoffee * @date 2013-10-22 * @version 1.0 * @desc 数据库接口实现类,查询使用SODA。 NQ查询更安全,考虑到效率和简单使用了SODA, *       如此一来必须使用字符串来表示字段,如果javaBean变动这里字段必须做调整 */public class DbApiImpl implements DbApi {	public Cache getCacheById(final String id) {		Db<Cache> db = new Db<Cache>(Cache.class, "id");		Cache cache = db.queryById(id);		db.close();		return cache;	}	public void updateCache(Cache cache) {		Db<Cache> db = new Db<Cache>(Cache.class, "id");		Cache c = db.queryById(cache.getId());		db.delete(c);		db.store(cache);		db.close();	}	public void clearCache() {		Db<Cache> db = new Db<Cache>(Cache.class, "id");		List<Cache> list = db.queryAll();		db.delete(list);		db.close();	}}	
 
这里注意两点一个是Serializable接口,一个是空构造方法。
Cache.java
package com.sljm.lfa.bean;import java.io.Serializable;/** * @author SunnyCoffee * @create 2013-8-21 * @version 1.0 * @desc 缓存bean */public class Cache implements Serializable {	/**	 * 	 */	private static final long serialVersionUID = 1L;	private String id;	private long lastModified;	private long valid;	private Object result;	public Cache() {	}		// set and get}

参考链接:

http://www.ibm.com/developerworks/cn/java/j-db4o/

http://www.db4o.com

0 人点赞