HarmonyOS 數(shù)據(jù)庫系列之關(guān)系型數(shù)據(jù)庫

作者：陳建朋 2021-09-06 10:24:12

移動端開發(fā)，數(shù)據(jù)存儲是非常重要的，鴻蒙也不例外，說到數(shù)據(jù)存儲，首要的就是數(shù)據(jù)庫了，數(shù)據(jù)庫的存儲機(jī)制是否完善，提供的功能是否簡單方便，直接影響開發(fā)者的開發(fā)速度和性能。

[[421539]]

想了解更多內(nèi)容，請訪問：

51CTO和華為官方合作共建的鴻蒙技術(shù)社區(qū)

https://harmonyos.51cto.com

前言

作為鴻蒙開發(fā)者，最近就深入學(xué)習(xí)了鴻蒙的數(shù)據(jù)庫知識點，了解了存儲機(jī)制并且嘗試了使用，發(fā)現(xiàn)鴻蒙的數(shù)據(jù)庫真的做到了應(yīng)有盡有，操作還簡單的地步。

概念

先來看看鴻蒙的關(guān)系型數(shù)據(jù)庫(Relational Database，RDB) 概念。

鴻蒙的RDB 是一種基于關(guān)系模型來管理數(shù)據(jù)的數(shù)據(jù)庫。

HarmonyOS關(guān)系型數(shù)據(jù)庫基于SQLite組件提供了一套完整的對本地數(shù)據(jù)庫進(jìn)行管理的機(jī)制，對外提供了一系列的增、刪、改、查接口，也可以直接運行用戶輸入的SQL語句來滿足復(fù)雜的場景需要。HarmonyOS提供的關(guān)系型數(shù)據(jù)庫功能更加完善，查詢效率更高。

概念中一句話很重要，HarmonyOS提供的關(guān)系型數(shù)據(jù)庫功能更加完善，查詢效率更高。看到這里我當(dāng)時是非常激動的，作為開發(fā)者難道不是最希望使用的api在什么情況下都適用嗎?

下面看看鴻蒙數(shù)據(jù)庫的運作機(jī)制，了解機(jī)制才能了解數(shù)據(jù)庫開發(fā)的核心，也有利于擴(kuò)展。

運作機(jī)制

HarmonyOS關(guān)系型數(shù)據(jù)庫對外提供通用的操作接口，底層使用SQLite作為持久化存儲引擎，支持SQLite具有的所有數(shù)據(jù)庫特性，包括但不限于事務(wù)、索引、視圖、觸發(fā)器、外鍵、參數(shù)化查詢和預(yù)編譯SQL語句。

關(guān)系型數(shù)據(jù)庫運作機(jī)制：

HarmonyOS 數(shù)據(jù)庫系列之關(guān)系型數(shù)據(jù)庫-鴻蒙HarmonyOS技術(shù)社區(qū)

看到上面的鴻蒙數(shù)據(jù)庫的運行機(jī)制不難發(fā)現(xiàn)，主要工作還是在framework層做的封裝，然后調(diào)用JNI,使用的還是SQLite組件,不管底層怎么做的開發(fā)，只要功能完善，體驗到位，鴻蒙應(yīng)用端直接使用不是很香嗎?

約束與限制

1、數(shù)據(jù)庫中連接池的最大數(shù)量是4個，用以管理用戶的讀寫操作。

連接池的數(shù)量是有限制的，最大時4個，不過4個已經(jīng)足夠使用了。

2、為保證數(shù)據(jù)的準(zhǔn)確性，數(shù)據(jù)庫同一時間只能支持一個寫操作。

同一時間支持一個寫操作時非常重要的，為了防止數(shù)據(jù)存儲的正確性，鴻蒙做了這一個限制，但是作為多年的移動端開發(fā)者，一般這種多操作或者大數(shù)據(jù)操作，都會使用多線程，異步線程，或者放在線程池中，這樣就更完美了。

數(shù)據(jù)庫操作DataAbility

鴻蒙在創(chuàng)建類的時候有一個 DataAbility，不知道各位開發(fā)者使用過了沒，其實這個就是為了數(shù)據(jù)庫操作爾來的。

