HarmonyOS 數(shù)據(jù)庫(kù)系列之關(guān)系型數(shù)據(jù)庫(kù)
想了解更多內(nèi)容，請(qǐng)?jiān)L問(wèn)：
51CTO和華為官方合作共建的鴻蒙技術(shù)社區(qū)
前言
移動(dòng)端開(kāi)發(fā)，數(shù)據(jù)存儲(chǔ)是非常重要的，鴻蒙也不例外，說(shuō)到數(shù)據(jù)存儲(chǔ)，首要的就是數(shù)據(jù)庫(kù)了，數(shù)據(jù)庫(kù)的存儲(chǔ)機(jī)制是否完善，提供的功能是否簡(jiǎn)單方便，直接影響開(kāi)發(fā)者的開(kāi)發(fā)速度和性能。
作為鴻蒙開(kāi)發(fā)者，最近就深入學(xué)習(xí)了鴻蒙的數(shù)據(jù)庫(kù)知識(shí)點(diǎn)，了解了存儲(chǔ)機(jī)制并且嘗試了使用，發(fā)現(xiàn)鴻蒙的數(shù)據(jù)庫(kù)真的做到了應(yīng)有盡有，操作還簡(jiǎn)單的地步。
概念
先來(lái)看看 鴻蒙的 關(guān)系型數(shù)據(jù)庫(kù)(Relational Database，RDB) 概念。
鴻蒙的RDB 是一種基于關(guān)系模型來(lái)管理數(shù)據(jù)的數(shù)據(jù)庫(kù)。
HarmonyOS關(guān)系型數(shù)據(jù)庫(kù)基于SQLite組件提供了一套完整的對(duì)本地?cái)?shù)據(jù)庫(kù)進(jìn)行管理的機(jī)制，對(duì)外提供了一系列的增、刪、改、查接口，也可以直接運(yùn)行用戶(hù)輸入的SQL語(yǔ)句來(lái)滿(mǎn)足復(fù)雜的場(chǎng)景需要。HarmonyOS提供的關(guān)系型數(shù)據(jù)庫(kù)功能更加完善，查詢(xún)效率更高。
概念中一句話很重要，HarmonyOS提供的關(guān)系型數(shù)據(jù)庫(kù)功能更加完善，查詢(xún)效率更高。看到這里我當(dāng)時(shí)是非常激動(dòng)的，作為開(kāi)發(fā)者難道不是最希望 使用的api在什么情況下都適用嗎?
下面看看鴻蒙數(shù)據(jù)庫(kù)的運(yùn)作機(jī)制，了解機(jī)制才能了解數(shù)據(jù)庫(kù)開(kāi)發(fā)的核心，也有利于擴(kuò)展。
運(yùn)作機(jī)制
HarmonyOS關(guān)系型數(shù)據(jù)庫(kù)對(duì)外提供通用的操作接口，底層使用SQLite作為持久化存儲(chǔ)引擎，支持SQLite具有的所有數(shù)據(jù)庫(kù)特性，包括但不限于事務(wù)、索引、視圖、觸發(fā)器、外鍵、參數(shù)化查詢(xún)和預(yù)編譯SQL語(yǔ)句。
關(guān)系型數(shù)據(jù)庫(kù)運(yùn)作機(jī)制：
看到上面的鴻蒙數(shù)據(jù)庫(kù)的運(yùn)行機(jī)制 不難發(fā)現(xiàn)，主要工作還是在framework層做的封裝，然后調(diào)用JNI,使用的還是SQLite組件,不管 底層怎么做的開(kāi)發(fā)，只要功能完善，體驗(yàn)到位，鴻蒙應(yīng)用端直接使用不是很香嗎?
約束與限制
1、數(shù)據(jù)庫(kù)中連接池的最大數(shù)量是4個(gè)，用以管理用戶(hù)的讀寫(xiě)操作。
連接池的數(shù)量是有限制的 ，最大時(shí)4個(gè)，不過(guò)4個(gè)已經(jīng)足夠使用了。
2、為保證數(shù)據(jù)的準(zhǔn)確性，數(shù)據(jù)庫(kù)同一時(shí)間只能支持一個(gè)寫(xiě)操作。
同一時(shí)間支持一個(gè)寫(xiě)操作時(shí)非常重要的，為了防止數(shù)據(jù)存儲(chǔ)的正確性，鴻蒙做了這一個(gè)限制，但是作為多年的移動(dòng)端開(kāi)發(fā)者，一般這種多操作或者大數(shù)據(jù)操作，都會(huì)使用多線程，異步線程，或者放在線程池中，這樣就更完美了。
數(shù)據(jù)庫(kù)操作DataAbility
鴻蒙在創(chuàng)建類(lèi)的時(shí)候 有一個(gè) DataAbility，不知道各位開(kāi)發(fā)者使用過(guò)了沒(méi)，其實(shí)這個(gè)就是為了數(shù)據(jù)庫(kù)操作爾來(lái)的。
添加步驟很簡(jiǎn)單：
添加類(lèi)的時(shí)候 選擇Empty DataAbility即可。
一、 配置：
添加類(lèi)后 會(huì)自動(dòng)生成如下配置：
- {
- "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ù)庫(kù)需要權(quán)限信息
- "permissions": [
- "com.huawei.codelab.DataAbilityShellProvider.PROVIDER"
- ]
2、需要配置url，url很重要，在進(jìn)行數(shù)據(jù)庫(kù)表操作的時(shí)候 需要保持一致
二 、DataAbility操作內(nèi)容
默認(rèn)創(chuàng)建的DataAbility類(lèi)會(huì)自動(dòng)重寫(xiě) 數(shù)據(jù)庫(kù)的增，刪，改，查 幾種操作的函數(shù)?？梢钥聪旅妫?/p>
- 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ù)庫(kù)操作
- super.onStart(intent);
- HiLog.info(LABEL_LOG, "DataAbility onStart");
- DatabaseHelper databaseHelper = new DatabaseHelper(this);
- rdbStore = databaseHelper.getRdbStore(config, DB_VERSION, rdbOpenCallback, null);
- }
- // 數(shù)據(jù)庫(kù) 查詢(xún)操作
- @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ù)庫(kù) 插入操作
- @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ù)庫(kù) 刪除操作
- @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ù)庫(kù) 更新操作
- @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 會(huì)自動(dòng)重寫(xiě)四個(gè)接口函數(shù)，有關(guān)數(shù)據(jù)庫(kù)的增，刪，改，查。
2、該DataAbility在運(yùn)行項(xiàng)目后會(huì)自行執(zhí)行onStart 方法 進(jìn)行數(shù)據(jù)庫(kù)及其數(shù)據(jù)表的創(chuàng)建工作
3、通過(guò)RdbPredicates 數(shù)據(jù)庫(kù)進(jìn)行數(shù)據(jù)庫(kù)關(guān)系的關(guān)聯(lián)進(jìn)行操作。
三 、數(shù)據(jù)庫(kù)操作
這里的數(shù)據(jù)庫(kù)操作 時(shí)開(kāi)發(fā)需求做的數(shù)據(jù)庫(kù)操作，可以通過(guò)自己的需求來(lái)開(kāi)發(fā)數(shù)據(jù)庫(kù)的調(diào)用操作，最終還是通過(guò)使用 DataAbility直接調(diào)用系統(tǒng)的數(shù)據(jù)庫(kù)。
- 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)造查詢(xún)條件
- DataAbilityPredicates predicates = new DataAbilityPredicates();
- predicates.between(DB_COLUMN_AGE, 15, 40); // 查詢(xún)時(shí)間段
- 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");
- }
- }
- }
1、數(shù)據(jù)插入 使用 對(duì)象類(lèi) ValuesBucket
2、使用 DataAbilityPredicates 實(shí)例 進(jìn)行數(shù)據(jù)查詢(xún)的條件設(shè)置
到此有關(guān)數(shù)據(jù)庫(kù)的關(guān)系型數(shù)據(jù)庫(kù)操作 基本就完成了，是不是非常，非常簡(jiǎn)單，可以直接拿來(lái)主義 驗(yàn)證一下。
想了解更多內(nèi)容，請(qǐng)?jiān)L問(wèn)：
51CTO和華為官方合作共建的鴻蒙技術(shù)社區(qū)
