鸿蒙harmony--数据库sqlite详解

打印 上一主题 下一主题

主题 828|帖子 828|积分 2484

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


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

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

惊雷无声

金牌会员
这个人很懒什么都没写!

标签云

快速回复 返回顶部 返回列表