添加步驟很簡單：

添加類的時候選擇Empty DataAbility即可。

一、配置：

添加類后會自動生成如下配置：

{ 
  "permissions": [ 
    "com.huawei.codelab.DataAbilityShellProvider.PROVIDER" 
  ], 
  "name": "com.hadiidbouk.databasemanager.database.DataAbility", 
  "icon": "$media:icon", 
  "description": "$string:dataability_description", 
  "type": "data", 
  "uri": "dataability://com.huawei.codelab.PersonDataAbility" 
}

1、操作數(shù)據(jù)庫需要權(quán)限信息

"permissions": [ 
        "com.huawei.codelab.DataAbilityShellProvider.PROVIDER" 
      ]

2、需要配置url，url很重要，在進(jìn)行數(shù)據(jù)庫表操作的時候需要保持一致

二、DataAbility操作內(nèi)容

默認(rèn)創(chuàng)建的DataAbility類會自動重寫數(shù)據(jù)庫的增，刪，改，查幾種操作的函數(shù)。可以看下面：

public class DataAbility extends Ability { 
    private static final HiLogLabel LABEL_LOG = new HiLogLabel(3, 0xD001100, "Demo"); 
    private static final String DB_NAME = "persondataability.db"; 
    private static final String DB_TAB_NAME = "person"; 
    private static final String DB_COLUMN_PERSON_ID = "id"; 
    private static final String DB_COLUMN_NAME = "name"; 
    private static final String DB_COLUMN_GENDER = "gender"; 
    private static final String DB_COLUMN_AGE = "age"; 
    private static final int DB_VERSION = 1; 
 
    private StoreConfig config = StoreConfig.newDefaultConfig(DB_NAME); 
    private RdbStore rdbStore; 
    private RdbOpenCallback rdbOpenCallback = new RdbOpenCallback() { 
        @Override 
        public void onCreate(RdbStore store) { 
            store.executeSql("create table if not exists " 
                    + DB_TAB_NAME + " (" 
                    + DB_COLUMN_PERSON_ID + " integer primary key, " 
                    + DB_COLUMN_NAME + " text not null, " 
                    + DB_COLUMN_GENDER + " text not null, " 
                    + DB_COLUMN_AGE + " integer)"); 
        } 
        @Override 
        public void onUpgrade(RdbStore store, int oldVersion, int newVersion) { 
        } 
    }; 
 
    @Override 
    public void onStart(Intent intent) { //創(chuàng)建數(shù)據(jù)庫操作 
        super.onStart(intent); 
        HiLog.info(LABEL_LOG, "DataAbility onStart"); 
        DatabaseHelper databaseHelper = new DatabaseHelper(this); 
        rdbStore = databaseHelper.getRdbStore(config, DB_VERSION, rdbOpenCallback, null); 
    } 
 
// 數(shù)據(jù)庫 查詢操作 
    @Override 
    public ResultSet query(Uri uri, String[] columns, DataAbilityPredicates predicates) { 
        RdbPredicates rdbPredicates = DataAbilityUtils.createRdbPredicates(predicates, DB_TAB_NAME); 
        ResultSet resultSet = rdbStore.query(rdbPredicates, columns); 
        if (resultSet == null) { 
            HiLog.info(LABEL_LOG, "resultSet is null"); 
        } 
        return resultSet; 
    } 
 
// 數(shù)據(jù)庫 插入操作 
    @Override 
    public int insert(Uri uri, ValuesBucket value) { 
        HiLog.info(LABEL_LOG, "DataAbility insert"); 
        String path = uri.getLastPath(); 
        if (!"person".equals(path)) { 
            HiLog.info(LABEL_LOG, "DataAbility insert path is not matched"); 
            return -1; 
        } 
        ValuesBucket values = new ValuesBucket(); 
        values.putInteger(DB_COLUMN_PERSON_ID, value.getInteger(DB_COLUMN_PERSON_ID)); 
        values.putString(DB_COLUMN_NAME, value.getString(DB_COLUMN_NAME)); 
        values.putString(DB_COLUMN_GENDER, value.getString(DB_COLUMN_GENDER)); 
        values.putInteger(DB_COLUMN_AGE, value.getInteger(DB_COLUMN_AGE)); 
        int index = (int) rdbStore.insert(DB_TAB_NAME, values); 
        DataAbilityHelper.creator(this, uri).notifyChange(uri); 
        return index; 
    } 
 
// 數(shù)據(jù)庫 刪除操作 
    @Override 
    public int delete(Uri uri, DataAbilityPredicates predicates) { 
        RdbPredicates rdbPredicates = DataAbilityUtils.createRdbPredicates(predicates, DB_TAB_NAME); 
        int index = rdbStore.delete(rdbPredicates); 
        HiLog.info(LABEL_LOG, "delete: " + index); 
        DataAbilityHelper.creator(this, uri).notifyChange(uri); 
        return index; 
    } 
 
// 數(shù)據(jù)庫 更新操作 
    @Override 
    public int update(Uri uri, ValuesBucket value, DataAbilityPredicates predicates) { 
        RdbPredicates rdbPredicates = DataAbilityUtils.createRdbPredicates(predicates, DB_TAB_NAME); 
        int index = rdbStore.update(value, rdbPredicates); 
        HiLog.info(LABEL_LOG, "update: " + index); 
        DataAbilityHelper.creator(this, uri).notifyChange(uri); 
        return index; 
    } 
 
