IT评测·应用市场-qidao123.com

标题: 鸿蒙harmony--数据库sqlite详解 [打印本页]

---

作者: 惊雷无声    时间: 2024-6-11 19:08
标题: 鸿蒙harmony--数据库sqlite详解
今天是1月20号星期六，早安，岁末大寒至，静后春归来。愿他乡故人，漂泊有归宿，前程有奔赴，愿人间不寒，温暖常伴，诸事顺遂，喜乐长安。 
    目次
  
  一，界说
  二，运作机制
  三，束缚限制
  四，接口说明
  五，开发步调
  5.1 获取数据库
  5.2 创建数据库表
  5.3 数据库起落级
  5.4插入数据
  5.5 更新数据
  5.6 删除数据
  5.7删除数据库
  一，界说

关系型数据库基于SQLite组件，适用于存储包罗复杂关系数据的场景，比如一个班级的学生信息，需要包罗姓名、学号、各科结果等，又或者公司的雇员信息，需要包罗姓名、工号、职位等，由于数据之间有较强的对应关系，复杂水平比键值型数据更高，此时需要使用关系型数据库来持久化保存数据。
谓词：数据库中用来代表数据实体的性子、特征或者数据实体之间关系的词项，主要用来界说数据库的操作条件。
结果集：指用户查询之后的结果聚集，可以对数据进行访问。结果集提供了灵活的数据访问方式，可以更方便地拿到用户想要的数据。
二，运作机制

关系型数据库对应用提供通用的操作接口，底层使用SQLite作为持久化存储引擎，支持SQLite具有的数据库特性，包罗但不限于事件、索引、视图、触发器、外键、参数化查询和预编译SQL语句。

三，束缚限制

   1，系统默认日记方式是WAL（Write Ahead Log）模式，系统默认落盘方式是FULL模式。
  2，数据库中有4个读毗连和1个写毗连，线程获取到空闲读毗连时，即可进行读取操作。当没有空闲读毗连且有空闲写毗连时，会将写毗连当做读毗连来使用。
  3，为保证数据的准确性，数据库同一时间只能支持一个写操作。
  4，当应用被卸载完成后，设备上的相干数据库文件及临时文件会被主动清除。
  5，ArkTS侧支持的基本数据类型：number、string、二进制类型数据、boolean。
  6，为保证插入并读取数据成功，建议一条数据不要超过2M。超出该大小，插入成功，读取失败。
  四，接口说明

接口名称描述getRdbStore(context: Context, config: StoreConfig, callback: AsyncCallback<RdbStore>): void得到一个相干的RdbStore，操作关系型数据库，用户可以根据本身的需求设置RdbStore的参数，然后通过RdbStore调用相干接口可以执行相干的数据操作。executeSql(sql: string, bindArgs: Array<ValueType>, callback: AsyncCallback<void>):void执行包罗指定参数但不返回值的SQL语句。insert(table: string, values: ValuesBucket, callback: AsyncCallback<number>):void向目标表中插入一行数据。update(values: ValuesBucket, predicates: RdbPredicates, callback: AsyncCallback<number>):void根据RdbPredicates的指定实例对象更新数据库中的数据。delete(predicates: RdbPredicates, callback: AsyncCallback<number>):void根据RdbPredicates的指定实例对象从数据库中删除数据。query(predicates: RdbPredicates, columns: Array<string>, callback: AsyncCallback<ResultSet>):void根据指定条件查询数据库中的数据。deleteRdbStore(context: Context, name: string, callback: AsyncCallback<void>): void删除数据库。 五，开发步调

5.1 获取数据库

