基于Rdb创建的Data_Ability的数据操作过程-电子发烧友网

首先介绍几个基本概念和方法

①关系型数据库

基于关系模型来管理数据的数据库，以行和列的形式存储数据。（可以简单理解成一个 excel 表格的形式）

②谓词

数据库中用来代表数据实体的性质、特征或者数据实体之间关系的词项，主要用来定义数据库的操作条件。（谓词：属于函数的一种，但其返回值是真值(true/false/unknown)）

③结果集

指用户查询之后的结果集合，有多种方法可以对数据进行访问。

④SQLite 数据库

它是一个开源的轻型的数据库。

⑤场景介绍

关系型数据库是在 SQLite 基础上实现的本地数据操作机制，提供给用户无需编写原生 SQL 语句就能进行数据增删改查的方法，同时也支持原生 SQL 语句操作。

再看几个Data中相关生命周期功能介绍

如下图：

基于Rdb创建的Data_Ability的数据操作过程

运作机制

基于Rdb创建的Data_Ability的数据操作过程

从上图可以知：Data 模板的 Ability 是基于 Rdb 封装的，Rdb 是基于 SQLite 数据库，一个开源的轻型的数据库，所以Data_Ability 高效便捷的为我们提供了一套工具去管理其自身和其他应用存储数据的访问。下面逐步分析基于 Rdb 创建的一个 Data_Ability 的数据操作过程：

//=====================导入模块部分=========================
//导入DataAbility谓词相关模块
importdataAbilityfrom'@ohos.data.dataability'
//导入rdb关系数据库模块
importdataRdbfrom'@ohos.data.rdb'
//=====================定义变量部分=========================
//定义数据库表名book
constTABLE_NAME='book'
//与此RDB存储相关的数据库配置。. encryptKey:为数据库设置的加密密钥
constSTORE_CONFIG={name:'book.db',encryptKey:newUint8Array([])}
//定义SQL_CREATE_TABLE关键字参数,下面执行参数会用到
constSQL_CREATE_TABLE='CREATETABLEIFNOTEXISTSbook(idINTEGERPRIMARYKEYAUTOINCREMENT,nameTEXTNOTNULL,ageINTEGER,introductionTEXTNOTNULL)'
//定义一个变量进行储存数据库返回内容,避免多次调用执行,节省性能
letrdbStore:any=undefined
//测试用打log用的
constTAG='DataAbility.data'
//=====================创建数据库=========================
exportdefault{
// onInitialized 在Ability初始化调用，通过此回调方法执行rdb等初始化操作。
onInitialized(abilityInfo){
console.info('DataAbilityonInitialized,abilityInfo='+abilityInfo.bundleName)
//getRdbStore()获得一个相关的RdbStore，操作关系型数据库，用户可以根据自己的需求配置RdbStore的参数，然后通过RdbStore调用相关接口可以执行相关的数据操作，结果以callback形式返回。
dataRdb.getRdbStore(STORE_CONFIG,1,(err,store)=>{
console.info('[data]getRdbStoreThen')
//执行包含指定参数但不返回值的SQL语句，结果以Promise形式返回。
store.executeSql(SQL_CREATE_TABLE,[])
//把获得的数据库存入本地变量,防止后面多次操作读取创建
rdbStore=store
});
},
//=====================数据库操作方法=========================
//url:通信使用的URI
//callback:自定义回调函数名如果操作成功，则返回ResultSet对象。
//valueBucket:指示数据库中要更新的数据行。键值对与数据库表的列名相关联
//TABLE_NAME:指定的目标表名。
//insert:向数据中插入一条数据。 callbacke方式调用:
insert(uri,valueBucket,callback){
console.info(TAG+'insertstart')
rdbStore.insert(TABLE_NAME,valueBucket,callback)
},


//url:通信使用的URI
//valueBucket:指示数据库中要更新的数据行。键值对与数据库表的列名相关联
//callback:指定callback回调函数。如果操作成功，则返回ResultSet对象。
// batchInsert:向数据库中插入多条数据。
batchInsert(uri,valueBuckets,callback){
console.info(TAG+'batchinsertstart')
//循环遍历
for(leti=0;i< valueBuckets.length; i++) {
            console.info(TAG+'batchinserti='+i)
if(i< valueBuckets.length - 1){
//最终还是用到的insert方法
rdbStore.insert(TABLE_NAME,valueBuckets[i],(num:number)=>{
console.info(TAG+'batchinsertret='+num)
})
}else{
rdbStore.insert(TABLE_NAME,valueBuckets[i],callback)
}
}
},



//url:通信使用的URI
//predicates:表示rdbPredicates的实例对象指定的查询条件。
//columns:表示要查询的列。如果值为空，则查询应用于所有列。
//callback:指定callback回调函数。如果操作成功，则返回ResultSet对象。
//query:查询数据库中的数据。
query(uri,columns,predicates,callback){
console.info(TAG+'querystart')
letrdbPredicates=dataAbility.createRdbPredicates(TABLE_NAME,predicates)
rdbStore.query(rdbPredicates,columns,callback)
},

//url:通信使用的URI
//valueBucket:指示数据库中要更新的数据行。键值对与数据库表的列名相关联
//predicates:表示要插入到表中的数据行。
//callback:指定callback回调函数。如果操作成功，则返回ResultSet对象。
// update:更新数据库中的数据。
update(uri,valueBucket,predicates,callback){
console.info(TAG+'updatestart')
letrdbPredicates=dataAbility.createRdbPredicates(TABLE_NAME,predicates)
rdbStore.update(valueBucket,rdbPredicates,callback)
},



//url:通信使用的URI
//delete:删除一条或多条数据。
//predicates:表示要删除表中的数据行。
//callback:指定callback回调函数。如果操作成功，则返回ResultSet对象。
delete(uri,predicates,callback){
console.info(TAG+'deletestart')
letrdbPredicates=dataAbility.createRdbPredicates(TABLE_NAME,predicates)
rdbStore.delete(rdbPredicates,callback)
}
};