HarmonyOS NEXT 鸿蒙中关系型数据库@ohos.data.relationalStore API 9+

核心API

@ohos.data.relationalStore API 9+

数据库

数据库是存储和管理数据的系统

数据库（Database）是一个以特定方式组织、存储和管理数据的集合，通常用于支持各种应用程序和系统的运行。它不仅是存放数据的仓库，还通过一定的规则和结构来确保数据的高效查询和管理。‌

数据库的核心特点

‌数据存储‌：数据库可以存储大量数据，从百万条到上亿条不等，且数据按特定规则组织，以提高查询效率。
‌数据管理‌：数据库通过数据库管理系统（DBMS）进行统一管理，确保数据的安全性、完整性和一致性。
‌数据共享‌：数据库支持多用户同时访问，且数据可以被多个应用程序共享和使用。

数据库的常见类型

‌关系型数据库‌：基于关系模型，数据以表格形式存储，支持SQL语言进行复杂查询，如MySQL、Oracle等。
‌非关系型数据库（NoSQL）‌：适用于非结构化或半结构化数据，具有更好的横向扩展能力，如MongoDB、Redis等。

鸿蒙的关系型数据库用法 @ohos.data.relationalStore API 9+

关系型数据库（Relational Database，RDB）是一种基于关系模型来管理数据的数据库。关系型数据库基于SQLite组件提供了一套完整的对本地数据库进行管理的机制，对外提供了一系列的增、删、改、查等接口，也可以直接运行用户输入的SQL语句来满足复杂的场景需要。支持通过ResultSet.getSendableRow方法获取Sendable数据，进行跨线程传递。

为保证插入并读取数据成功，建议一条数据不要超过2M。超出该大小，插入成功，读取失败。

大数据量场景下查询数据可能会导致耗时长甚至应用卡死，如有相关操作可参考文档批量数据写数据库场景，且有建议如下：

单次查询数据量不超过5000条。
在TaskPool中查询。
拼接SQL语句尽量简洁。
合理地分批次查询。

该模块提供以下关系型数据库相关的常用功能：

RdbPredicates：数据库中用来代表数据实体的性质、特征或者数据实体之间关系的词项，主要用来定义数据库的操作条件。
RdbStore：提供管理关系数据库(RDB)方法的接口。
ResultSet：提供用户调用关系型数据库查询接口之后返回的结果集合。
Transaction：提供管理事务对象的接口。

使用数据库封装一个数据库工具，用于存储录音

在之前的文章中，我们完成了一些录音和播放的功能，但是目前只能现录现播。如果我们想把录音数据存起来，这时候用关系型数据库就比较合适。

首先我们要准备好要存储的数据类型，并且继承数据库提供的“桶”类型ValuesBucket
要有一个初始化数据库的方法，获取上下文，并判断是否获取到上下文
如果数据库不存在就创建relationalStore.getRdbStore，存在就不创建
store.executeSql在数据库中创建或打开表，SQL语句可以去用AI生成
需要增删改查四个方法
增：直接传入要添加的数据
删：创建谓词对象，传入Id，根据id找到行，然后删除
改：创建谓词对象，传入整个对象，找到修改行，更新
查：创建谓词对象，传入user_Id,采用游标移动取值，循环到没有下一行为止，每一次循环都在数组中追加当前的行，最后返回一个数组。

import { relationalStore, ValuesBucket } from "@kit.ArkData"
import { InterviewAudioItem } from "../../models"export interface InterviewAudioItem extends ValuesBucket {id: number | nulluser_id: stringname: stringpath: stringduration: numbersize: numbercreate_time: number
}class AudioDB {store?: relationalStore.RdbStoretableName = 'success_audio'// 1. 初始化数据库和数据库表async initStore() {// 1.0 获取上下文const ctx = AppStorage.get<Context>('context')if (ctx) {// 1.1 创建数据库// 有则获取, 没有则创建const store = await relationalStore.getRdbStore(ctx, {name: 'interview_audio.db',securityLevel: relationalStore.SecurityLevel.S1})// 1.2 在数据库中创建一张数据库表store.executeSql(`CREATE TABLE IF NOT EXISTS ${this.tableName} (id INTEGER PRIMARY KEY AUTOINCREMENT,user_id TEXT NOT NULL,name TEXT NOT NULL,path TEXT NOT NULL,duration INTEGER NOT NULL,size INTEGER NOT NULL,create_time INTEGER NOT NULL)`)this.store = store}}// 2. 添加一条音频数据async insert(item: InterviewAudioItem) {if (this.store) {const rowId = await this.store.insert(this.tableName, item)if (rowId === undefined || rowId === -1) {return Promise.reject('插入音频数据失败')} else {return Promise.resolve()}}}// 3. 删除一条音频数据async delete(audioId: number) {if (this.store) {const predicates = new relationalStore.RdbPredicates(this.tableName)predicates.equalTo('id', audioId)const rowId = await this.store.delete(predicates)if (rowId === undefined || rowId === -1) {return Promise.reject('删除音频数据失败')} else {return Promise.resolve()}}}// 4. 修改一条音频数据async update(item: InterviewAudioItem) {if (this.store) {const predicates = new relationalStore.RdbPredicates(this.tableName)predicates.equalTo('id', item.id)const rowId = await this.store.update(item, predicates)if (rowId === undefined || rowId === -1) {return Promise.reject('修改音频数据失败')} else {return Promise.resolve()}}}// 5. 根据用户id查询用户所有的录音数据async query(userId: string) {if (this.store) {// 1. 创建一个基于查询条件的谓词对象const predicates = new relationalStore.RdbPredicates(this.tableName)predicates.equalTo('user_id', userId)// 2. 执行数据库查询得到结果集const resultSet = await this.store.query(predicates)if (!resultSet) {return Promise.reject('query fail')}// 3. 采用游标移动取值const list: InterviewAudioItem[] = []// 3.1 如果有下一行, 则继续循环while (resultSet?.goToNextRow()) {list.push(resultSet.getRow() as InterviewAudioItem)}// 3.2 关闭查询结果集resultSet.close()return Promise.resolve(list)}return Promise.reject('暂无数据库')}
}export const audioDB = new AudioDB()

这样一个完整功能的数据库工具就创建好了，那么我们就直接去把录音存到数据库中吧！

在录音页面中使用数据库保存数据

首先在页面开始时初始化数据库

  async aboutToAppear() {await this.getPermission()// 2. 初始化数据库await audioDB.initStore()}

初始化完成可以在设备管理器中看到三个数据库相关文件

在录制开始的函数中，我们记录下开始时间

在点击结束录制的时候，我们再额外调用一个方法，传入音频类型的项，调用数据库方法插入数据库中。

// 存入数据库方法async onRecordEnd(item: InterviewAudioItem) {await audioDB.insert(item)AlertDialog.show({ message: '录音保存成功' })}Button('停止录制').onClick(() => {this.stopRecord()// 以只读的方式根据路径打开文件const file = fileIo.openSync(this.filePath, fileIo.OpenMode.READ_ONLY)const stat = fileIo.statSync(file.fd)this.onRecordEnd({id: null,user_id: auth.getUser().id,name: dayjs().format('YYYY年MM月DD日_hh点mm分ss秒'),path: this.filePath || '',duration: Date.now() - this.startTime,create_time: Date.now(),size: stat.size})promptAction.showToast({ message: '停止录制' })})

点击开始录音录制一段时间，然后结束录制