devbox
凡人多烦事01
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

鸿蒙harmony--数据库sqlite详解_鸿蒙开发 sqlite

作者：凡人多烦事01 | 2024-03-14 19:22:51

赞

踩

鸿蒙开发 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';
  2.  
  3. export default class RDBUtils{
  4.   private static instace: RDBUtils
  5.  
  6.   private context:Context
  7.  
  8.   private rdbStore: relationalStore.RdbStore
  9.  
  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.     };
  28.  
  29.     relationalStore.getRdbStore(this.context, STORE_CONFIG, (err, store) => {
  30.       if (err) {
  31.         return;
  32.       }
  33.       this.rdbStore =store
  34.     })
  35.   }
  36.  
  37.  
  38.  
  39.  
  40.  
  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';
  3.  
  4. export default class RDBUtils{
  5.   private static instace: RDBUtils
  6.  
  7.   private context:Context
  8.  
  9.   private rdbStore: relationalStore.RdbStore
  10.  
  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.     };
  29.  
  30.     relationalStore.getRdbStore(this.context, STORE_CONFIG, (err, store) => {
  31.       if (err) {
  32.         return;
  33.       }
  34.       this.rdbStore =store
  35.     })
  36.   }
  37.  
  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.   }
  52.  
  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.   }
  75.  
  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.   }
  86.  
  87.   /**
  88.    * 更新数据
  89.    * */
  90.  
  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.   }
  108.  
  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. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/凡人多烦事01/article/detail/236839
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号