HarmonyOS学习(十三)——数据管理(二) 关系型数据库

🕗 发布于 2024-09-21 10:53 数据库 harmonyos 学习鸿蒙 arkts

文章目录

官方文档地址：通过关系型数据库实现数据持久化-应用数据持久化-ArkData（方舟数据管理）-应用框架 - 华为HarmonyOS开发者 (huawei.com)

1、基本概念

关系数据库：用于关系模型来管理数据的数据库，以行和列的形式存储数据。
谓词：数据库中用来代表数据实体的性质、特征或者数据实体之间关系的词项，主要用来定义数据库的操作条件。
结果集：指用户查询之后的结果集合，可以对数据进行访问。结果集提供了灵活的数据访问方式，可以更方便地拿到用户想要的数据。
Sqlite：一款用于嵌入式的轻量型关系数据库。

2、运行机制

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

3、默认配置与限制

系统默认日志方式是WAL（Write Ahead Log）模式，系统默认落盘方式是FULL模式。
数据库使用的共享内存默认大小为2M。
数据库中连接池最大数量是4个，用以管理用户的读操作。
为保证数据的准确性，数据库同一时间只能支持一个写操作。
当应用被卸载完成后，设备上的相关数据库文件及临时文件会被自动清除。
ArkTS侧支持的基本数据类型：number、string、二进制类型数据、boolean。

4、接口说明

以下是关系型数据库持久化功能的相关接口，大部分为异步接口。异步接口均有callback和Promise两种返回形式，下表均以callback形式为例，更多接口及使用方式请见关系型数据库。

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

5、实战：开发“账本”

5.1、创建RdbStore

import relationalStore from '@ohos.data.relationalStore';

 private rdbStore:relationalStore.RdbStore = null;

  private ACCOUNT_TABLE = {
    tableName: "accountTable",
    sqlCreate: "CREATE TABLE IF NOT EXISTS accountTable (" +
    "id INTEGER PRIMARY KEY AUTOINCREMENT," +
    "accountType INTEGER," +
    "typeText TEXT," +
    "amount INTEGER)",
    columns: ['id', 'accountType', 'typeText', 'amount']
  };

  private STORE_CONFIG: relationalStore.StoreConfig = {
    name: "rdbstore.db", //数据库文件名
    securityLevel: relationalStore.SecurityLevel.S1, //数据库安全等级
    encrypt: false, //指定数据库是否加密  默认不加密
  }

  aboutToAppear(){
    //获取一个RdbStore
    relationalStore.getRdbStore(this.context,this.STORE_CONFIG,(err,store) => {
      if(err){
        console.info(this.LOG_TAG,'getRdbStore failed,err:'+err);
        return;
      }
      console.info(this.LOG_TAG,'getRdbStore success');
      this.rdbStore = store;
      store.executeSql(this.ACCOUNT_TABLE.sqlCreate);
    });
  }

5.2、创建数据库

//创建表
Button("创建表")
  .width('100%')
  .type(ButtonType.Capsule)
  .onClick(() => {
     this.rdbStore.executeSql(this.ACCOUNT_TABLE.sqlCreate);
  })

5.3、增加数据

//添加数据
Button("ADD")
  .width('100%')
  .type(ButtonType.Capsule)
  .margin({top:20})
  .onClick(() => {
   let valueBucket1:relationalStore.ValuesBucket = {
     'accountType':0,
     'typeText':'购物',
     'amount':20
   };
    this.rdbStore.insert(this.ACCOUNT_TABLE.tableName,valueBucket1,(err,rowId) => {
      if(err){
        console.info(this.LOG_TAG,'insertData() failed,err : '+ err);
        return;
      }else {
        console.info(this.LOG_TAG,'Succesed in insert data , rowId:'+rowId);
      }
    })
  })

5.4、删除数据

//删除数据
Button("Delete")
  .width('100%')
  .type(ButtonType.Capsule)
  .margin({ top: 20 })
  .onClick(() => {
    let predicate: relationalStore.RdbPredicates = new relationalStore.RdbPredicates(this.ACCOUNT_TABLE.tableName);
    predicate.equalTo('id', 1); //删除id为1的数据
    this.rdbStore.delete(predicate, (err, rows) => {
      if(err){
        console.info(this.LOG_TAG,'deleteData() failed,err: ' + err);
        return;
      } else {
        console.info(this.LOG_TAG,'delete rows:'+rows)
      }
    })
  });

5.5、修改数据

 //修改数据
      Button("Update")
        .width('100%')
        .type(ButtonType.Capsule)
        .margin({ top: 20 })
        .onClick(() => {
          let valueBucket: relationalStore.ValuesBucket = {
            'accountType': 0,
            'typeText': '购物',
            'amount': 50
          };
          let predicate: relationalStore.RdbPredicates = new relationalStore.RdbPredicates(this.ACCOUNT_TABLE.tableName);
          predicate.equalTo('typeText', '购物'); //修改购物的值
          this.rdbStore.update(valueBucket,predicate, (err, rows) => {
            if(err){
              console.info(this.LOG_TAG,'update() failed,err: ' + err);
              return;
            } else {
              console.info(this.LOG_TAG,'success update rows count:'+rows);
            }
          })
        });

