前言:當你想成為什麼樣的人,努力朝目標努力,終究有一天會實現,人生最大的快樂就是不斷追尋夢想的過程

準備寫一個數據庫框架,現在的專案中資料庫框架是用三方orm,不知道是不是叫這個名字,不重要了,準備這段時間把這資料庫框架寫出來,也許寫的不夠好,沒關係,只要堅持住總會比之前好,這就是進步,我們如果不使用資料庫框架的話,寫的步驟可能要多點,現在就開始準備寫,把這個框架命名為android_simple_sqlite

我們之前建立的資料庫檔案都是放在data/data/packageName/xxx.db,放在這裡有一個不好的地方在於如果這個apk被使用者解除安裝了,那麼這個資料庫也會跟著沒了,如果專案需求要求你是在apk被解除安裝了後,apk第二次被安裝時要求做什麼功能需要用到之前資料庫,那麼這個時候你把資料庫放在data/data/packageName/xxx.db就歇菜了!所以我們要針對這部分可以讓資料庫檔案根據使用者的需求存放在哪?

現在畫一個架構設計圖：

看下我的專案包結構：

uml類圖如下：

上面的圖可能畫的不夠好,就就將著看下吧,我們在上層只是和DaoFactory這個類打交道,呼叫getDataHelper()方法返回BaseDao,看下呼叫層基本呼叫：

baseDao = DaoFactory.getInstance(this).getDataHelper(UserDao.class,User.class);

User user = new User();
user.setAge(18);
user.setName("zhouguizhi");
user.setPassword("123456");
 
baseDao.insert(user);

第一個泛型是對資料庫進行增刪改查的具體業務類,你不可能操作User實體物件你傳遞一個PersonDao,這樣會導致去獲取實體物件中的屬性以及屬性上的註解會出現問題

第二個泛型是對那個實體物件進行操作

public  synchronized  <T extends BaseDao<M>,M> T getDataHelper(Class<T
 
> clazz, Class<M> entityClass)
{
    BaseDao baseDao=null;
    try {
        baseDao=clazz.newInstance();
baseDao.init(entityClass,sqLiteDatabase);
} catch (InstantiationException e) {
        e.printStackTrace();
} catch (IllegalAccessException e) {
        e.printStackTrace();
}
    return (T) baseDao;
}

package com.sqlite.annotation;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
 * Created by admin on 2017/2/6.
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface AnnTableName {
    String value();
}

package com.sqlite.annotation;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target(ElementType.FIELD)
@Retention(RetentionPolicy.RUNTIME)
public @interface AnnFiled {
    String columnName() default "";//欄位名
String  type() default "";//欄位型別
int len() default 0;//欄位長度
}

columnName:表示表名

type：表示欄位什麼型別的

len:預設的欄位多少長度

使用：

package com.sqlite.bean;
/**
 * Created by admin on 2017/2/6.
 */
import com.sqlite.annotation.AnnFiled;
import com.sqlite.annotation.AnnTableName;
@AnnTableName("user")
public class User {
    @AnnFiled(columnName = "age",type ="Integer")
    public int age;
@AnnFiled(columnName = "name",type ="varchar",len = 20)
    public String name;
@AnnFiled(columnName = "pwd",type ="varchar",len = 20)
    public String password;
    public int getAge() {
        return age;
}
    public void setAge(int age) {
        this.age = age;
}

    public String getName() {
        return name;
}

    public void setName(String name) {
        this.name = name;
}

    public String getPassword() {
        return password;
}
    public void setPassword(String password) {
        this.password = password;
}
}

但是前提我們要讓表名和實體bean屬性對應起來,而且還有可能就bean上的屬性名和表名不一致的情況,所以我們第一步就要把這關係對應上,第二次就不用了,這就是為什麼要在BaseDao中init()方法的作用：

BaseDao.java

/**
 * 初始化 主要是對映關係是否建立 以及
* @param entityClass
* @param sqLiteDatabase
* @param
*/
public synchronized boolean init(Class<T> entityClass, SQLiteDatabase sqLiteDatabase) {
    if(!isInit){
        this.dataBase = sqLiteDatabase;
        this.clazz = entityClass;
        if(dataBase!=null){
            if(!dataBase.isOpen()){//判斷資料庫是否開啟
return false;
}
        }
        String sql = "";
        if(clazz.getAnnotation(AnnTableName.class)!=null){
            tbName = clazz.getAnnotation(AnnTableName.class).value();
}else{
            tbName = clazz.getSimpleName().toLowerCase();
}
        try {
            sql =  createTable(clazz.newInstance());
} catch (InstantiationException e) {
            e.printStackTrace();
} catch (IllegalAccessException e) {
            e.printStackTrace();
}
        if(!TextUtils.isEmpty(sql)){
            dataBase.execSQL(sql);//建立表
}
        cacheMap = new HashMap<>();
initCacheMap();
isInit = true;
}
    return isInit;
}

我們在DataFactory類做成了單例,在建構函式中做資料庫建立和開啟的操作

