移动架构 (五) 仅仅对 Java Bean 的操作，就能完成对数据持久化
移动架构 (二) Android 中 Handler 架构分析，并实现自己简易版本 Handler 框架
移动架构 (四) EventBus 3.1.1 源码分析及实现自己的轻量级 EventBus 框架，根据 TAG 发送接收事件。
前言
GitHub 上面开源了多个 Android 数据库，比如 GreenDao , LitePal , ORMLite 等，开源的数据库一般都是使用非常简单，不用开发者写 SQL，创建 table 等一些繁琐的操作，都是基于对对象的一些操作。那么我们自己可以设计一款不用自己来写 SQL 的轻量级数据库吗？当然可以，下面我们就来开干。
使用
给一个 Object 对象定义协定好的注解 table ,id
@YKTable("tb_police")
public class Police {
/**
* 人员 id
*/
@YKField("_id")
private String id;
/**
* 人员姓名
*/
private String name;
public Police(String id, String name) {
this.id = id;
this.name = name;
}
public Police() {
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Override
public String toString() {
return "Police{" +
"id='" + id + '\'' +
", name='" + name + '\'' +
'}';
}
}
复制代码插入数据
BaseDaoFactory.getOurInstance().getBaseDao(Police.class).insert(new Police("01", "DevYK"));
复制代码删除数据
BaseDaoFactory.getOurInstance().getBaseDao(Police.class).delete(new Police("01", "DevYK"));
复制代码更新数据
BaseDaoFactory.getOurInstance().getBaseDao(Police.class).updata(new Police("02", "BaseDevYK"), new Police("01", "DevYK"));
复制代码查询数据
BaseDaoImp<Police> mBaseDao BaseDaoFactory.getOurInstance().getBaseDao(Police.class);
Police police = new Police();
police.setId("02");
List<Police> policeLists = mBaseDao.query(police);
复制代码
到这里，增删改查咱们都已经操作完了，使用是不是非常的简单，不用使用者写一行 SQL 语句，基本上一行代码解决，下面我们来看看源码实现，它到底做了些什么？
自动创建 table
流程
创建表核心代码
/**
* 初始化
*
* @param sqLiteDatabase
* @param entityClass
*/
public void init(SQLiteDatabase sqLiteDatabase, Class<T> entityClass) {
this.mSQLiteDatabase = sqLiteDatabase;
this.mEntityClass = entityClass;
if (!isInit) {
//自动建表，取得表名
if (entityClass != null && (entityClass.getAnnotation(YKTable.class) == null)) {
//通过反射得到类名
this.mTableName = entityClass.getSimpleName();
} else {
if (TextUtils.isEmpty(entityClass.getAnnotation(YKTable.class).value())) {
//如果有注解但是注解为空的话，就取当前 类名
this.mTableName = entityClass.getSimpleName();
} else {
//取得注解上面的表名
this.mTableName = entityClass.getAnnotation(YKTable.class).value();
}
}
//执行创建表的操作， 使用 getCreateTabeSql () 生成 sql 语句
String autoCreateTabSql = getCreateTableSql();
Log.i(TAG, "tagSQL-->" + autoCreateTabSql);
//执行创建表的 SQL
this.mSQLiteDatabase.execSQL(autoCreateTabSql);
mCacheMap = new HashMap<>();
initCacheMap();
isInit = true;
}
}
复制代码insert 插入数据
流程
插入核心代码
/**
* 插入数据
* @param entity
* @return
*/
@Override
public long insert(T entity) {
//1. 准备好 ContentValues 中需要的数据
Map<String, String> map = getValues(entity);
if (map == null || map.size() == 0) return 0;
//2. 把数据转移到 ContentValues 中
ContentValues values = getContentValues(map);
//将数据插入表中
return mSQLiteDatabase.insert(mTableName, null, values);
}
复制代码- 首先接收外部传入的数据对象。
- 对数据对象进行解析，拿到数据库表中对应字段的值，拿到之后将字段 key,对应的值 values 存入 map。
- 将 map 解析为 ContentValues。
- 进行数据库插入 mSQLiteDatabase.insert。
delete 删除数据
流程图
核心代码流程
拿到对应字段的值
/**
* key(字段) - values(成员变量) ---》getValues 后 ---》key (成员变量的名字) ---values 成员变量的值 id 1，name alan , password 123
*
* @param entity
* @return
*/
private Map<String, String> getValues(T entity) {
HashMap<String, String> map = new HashMap<>();
//返回所有的成员变量
Iterator<Field> iterator = mCacheMap.values().iterator();
while (iterator.hasNext()) {
Field field = iterator.next();
field.setAccessible(true);
try {
Object object = field.get(entity);
if (object == null) {
continue;
}
String values = object.toString();
String key = "";
if (field.getAnnotation(YKField.class) != null) {
key = field.getAnnotation(YKField.class).value();
} else {
key = field.getName();
}
if (!TextUtils.isEmpty(key) && !TextUtils.isEmpty(values)) {
map.put(key, values);
}
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
return map;
}
复制代码将拿到要删除的 key,values 字段对应的值，自动生成 SQL
public Condition(Map<String,String> whereCasue) {
//whereArgs 里面的内容存入的 list
ArrayList list = new ArrayList();
StringBuffer stringBuffer = new StringBuffer();
stringBuffer.append("1=1");
//取得所有成员变量的名字
Set<String> keys = whereCasue.keySet();
Iterator<String> iterator = keys.iterator();
while (iterator.hasNext()) {
String key = iterator.next();
String value = whereCasue.get(key);
if (value != null){
stringBuffer.append(" and " + key + "=?");
list.add(value);
}
}
this.whereClause = stringBuffer.toString();
this.whereArgs = (String[]) list.toArray(new String[list.size()]);
}
复制代码根据生成的 SQL 条件删除数据
int delete = mSQLiteDatabase.delete(mTableName, condition.getWhereClause(), condition.getWhereArgs());
复制代码
query 查询数据
流程图
核心代码流程
拿到查询的条件的对象，转为 key,values 的 map 对象
Map<String, String> values = getValues(where);
private Map<String, String> getValues(T entity) {
HashMap<String, String> map = new HashMap<>();
//返回所有的成员变量
Iterator<Field> iterator = mCacheMap.values().iterator();
while (iterator.hasNext()) {
//拿到成员变量
Field field = iterator.next();
//设置可操作的权限
field.setAccessible(true);
try {
//拿到成员变量对应的值 values
Object object = field.get(entity);
if (object == null) {
continue;
}
String values = object.toString();
String key = "";
//如果成员变量上声明了注解，直接拿到该值 key,反之反射拿
if (field.getAnnotation(YKField.class) != null) {
key = field.getAnnotation(YKField.class).value();
} else {
key = field.getName();
}
//将类中拿到的 key values 存入 map 中
if (!TextUtils.isEmpty(key) && !TextUtils.isEmpty(values)) {
map.put(key, values);
}
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
return map;
}
复制代码将 map 转为自动生成 SQL 对象
public Condition(Map<String,String> whereCasue) {
//whereArgs 里面的内容存入的 list
ArrayList list = new ArrayList();
StringBuffer stringBuffer = new StringBuffer();
stringBuffer.append("1=1");
//取得所有成员变量的名字
Set<String> keys = whereCasue.keySet();
Iterator<String> iterator = keys.iterator();
while (iterator.hasNext()) {
String key = iterator.next();
String value = whereCasue.get(key);
if (value != null){
//查询的条件 sql
stringBuffer.append(" and " + key + "=?");
//查询的条件对应的 值
list.add(value);
}
}
this.whereClause = stringBuffer.toString();
this.whereArgs = (String[]) list.toArray(new String[list.size()]);
}
复制代码查询数据，并遍历 Cursor 取出数据
Cursor cursor = mSQLiteDatabase.query(mTableName,null,condition.getWhereClause(), condition.getWhereArgs(), null, limitString, orderBy);
List<T> result = getResult(cursor, where);
复制代码
update 更新数据
流程图
核心代码流程
拿到需要更新的值，转为 map
Map<String, String> values = getValues(entity);
复制代码将需要更新的 map 转为 ContentValues
ContentValues contentValues = getContentValues(values);
复制代码将条件转为 map
//条件
Map<String, String> whereMp = getValues(where);
复制代码将条件 map 转为 sql
public Condition(Map<String,String> whereCasue) {
//whereArgs 里面的内容存入的 list
ArrayList list = new ArrayList();
StringBuffer stringBuffer = new StringBuffer();
stringBuffer.append("1=1");
//取得所有成员变量的名字
Set<String> keys = whereCasue.keySet();
Iterator<String> iterator = keys.iterator();
while (iterator.hasNext()) {
String key = iterator.next();
String value = whereCasue.get(key);
if (value != null){
//查询的条件 sql
stringBuffer.append(" and " + key + "=?");
//查询的条件对应的 值
list.add(value);
}
}
this.whereClause = stringBuffer.toString();
this.whereArgs = (String[]) list.toArray(new String[list.size()]);
}
复制代码
总结
通过上面的步骤，我们不编写 SQL ，完全是依赖数据对象来做操作，对 SQL 不太熟悉的很友好。对于那些开源框架为什么可以自动建表，不用填写 SQL ，仅仅通过数据 Bean 就能操作数据库的好奇，在没有了解它们内部实现的原理下，看看自己能不能实现，结果也没那么难嘛。但是实际项目还是建议在了解内部实现原理的情况下使用开源框架。在这里推荐下 郭霖大神的 LitePal 框架非常稳定，使用非常简单，易上手。
如果对上面源码感兴趣的可以去我的代码仓库YKDB详细了解。
作者：DevYK
链接：https://juejin.cn/post/6844903907613753351
来源：掘金
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。
