日期:2014-05-16 浏览次数:20548 次
Android系统内部集成了SQLite数据库,可是杯具的却没有Android系统可用的Hibernate。
想当初做JavaEE时有Hibernate在手的那个飘逸,我尝试用JavaEE的思路封装了一个类似的工具包。(感谢“编程浪子”在JavaEE上给我的帮助)
?
首先,晒晒我的包结构:
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
?
大家可以看到,我在项目中创建了两个SourceFolder。其中core文件夹下存放的都是通用代码,可以在其他项目中重复使用(当然最好是导出jar包了)。org.dw.core.utils包下是一些工具类,所提供的都是静态方法(可以开源的)。org.dw.core.db包下就是数据库的操作工具了。EntityDao是一个泛型接口,定义了CRUD的方法,其他实体DAO都要实现她。目前只做到这一步,下一步将利用反射实现更高级的封装。
?
上代码:
/** * 基本DAO接口 * @author EwinLive * * @param <T> * @param <PK> */ public interface EntityDao<T, PK extends Serializable> { /** * 添加 * @param entity */ void save(final T entity); /** * 移除记录(指定ID集) * @param ids 可以有多个 */ void remove(final PK... ids); /** * 更新 * @param entity */ void upDate(final T entity); /** * 按ID查询对象 * @param id * @return */ T find(final PK id); /** * 分页查询 * @param startResult 开始位置 * @param maxResult 记录容量 * @return */ List<T> getScroolData(Integer startResult, Integer maxResult); /** * 返回记录总数 * @return */ public Long getCount(); }
?
我的项目中要对消息实体"SimpleMessage"实现数据库的CRUD操作,只需要创建一个实现了"EntityDao"接口的"SimpleMessageDao"(可以观察一下包的位置)。这样做不仅可以简化代码结构,而且可以大大减少SQL语句的编写。
上代码:
/** * 简单消息DAO * SQLite * dbHelper * @author EwinLive * *事务处理示例: SQLiteDatabase sdb = dbHelper.getReadableDatabase(); sdb.beginTransaction();//开启事务 try { sdb.execSQL("XXXXX"); sdb.execSQL("YYYYY"); sdb.setTransactionSuccessful();//设置事务成功标志 } catch (SQLException e) { e.printStackTrace(); } sdb.endTransaction();//提交事务 */ public class SimpleMessageDao implements EntityDao<SimpleMessage, Integer> { /** * 表名 */ public static final String TABLE = "simple_message"; /** * 数据库管理器 * 注意:dbHelper.getReadableDatabase(),会先以可读写方式访问数据库,当磁盘空间已满时会切换到只读方式。 */ DataBaseHelper dbHelper; public SimpleMessageDao(Context context) { super(); dbHelper = new DataBaseHelper(context); } @Override public void save(SimpleMessage entity) { dbHelper.getReadableDatabase().execSQL( "insert into "+ TABLE +"(title, content, time, accountId, consumerId) values(?,?,?,?,?)", new Object[]{entity.getTitle(),entity.getContent(),entity.getTime(),entity.getAccountId(),entity.getConsumerId()}); } @SuppressWarnings("unused") @Override public void remove(Integer... ids) { if(ids.length > 0){ StringBuffer sb = new StringBuffer(); for(Integer id : ids){ sb.append('?').append(','); } sb.deleteCharAt(sb.length() - 1); dbHelper.getReadableDatabase().execSQL( "delete from "+ TABLE +" where id in(" + sb + ")", (Object[]) ids); } } @Override public void upDate(SimpleMessage entity) { dbHelper.getReadableDatabase().execSQL( "updat