private DaoFactory(){
    dbFilePath= FileUtils.getDataBasePath(ctx,"zgz","user.db");
LogUtils.e("dbFilePath="+dbFilePath);
openDatabase();
}

開啟或者建立資料庫的方法如下：

/**
 * 開啟資料庫
*/
private void openDatabase() {
    this.sqLiteDatabase=SQLiteDatabase.openOrCreateDatabase(dbFilePath,null);
}

try {
    sql =  createTable(clazz.newInstance());
} catch (InstantiationException e) {
    e.printStackTrace();
} catch (IllegalAccessException e) {
    e.printStackTrace();
}
if(!TextUtils.isEmpty(sql)){
    dataBase.execSQL(sql);//建立表
}

package com.sqlite.dao;
import com.sqlite.annotation.AnnFiled;
import com.sqlite.annotation.AnnTableName;
import com.sqlite.bean.User;
import com.sqlite.constant.Constant;
import com.sqlite.dao.base.BaseDao;
import com.sqlite.utils.LogUtils;
import java.lang.reflect.Field;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
 * Created by admin on 2017/2/6.
 */
public class UserDao extends BaseDao<User> {
    @Override
protected String createTable(User user) {
        String tb_name =  User.class.getAnnotation(AnnTableName.class).value();
Field[] fields =  User.class.getDeclaredFields();
String fieldName = "";
String type = "";
        int len = 0;
Map<String,Field> columsMap = new HashMap<>();
        for(Field field:fields){
            columsMap.put(field.getName(),field);
}
        StringBuffer sb = new StringBuffer(Constant.create_table_prix);
sb.append(" ");
sb.append(tb_name);
        boolean isFirst = false;
        int i=0;
        for (Map.Entry<String, Field> entry: columsMap.entrySet()) {
            Field filed = entry.getValue();
            if(!isFirst){
                isFirst = true;
sb.append("(");
}
            if(filed.getAnnotation(AnnFiled.class)!=null){
                fieldName=filed.getAnnotation(AnnFiled.class).columnName();
type = filed.getAnnotation(AnnFiled.class).type();
len = filed.getAnnotation(AnnFiled.class).len();
sb.append(fieldName).append(" ").append(type).append(len>0?"("+len+")":"").append((i==columsMap.size()-1)? ")":",");
i++;
}
        }
        LogUtils.e(sb.toString());
        return sb.toString();
}

    @Override
public Long insert(List<User> entity) {
        return null;
}
}

表建立成功了後就是找對映關係了,封裝在initCacheMap()方法中,畫一個圖就理解了

用文字太難描述了,可能是文采太差的原因,還是畫圖好

FileUtils.java是對檔案操作的工具類在這貼下：

package com.sqlite.utils;
import android.content.Context;
import android.os.Environment;
import android.text.TextUtils;
import java.io.File;
import java.io.IOException;
/**
 * Created by Adminis on 2017/2/6.
 */
public class FileUtils {
    /**
     * 判斷sd卡是否存在
* @return
*/
public static boolean sdCardIsExites(){
        if(Environment.getExternalStorageState().equals(android.os.Environment.MEDIA_MOUNTED)){
                return true;
}
        return false;
}
    /**
     * 獲取sd卡根目錄
* @return
*/
public static String getPath(){
        String path = "";
        if(sdCardIsExites()){
            path = Environment.getExternalStorageDirectory().getAbsolutePath();
}
        return path;
}
    /**
     * 在sd卡下面建立一個目錄
*/
public static String createFolder(Context context, String folderName){
        File file = null;
String sdRootPath = getPath();
        if(TextUtils.isEmpty(sdRootPath)){//表示sd卡不存在
if(context!=null){
                // /data/data/com.sqlite/files/zhgougui
file = new File(context.getFilesDir().getAbsolutePath()+File.separator+folderName);
}
        }else{
            file = new File(sdRootPath+File.separator+folderName);
}
        if(file!=null&&!file.exists()){
            file.mkdir();
}
        return file.getAbsolutePath();
}

    /**
     *
     * @param ctx 上下文
* @param folderName 資料夾名
* @param dataBaseName 資料庫名
* @return
*/
public static String getDataBasePath(Context ctx,String folderName,String dataBaseName){
        String dbPath = "";
String dirPath = createFolder(ctx,folderName);
File file = new File(dirPath+File.separator+dataBaseName);
        if(file!=null&&!file.exists()){
            try {
                file.createNewFile();
} catch (IOException e) {
                e.printStackTrace();
}
        }
        dbPath = file.getAbsolutePath();
        return dbPath;
}
}

/**
 * 插入單條資料
*/
private void addSingleData() {
    User user = new User();
user.setAge(18);
user.setName("zhouguizhi");
user.setPassword("123456");
baseDao.insert(user);
}

看下user表什麼都沒：

我們現在點選下button

現在再把資料庫檔案匯入出來看看：

ok,資料是插入成功了,這是做單條資料插入,有時間會把插入多條資料邏輯寫下,我把我專案放在這部落格中,有需要看的去下載看下,用文字描述太難,不知道怎麼說!

程式碼下載地址：