1. import relationalStore from '@ohos.data.relationalStore';
3. export default class RDBUtils{
4.   private static instace: RDBUtils
6.   private context:Context
8.   private rdbStore: relationalStore.RdbStore
10.   private constructor(context:Context) {
11.       this.context =context
12.   }
13.   static getInstance(context:Context): RDBUtils {
14.     if (!RDBUtils.instace) {
15.       RDBUtils.instace = new RDBUtils(context)
16.     }
17.     return RDBUtils.instace
18.   }
19.   /**
20.    * 数据库初始化
21.    * */
22.   public initRDB() {
23.     const STORE_CONFIG: relationalStore.StoreConfig = {
24.       name: 'yuanzhen.db', // 数据库文件名
25.       securityLevel: relationalStore.SecurityLevel.S1, // 数据库安全级别
26.       encrypt: false, // 可选参数，指定数据库是否加密，默认不加密
27.     };
29.     relationalStore.getRdbStore(this.context, STORE_CONFIG, (err, store) => {
30.       if (err) {
31.         return;
32.       }
33.       this.rdbStore =store
34.     })
35.   }
41. }

复制代码

5.2 创建数据库表

1. public createTab(){
2.   // 判断数据库版本，如果不匹配则需进行升降级操作
3.   // 假设当前数据库版本为3，表结构：EMPLOYEE (NAME, AGE, SALARY, CODES)
4.   const SQL_CREATE_TABLE = 'CREATE TABLE IF NOT EXISTS EMPLOYEE (ID INTEGER PRIMARY KEY AUTOINCREMENT, NAME TEXT NOT NULL, AGE INTEGER, SALARY REAL, CODES BLOB)'; // 建表Sql语句
5.   // 当数据库创建时，数据库默认版本为0
6.   if (this.rdbStore.version == 0) {
7.     this.rdbStore.executeSql(SQL_CREATE_TABLE); // 创建数据表
8.     // 设置数据库的版本，入参为大于0的整数
9.     this.rdbStore.version = 1;
10.   }
11. }

复制代码

5.3 数据库起落级

1. /**
2. * 升降级
3. * @param tagVersion目标版本号
4. * */
5. public upgrade(tagVersion:number){
6.   if(tagVersion!=this.rdbStore.version){
7.     switch (tagVersion) {
8.       case 2:
9.         if (this.rdbStore != undefined) {
10.           (this.rdbStore as relationalStore.RdbStore).executeSql('ALTER TABLE EMPLOYEE ADD COLUMN AGE INTEGER');
11.           this.rdbStore.version = 2;
12.         }
13.         break
14.       case 3:
15.         if (this.rdbStore != undefined) {
16.           (this.rdbStore as relationalStore.RdbStore).executeSql('ALTER TABLE EMPLOYEE DROP COLUMN ADDRESS TEXT');
17.           this.rdbStore.version = 3;
18.         }
19.         break
20.     }
21.   }
22. }

复制代码

5.4插入数据

1. /**
2. * 插入数据
3. * */
4. public instert(data:ValuesBucket,tabName:string){
5.     this.rdbStore.insert(tabName,data,(err)=>{
6.       if(err){
7.         console.log("insert error",err)
8.       }
9.     })
10. }

复制代码

5.5 更新数据

1. /**
2. * 更新数据
3. * */
4. public update(data:ValuesBucket,predicates:relationalStore.RdbPredicates){
5.   this.rdbStore.update(data,predicates,(err)=>{
6.     if(err){
7.       console.log("update error",err)
8.     }
9.   })
10. }

复制代码

5.6 删除数据

1. /*
2. * 删除数据
3. * */
4. public deleteData(predicates:relationalStore.RdbPredicates){
5.   this.rdbStore.delete(predicates,(err)=>{
6.     if(err){
7.       console.log("delete error",err)
8.     }
9.   })
10. }

复制代码

5.7删除数据库

1. /**
2. * 删除数据库
3. * */
4. public destroy(){
5.   relationalStore.deleteRdbStore(this.context,"yuanzhen.db",(err)=>{
6.     if(err){
7.       console.log("delete error",err)
8.     }
9.   })
10. }

复制代码

完备代码，只是简单的演示