    @Override 
    public FileDescriptor openFile(Uri uri, String mode) { 
        return null; 
    } 
 
    @Override 
    public String[] getFileTypes(Uri uri, String mimeTypeFilter) { 
        return new String[0]; 
    } 
 
 
    @Override 
    public PacMap call(String method, String arg, PacMap extras) { 
        return null; 
    } 
 
    @Override 
    public String getType(Uri uri) { 
        return null; 
    } 
}

1、添加DataAbility 會自動重寫四個接口函數(shù)，有關(guān)數(shù)據(jù)庫的增，刪，改，查。

2、該DataAbility在運行項目后會自行執(zhí)行onStart 方法進(jìn)行數(shù)據(jù)庫及其數(shù)據(jù)表的創(chuàng)建工作

3、通過RdbPredicates 數(shù)據(jù)庫進(jìn)行數(shù)據(jù)庫關(guān)系的關(guān)聯(lián)進(jìn)行操作。

三、數(shù)據(jù)庫操作

這里的數(shù)據(jù)庫操作時開發(fā)需求做的數(shù)據(jù)庫操作，可以通過自己的需求來開發(fā)數(shù)據(jù)庫的調(diào)用操作，最終還是通過使用 DataAbility直接調(diào)用系統(tǒng)的數(shù)據(jù)庫。

public class DataBaseAbilitySlice extends AbilitySlice { 
    private static final HiLogLabel LABEL_LOG = new HiLogLabel(3, 0xD001100, "Demo"); 
    private DataAbilityHelper databaseHelper; 
 
    private static final String BASE_URI = "dataability:///com.huawei.codelab.PersonDataAbility"; 
    private static final String DATA_PATH = "/person"; 
    private static final String DB_COLUMN_PERSON_ID = "id"; 
    private static final String DB_COLUMN_NAME = "name"; 
    private static final String DB_COLUMN_GENDER = "gender"; 
    private static final String DB_COLUMN_AGE = "age"; 
 
    @Override 
    public void onStart(Intent intent) { 
        super.onStart(intent); 
        super.setUIContent(ResourceTable.Layout_ability_data_base); 
        databaseHelper = DataAbilityHelper.creator(this); 
 
        Text text = (Text)findComponentById(ResourceTable.Id_text_helloworld); 
        text.setClickedListener(new Component.ClickedListener() { 
            @Override 
            public void onClick(Component component) { 
                query(); 
                insert(100, "Tom", "male", 20); 
                insert(101, "Jerry", "female", 21); 
                insert(102, "Bob", "male", 22); 
                query(); // 查看插入后的結(jié)果 
                update(); 
                query(); // 查看更新后的結(jié)果 
                delete(); 
                query(); // 查看刪除后的結(jié)果 
            } 
        }); 
    } 
 
    @Override 
    public void onActive() { 
        super.onActive(); 
    } 
 
