HarmonyOS NEXT 关系型数据存储-CFANZ编程社区

HarmonyOS NEXT 关系型数据存储

在应用开发中，关系型数据存储是一种常用的方式，用于管理和维护结构化的数据。HarmonyOS 提供了对 SQLite 的支持，使开发者能够在设备上高效地进行关系型数据库操作。

介绍

关系型数据存储: 是一种以表格形式组织数据的存储技术，支持复杂的查询、更新和事务操作。
HarmonyOS 支持: 提供了对 SQLite 数据库的内置支持，方便开发者进行数据管理。

应用使用场景

用户信息管理: 存储和管理用户的个人资料、偏好设置等。
内容管理系统: 管理跨多个类别的文本、图片和视频等多媒体内容。
财务应用: 记录交易明细、生成报告和执行统计分析。

原理解释

数据表结构: 使用表来定义数据的结构，每个表拥有列和行。
SQL操作: 使用 SQL 语句进行数据的增删改查（CRUD）操作。
事务处理: 确保一系列数据库操作的原子性和一致性。

算法原理流程图

[启动应用] --> [连接数据库] --> [执行SQL语句]
    |                              |
    --------------------------------
    |
[处理结果集] --> [关闭连接]

算法原理解释

启动应用: 初始化应用环境，并准备数据库资源。
连接数据库: 打开或创建一个数据库连接。
执行SQL语句: 使用 SQL 进行数据操作，如 SELECT、INSERT、UPDATE、DELETE。
处理结果集: 解析查询结果并在 UI 中呈现或用于其他逻辑。
关闭连接: 操作完成后释放数据库连接，保持资源优化。

实际详细应用 ArkTS + ArkUI 代码示例实现

以下是一个 ArkTS 示例，展示如何在 HarmonyOS 中使用 SQLite 执行基本的数据库操作：

// dbService.ts
import rdb from '@ohos.data.rdb';

const TAG = 'DBService';
let rdbStore;

export async function initDatabase() {
  try {
    const config = { name: 'example.db' };
    rdbStore = await rdb.getRdbStore(config, 1);
    console.info(TAG, 'Database connected.');
    
    const createTableQuery = `CREATE TABLE IF NOT EXISTS users (
      id INTEGER PRIMARY KEY AUTOINCREMENT,
      name TEXT NOT NULL,
      email TEXT)`;
    await rdbStore.executeSql(createTableQuery);
    console.info(TAG, 'Table created.');
  } catch (error) {
    console.error(TAG, 'Failed to initialize database:', error);
  }
}

export async function insertUser(name, email) {
  try {
    const values = { name, email };
    await rdbStore.insert('users', values);
    console.info(TAG, 'User inserted:', values);
  } catch (error) {
    console.error(TAG, 'Failed to insert user:', error);
  }
}

export async function queryUsers() {
  try {
    const resultSet = await rdbStore.query({ table: 'users', columns: ['id', 'name', 'email'] });
    let users = [];
    while (resultSet.goToNextRow()) {
      users.push({
        id: resultSet.getInt(0),
        name: resultSet.getString(1),
        email: resultSet.getString(2)
      });
    }
    resultSet.close();
    return users;
  } catch (error) {
    console.error(TAG, 'Failed to query users:', error);
    return [];
  }
}