1. import relationalStore from '@ohos.data.relationalStore';
2. import { ValuesBucket } from '@ohos.data.ValuesBucket';
4. export default class RDBUtils{
5.   private static instace: RDBUtils
7.   private context:Context
9.   private rdbStore: relationalStore.RdbStore
11.   private constructor(context:Context) {
12.       this.context =context
13.   }
14.   static getInstance(context:Context): RDBUtils {
15.     if (!RDBUtils.instace) {
16.       RDBUtils.instace = new RDBUtils(context)
17.     }
18.     return RDBUtils.instace
19.   }
20.   /**
21.    * 数据库初始化
22.    * */
23.   public initRDB() {
24.     const STORE_CONFIG: relationalStore.StoreConfig = {
25.       name: 'yuanzhen.db', // 数据库文件名
26.       securityLevel: relationalStore.SecurityLevel.S1, // 数据库安全级别
27.       encrypt: false, // 可选参数，指定数据库是否加密，默认不加密
28.     };
30.     relationalStore.getRdbStore(this.context, STORE_CONFIG, (err, store) => {
31.       if (err) {
32.         return;
33.       }
34.       this.rdbStore =store
35.     })
36.   }
38.   /**
39.    * 创建数据库表
40.    * */
41.   public createTab(){
42.     // 判断数据库版本，如果不匹配则需进行升降级操作
43.     // 假设当前数据库版本为3，表结构：EMPLOYEE (NAME, AGE, SALARY, CODES)
44.     const SQL_CREATE_TABLE = 'CREATE TABLE IF NOT EXISTS EMPLOYEE (ID INTEGER PRIMARY KEY AUTOINCREMENT, NAME TEXT NOT NULL, AGE INTEGER, SALARY REAL, CODES BLOB)'; // 建表Sql语句
45.     // 当数据库创建时，数据库默认版本为0
46.     if (this.rdbStore.version == 0) {
47.       this.rdbStore.executeSql(SQL_CREATE_TABLE); // 创建数据表
48.       // 设置数据库的版本，入参为大于0的整数
49.       this.rdbStore.version = 1;
50.     }
51.   }
53.   /**
54.    * 升降级
55.    * @param tagVersion目标版本号
56.    * */
57.   public upgrade(tagVersion:number){
58.     if(tagVersion!=this.rdbStore.version){
59.       switch (tagVersion) {
60.         case 2:
61.           if (this.rdbStore != undefined) {
62.             (this.rdbStore as relationalStore.RdbStore).executeSql('ALTER TABLE EMPLOYEE ADD COLUMN AGE INTEGER');
63.             this.rdbStore.version = 2;
64.           }
65.           break
66.         case 3:
67.           if (this.rdbStore != undefined) {
68.             (this.rdbStore as relationalStore.RdbStore).executeSql('ALTER TABLE EMPLOYEE DROP COLUMN ADDRESS TEXT');
69.             this.rdbStore.version = 3;
70.           }
71.           break
72.       }
73.     }
74.   }
76.   /**
77.    * 插入数据
78.    * */
79.   public instert(data:ValuesBucket,tabName:string){
80.       this.rdbStore.insert(tabName,data,(err)=>{
81.         if(err){
82.           console.log("insert error",err)
83.         }
84.       })
85.   }
87.   /**
88.    * 更新数据
89.    * */
91.   public update(data:ValuesBucket,predicates:relationalStore.RdbPredicates){
92.     this.rdbStore.update(data,predicates,(err)=>{
93.       if(err){
94.         console.log("update error",err)
95.       }
96.     })
97.   }
98.   /*
99.    * 删除数据
100.    * */
101.   public deleteData(predicates:relationalStore.RdbPredicates){
102.     this.rdbStore.delete(predicates,(err)=>{
103.       if(err){
104.         console.log("delete error",err)
105.       }
106.     })
107.   }
109.   /**
110.    * 删除数据库
111.    * */
112.   public destroy(){
113.     relationalStore.deleteRdbStore(this.context,"yuanzhen.db",(err)=>{
114.       if(err){
115.         console.log("delete error",err)
116.       }
117.     })
118.   }
119. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

---

欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/)

Powered by Discuz! X3.4