    @Override 
    public void onForeground(Intent intent) { 
        super.onForeground(intent); 
    } 
 
    private void insert(int id, String name, String gender, int age) { 
        ValuesBucket valuesBucket = new ValuesBucket(); 
        valuesBucket.putInteger(DB_COLUMN_PERSON_ID, id); 
        valuesBucket.putString(DB_COLUMN_NAME, name); 
        valuesBucket.putString(DB_COLUMN_GENDER, gender); 
        valuesBucket.putInteger(DB_COLUMN_AGE, age); 
        try { 
            if (databaseHelper.insert(Uri.parse(BASE_URI + DATA_PATH), valuesBucket) != -1) { 
//            if (databaseHelper.insert(Uri.parse(BASE_URI + DATA_PATH), valuesBucket) != -1) { 
                HiLog.info(LABEL_LOG, "insert successful"); 
            } 
        } catch (DataAbilityRemoteException | IllegalStateException exception) { 
            HiLog.error(LABEL_LOG, "insert: dataRemote exception|illegalStateException"); 
        } 
    } 
 
    private void delete() { 
        DataAbilityPredicates predicates = new DataAbilityPredicates() 
                .equalTo(DB_COLUMN_PERSON_ID, 100); 
        try { 
            if (databaseHelper.delete(Uri.parse(BASE_URI + DATA_PATH), predicates) != -1) { 
                HiLog.info(LABEL_LOG, "delete successful"); 
            } 
        } catch (DataAbilityRemoteException | IllegalStateException exception) { 
            HiLog.error(LABEL_LOG, "delete: dataRemote exception | illegalStateException"); 
        } 
    } 
 
    private void update() { 
        DataAbilityPredicates predicates = new DataAbilityPredicates(); 
        predicates.equalTo(DB_COLUMN_PERSON_ID, 102); 
        ValuesBucket valuesBucket = new ValuesBucket(); 
        valuesBucket.putString(DB_COLUMN_NAME, "ZhangSanPlus"); 
        valuesBucket.putInteger(DB_COLUMN_AGE, 28); 
        try { 
            if (databaseHelper.update(Uri.parse(BASE_URI + DATA_PATH), valuesBucket, predicates) != -1) { 
                HiLog.info(LABEL_LOG, "update successful"); 
            } 
        } catch (DataAbilityRemoteException | IllegalStateException exception) { 
            HiLog.error(LABEL_LOG, "update: dataRemote exception | illegalStateException"); 
        } 
    } 
 
    private void query() { 
        String[] columns = new String[] {DB_COLUMN_PERSON_ID, 
                DB_COLUMN_NAME, DB_COLUMN_GENDER, DB_COLUMN_AGE}; 
        // 構(gòu)造查詢條件 
        DataAbilityPredicates predicates = new DataAbilityPredicates(); 
        predicates.between(DB_COLUMN_AGE, 15, 40); // 查詢時間段 
        try { 
            ResultSet resultSet = databaseHelper.query(Uri.parse(BASE_URI + DATA_PATH), 
                    columns, predicates); 
            if (resultSet == null || resultSet.getRowCount() == 0) { 
                HiLog.info(LABEL_LOG, "query: resultSet is null or no result found"); 
                return; 
            } 
            resultSet.goToFirstRow(); 
            do { 
                int id = resultSet.getInt(resultSet.getColumnIndexForName(DB_COLUMN_PERSON_ID)); 
                String name = resultSet.getString(resultSet.getColumnIndexForName(DB_COLUMN_NAME)); 
                String gender = resultSet.getString(resultSet.getColumnIndexForName(DB_COLUMN_GENDER)); 
                int age = resultSet.getInt(resultSet.getColumnIndexForName(DB_COLUMN_AGE)); 
                HiLog.info(LABEL_LOG, "query: Id :" + id + " Name :" + name + " Gender :" + gender + " Age :" + age); 
            } while (resultSet.goToNextRow()); 
        } catch (DataAbilityRemoteException | IllegalStateException exception) { 
            HiLog.error(LABEL_LOG, "query: dataRemote exception | illegalStateException"); 
        } 
    } 
}