5.6、查询数据

//查询数据
Button("Query")
  .width('100%')
  .type(ButtonType.Capsule)
  .margin({ top: 20 })
  .onClick(() => {
    let predicate: relationalStore.RdbPredicates = new relationalStore.RdbPredicates(this.ACCOUNT_TABLE.tableName);
    predicate.equalTo('typeText', '购物'); //修改购物的值
    let result:Array<AccountData> = [];
    this.rdbStore.query(predicate,['id','accountType','typeText','amount'],(err,resultSet) => {
      if(err){
        console.info(this.LOG_TAG,'query() failed,err: ' + err);
        return;
      }else {
        console.info(this.LOG_TAG,'resultSet column name:'+ resultSet.columnNames+'column count:'=resultSet.columnCount);
        while (resultSet.goToNextRow()){
          let temp:AccountData = {id:0,accountType:0,typeText:'',amount:0}
          temp.id = resultSet.getDouble(resultSet.getColumnIndex('id'));
          temp.accountType = resultSet.getDouble(resultSet.getColumnIndex('accountType'));
          temp.typeText = resultSet.getString(resultSet.getColumnIndex('typeText'));
          temp.amount = resultSet.getDouble(resultSet.getColumnIndex('amount'));
          result.push(temp);
        }
        resultSet.close();//释放数据集内存

      }
    })
  });

5.7、备份数据库

this.rdbStore.backup(this.STORE_CONFIG.name,(err) => {
  if(err){
    console.info(this.LOG_TAG,'failed backup err;'+err);
    return;
  } else {
    console.info(this.LOG_TAG,'backup  success')
  } 
});

5.8、恢复数据库

this.rdbStore.restore(this.STORE_CONFIG.name,(err) => {
  if(err){
    console.info(this.LOG_TAG,'failed restore err;'+err);
    return;
  } else {
    console.info(this.LOG_TAG,'restore  success')
  } 
});

5.9、删除数据库

this.rdbStore.deleteRdbStore(this.context,this.STORE_CONFIG.name,(err) => {
  if(err){
    console.info(this.LOG_TAG,'failed delete err;'+err);
    return;
  } else {
    console.info(this.LOG_TAG,'delete  success')
  } 
});

原文地址：https://blog.csdn.net/qi85481455/article/details/142391789

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：发现编程的全新境界——明基RD280U显示器使用体验
下一篇：VSCode集成Python环境搭建配置详细步骤

设计模式之装饰器模式(SSO单点登录功能扩展，增加拦截用户访问方法范围场景)
不改变原有类，可能有的小伙伴会想到继承、AOP切面，当然这些方式都可以实现，但是使用装饰器模式会是另外一种思路更为灵活，可以避免继承导致的子类过多，也可以避免AOP带来的复杂性。就像夏天热你穿短裤，冬
阅读更多2024-11-15
MySQL45讲第二十三讲是怎么保证数据不丢的？
在 MySQL 的世界里，数据的可靠性是至关重要的。今天，我们将深入探讨 MySQL 是如何保证数据不丢的，这涉及到 binlog 和 redo log 的写入机制，以及一些关键参数的设置。
阅读更多2024-11-15
【Electron】Electron Forge如何支持Element plus？
在 Electron Forge 项目中集成 Element Plus 是一个相对直接的过程。Element Plus 是一个基于 Vue 3 的 UI 组件库，因此你需要确保你的 Electron
阅读更多2024-11-15
jupyter可视化pandas dataframe
在Jupyter中显示HTML表格。
阅读更多2024-11-15
如何使用Jupyter
Jupyter Notebook 是一个开源的 Web 应用程序，允许你创建和共享包含实时代码、方程、可视化和解释性文本的文档。Jupyter Notebook 还支持许多高级功能，如魔法命令、扩展、
阅读更多2024-11-15
利用飞书多维表格自动发布版本
飞书的多维表格有自动化的能力，我们每周只需要设定好版本发布的时间，可以让其自动触发版本发布，并在群里通知所有人。那么假定我们每隔10分钟获取一次，除非在发版前10分钟内修改发版计划，否则都能感知到版本
阅读更多2024-11-15
SQL Server Service Broker完整示例
SQL server Service Broker实战
阅读更多2024-11-15
QT鼠标事件
这篇文章介绍如何使用事件和获取事件的信号。
阅读更多2024-11-15
基于Python+Vue开发的旅游景区管理系统
该项目是基于Python+Vue开发的旅游景区管理系统（前后端分离），这是一项为大学生课程设计作业而开发的项目。该系统旨在帮助大学生学习并掌握Python编程技能，同时锻炼他们的项目设计与开发能力。通
阅读更多2024-11-15
2023年12月中国电子学会青少年软件编程（Python）等级考试试卷（三级）答案 + 解析
2023年12月中国电子学会青少年软件编程（Python）等级考试试卷（三级）答案 + 解析
阅读更多2024-11-15