HarmonyOS：通过（SQLite）关系型数据库实现数据持久化

news2025/7/19 11:09:44

一、场景介绍

关系型数据库基于SQLite组件，适用于存储包含复杂关系数据的场景，比如一个班级的学生信息，需要包括姓名、学号、各科成绩等，又或者公司的雇员信息，需要包括姓名、工号、职位等，由于数据之间有较强的对应关系，复杂程度比键值型数据更高，此时需要使用关系型数据库来持久化保存数据。

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

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

二、基本概念

谓词：数据库中用来代表数据实体的性质、特征或者数据实体之间关系的词项，主要用来定义数据库的操作条件。

结果集：指用户查询之后的结果集合，可以对数据进行访问。结果集提供了灵活的数据访问方式，可以更方便地拿到用户想要的数据。

三、运作机制

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

关系型数据库运作机制

在这里插入图片描述

约束限制

  • 系统默认日志方式是WAL（Write Ahead Log）模式，系统默认落盘方式是FULL模式。
  • 数据库中有4个读连接和1个写连接，线程获取到空闲读连接时，即可进行读取操作。当没有空闲读连接且有空闲写连接时，会将写连接当做读连接来使用。
  • 为保证数据的准确性，数据库同一时间只能支持一个写操作。
  • 当应用被卸载完成后，设备上的相关数据库文件及临时文件会被自动清除。
  • ArkTS侧支持的基本数据类型：number、string、二进制类型数据、boolean。
  • 为保证插入并读取数据成功，建议一条数据不要超过2M。超出该大小，插入成功，读取失败。

四、接口说明

以下是关系型数据库持久化功能的相关接口，大部分为异步接口。异步接口均有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删除数据库。

五、开发步骤

因Stage模型、FA模型的差异，个别示例代码提供了在两种模型下的对应示例；示例代码未区分模型或没有对应注释说明时默认在两种模型下均适用。

关系库数据库操作或者存储过程中，有可能会因为各种原因发生非预期的数据库损坏（抛出14800011）异常情况，此时需要对数据库进行重建并恢复数据，以保障正常的应用开发，具体可见关系型数据库损坏重建。

1.使用关系型数据库实现数据持久化，需要获取一个RdbStore，其中包括建库、建表、升降级等操作。示例代码如下所示：

Stage模型示例：

import { relationalStore } from '@kit.ArkData'; // 导入模块
import { UIAbility } from '@kit.AbilityKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { window } from '@kit.ArkUI';

// 此处示例在Ability中实现，使用者也可以在其他合理场景中使用
class EntryAbility extends UIAbility {
  onWindowStageCreate(windowStage: window.WindowStage) {
    const STORE_CONFIG :relationalStore.StoreConfig= {
      name: 'RdbTest.db', // 数据库文件名
      securityLevel: relationalStore.SecurityLevel.S3, // 数据库安全级别
      encrypt: false, // 可选参数，指定数据库是否加密，默认不加密
      customDir: 'customDir/subCustomDir', // 可选参数，数据库自定义路径。数据库将在如下的目录结构中被创建：context.databaseDir + '/rdb/' + customDir，其中context.databaseDir是应用沙箱对应的路径，'/rdb/'表示创建的是关系型数据库，customDir表示自定义的路径。当此参数不填时，默认在本应用沙箱目录下创建RdbStore实例。
      isReadOnly: false // 可选参数，指定数据库是否以只读方式打开。该参数默认为false，表示数据库可读可写。该参数为true时，只允许从数据库读取数据，不允许对数据库进行写操作，否则会返回错误码801。
    };

    // 判断数据库版本，如果不匹配则需进行升降级操作
    // 假设当前数据库版本为3，表结构：EMPLOYEE (NAME, AGE, SALARY, CODES, IDENTITY)
    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, IDENTITY UNLIMITED INT)'; // 建表Sql语句, IDENTITY为bigint类型，sql中指定类型为UNLIMITED INT

    relationalStore.getRdbStore(this.context, STORE_CONFIG, (err, store) => {
      if (err) {
        console.error(`Failed to get RdbStore. Code:${err.code}, message:${err.message}`);
        return;
      }
      console.info('Succeeded in getting RdbStore.');

      // 当数据库创建时，数据库默认版本为0
      if (store.version === 0) {
        store.executeSql(SQL_CREATE_TABLE); // 创建数据表
        // 设置数据库的版本，入参为大于0的整数
        store.version = 3;
      }

      // 如果数据库版本不为0且和当前数据库版本不匹配，需要进行升降级操作
      // 当数据库存在并假定版本为1时，例应用从某一版本升级到当前版本，数据库需要从1版本升级到2版本
      if (store.version === 1) {
        // version = 1：表结构：EMPLOYEE (NAME, SALARY, CODES, ADDRESS) => version = 2：表结构：EMPLOYEE (NAME, AGE, SALARY, CODES, ADDRESS)
        (store as relationalStore.RdbStore).executeSql('ALTER TABLE EMPLOYEE ADD COLUMN AGE INTEGER');
        store.version = 2;
      }

      // 当数据库存在并假定版本为2时，例应用从某一版本升级到当前版本，数据库需要从2版本升级到3版本
      if (store.version === 2) {
        // version = 2：表结构：EMPLOYEE (NAME, AGE, SALARY, CODES, ADDRESS) => version = 3：表结构：EMPLOYEE (NAME, AGE, SALARY, CODES)
        (store as relationalStore.RdbStore).executeSql('ALTER TABLE EMPLOYEE DROP COLUMN ADDRESS TEXT');
        store.version = 3;
      }
    });

    // 请确保获取到RdbStore实例后，再进行数据库的增、删、改、查等操作
  }
}

FA模型示例：

import { relationalStore } from '@kit.ArkData'; // 导入模块
import { featureAbility } from '@kit.AbilityKit';
import { BusinessError } from '@kit.BasicServicesKit';

let context = featureAbility.getContext();

const STORE_CONFIG :relationalStore.StoreConfig = {
  name: 'RdbTest.db', // 数据库文件名
  securityLevel: relationalStore.SecurityLevel.S3 // 数据库安全级别
};

// 假设当前数据库版本为3，表结构：EMPLOYEE (NAME, AGE, SALARY, CODES, IDENTITY)
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, IDENTITY UNLIMITED INT)'; // 建表Sql语句，IDENTITY为bigint类型，sql中指定类型为UNLIMITED INT

relationalStore.getRdbStore(context, STORE_CONFIG, (err, store) => {
  if (err) {
    console.error(`Failed to get RdbStore. Code:${err.code}, message:${err.message}`);
    return;
  }
  console.info('Succeeded in getting RdbStore.');

  // 当数据库创建时，数据库默认版本为0
  if (store.version === 0) {
    store.executeSql(SQL_CREATE_TABLE); // 创建数据表
    // 设置数据库的版本，入参为大于0的整数
    store.version = 3;
  }

  // 如果数据库版本不为0且和当前数据库版本不匹配，需要进行升降级操作
  // 当数据库存在并假定版本为1时，例应用从某一版本升级到当前版本，数据库需要从1版本升级到2版本
  if (store.version === 1) {
    // version = 1：表结构：EMPLOYEE (NAME, SALARY, CODES, ADDRESS) => version = 2：表结构：EMPLOYEE (NAME, AGE, SALARY, CODES, ADDRESS)
    store.executeSql('ALTER TABLE EMPLOYEE ADD COLUMN AGE INTEGER');
    store.version = 2;
  }

  // 当数据库存在并假定版本为2时，例应用从某一版本升级到当前版本，数据库需要从2版本升级到3版本
  if (store.version === 2) {
    // version = 2：表结构：EMPLOYEE (NAME, AGE, SALARY, CODES, ADDRESS) => version = 3：表结构：EMPLOYEE (NAME, AGE, SALARY, CODES)
    store.executeSql('ALTER TABLE EMPLOYEE DROP COLUMN ADDRESS TEXT');
    store.version = 3;
  }
});

// 请确保获取到RdbStore实例后，再进行数据库的增、删、改、查等操作

说明

  • 应用创建的数据库与其上下文（Context）有关，即使使用同样的数据库名称，但不同的应用上下文，会产生多个数据库，例如每个UIAbility都有各自的上下文。
  • 当应用首次获取数据库（调用getRdbStore）后，在应用沙箱内会产生对应的数据库文件。使用数据库的过程中，在与数据库文件相同的目录下可能会产生以-wal和-shm结尾的临时文件。此时若开发者希望移动数据库文件到其它地方使用查看，则需要同时移动这些临时文件，当应用被卸载完成后，其在设备上产生的数据库文件及临时文件也会被移除。
  • 错误码的详细介绍请参见通用错误码和关系型数据库错误码。

2.获取到RdbStore后，调用insert()接口插入数据。示例代码如下所示：

let store: relationalStore.RdbStore | undefined = undefined;

let value1 = 'Lisa';
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
let value5 = BigInt('15822401018187971961171');
// 以下三种方式可用
const valueBucket1: relationalStore.ValuesBucket = {
  'NAME': value1,
  'AGE': value2,
  'SALARY': value3,
  'CODES': value4,
  'IDENTITY': value5,
};
const valueBucket2: relationalStore.ValuesBucket = {
  NAME: value1,
  AGE: value2,
  SALARY: value3,
  CODES: value4,
  IDENTITY: value5,
};
const valueBucket3: relationalStore.ValuesBucket = {
  "NAME": value1,
  "AGE": value2,
  "SALARY": value3,
  "CODES": value4,
  "IDENTITY": value5,
};

if (store !== undefined) {
  (store as relationalStore.RdbStore).insert('EMPLOYEE', valueBucket1, (err: BusinessError, rowId: number) => {
    if (err) {
      console.error(`Failed to insert data. Code:${err.code}, message:${err.message}`);
      return;
    }
    console.info(`Succeeded in inserting data. rowId:${rowId}`);
  })
}

说明
关系型数据库没有显式的flush操作实现持久化，数据插入即保存在持久化文件。

3.根据谓词指定的实例对象，对数据进行修改或删除。

调用update()方法修改数据，调用delete()方法删除数据。示例代码如下所示：

let value6 = 'Rose';
let value7 = 22;
let value8 = 200.5;
let value9 = new Uint8Array([1, 2, 3, 4, 5]);
let value10 = BigInt('15822401018187971967863');
// 以下三种方式可用
const valueBucket4: relationalStore.ValuesBucket = {
  'NAME': value6,
  'AGE': value7,
  'SALARY': value8,
  'CODES': value9,
  'IDENTITY': value10,
};
const valueBucket5: relationalStore.ValuesBucket = {
  NAME: value6,
  AGE: value7,
  SALARY: value8,
  CODES: value9,
  IDENTITY: value10,
};
const valueBucket6: relationalStore.ValuesBucket = {
  "NAME": value6,
  "AGE": value7,
  "SALARY": value8,
  "CODES": value9,
  "IDENTITY": value10,
};

// 修改数据
let predicates1 = new relationalStore.RdbPredicates('EMPLOYEE'); // 创建表'EMPLOYEE'的predicates
predicates1.equalTo('NAME', 'Lisa'); // 匹配表'EMPLOYEE'中'NAME'为'Lisa'的字段
if (store !== undefined) {
  (store as relationalStore.RdbStore).update(valueBucket4, predicates1, (err: BusinessError, rows: number) => {
    if (err) {
      console.error(`Failed to update data. Code:${err.code}, message:${err.message}`);
     return;
   }
   console.info(`Succeeded in updating data. row count: ${rows}`);
  })
}

// 删除数据
predicates1 = new relationalStore.RdbPredicates('EMPLOYEE');
predicates1.equalTo('NAME', 'Lisa');
if (store !== undefined) {
  (store as relationalStore.RdbStore).delete(predicates1, (err: BusinessError, rows: number) => {
    if (err) {
      console.error(`Failed to delete data. Code:${err.code}, message:${err.message}`);
      return;
    }
    console.info(`Delete rows: ${rows}`);
  })
}

4.根据谓词指定的查询条件查找数据。

调用query()方法查找数据，返回一个ResultSet结果集。示例代码如下所示：

let predicates2 = new relationalStore.RdbPredicates('EMPLOYEE');
predicates2.equalTo('NAME', 'Rose');
if (store !== undefined) {
  (store as relationalStore.RdbStore).query(predicates2, ['ID', 'NAME', 'AGE', 'SALARY', 'IDENTITY'], (err: BusinessError, resultSet) => {
    if (err) {
      console.error(`Failed to query data. Code:${err.code}, message:${err.message}`);
      return;
    }
    console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`);
    // resultSet是一个数据集合的游标，默认指向第-1个记录，有效的数据从0开始。
    while (resultSet.goToNextRow()) {
      const id = resultSet.getLong(resultSet.getColumnIndex('ID'));
      const name = resultSet.getString(resultSet.getColumnIndex('NAME'));
      const age = resultSet.getLong(resultSet.getColumnIndex('AGE'));
      const salary = resultSet.getDouble(resultSet.getColumnIndex('SALARY'));
      const identity = resultSet.getValue(resultSet.getColumnIndex('IDENTITY'));
      console.info(`id=${id}, name=${name}, age=${age}, salary=${salary}, identity=${identity}`);
    }
    // 释放数据集的内存
    resultSet.close();
  })
}

说明
当应用完成查询数据操作，不再使用结果集（ResultSet）时，请及时调用close方法关闭结果集，释放系统为其分配的内存。

5.在同路径下备份数据库。关系型数据库支持两种手动备份和自动备份（仅系统应用可用）两种方式，具体可见关系型数据库备份。

此处以手动备份为例：

if (store !== undefined) {
  // "Backup.db"为备份数据库文件名，默认在RdbStore同路径下备份。也可指定路径：customDir + "backup.db"
  (store as relationalStore.RdbStore).backup("Backup.db", (err: BusinessError) => {
    if (err) {
      console.error(`Failed to backup RdbStore. Code:${err.code}, message:${err.message}`);
      return;
    }
    console.info(`Succeeded in backing up RdbStore.`);
  })
}

6.从备份数据库中恢复数据。关系型数据库支持两种方式：恢复手动备份数据和恢复自动备份数据（仅系统应用可用），具体可见关系型数据库数据恢复。

此处以调用restore接口恢复手动备份数据为例：

if (store !== undefined) {
  (store as relationalStore.RdbStore).restore("Backup.db", (err: BusinessError) => {
    if (err) {
      console.error(`Failed to restore RdbStore. Code:${err.code}, message:${err.message}`);
      return;
    }
    console.info(`Succeeded in restoring RdbStore.`);
  })
}

7.删除数据库。
调用deleteRdbStore()方法，删除数据库及数据库相关文件。示例代码如下：

Stage模型示例：

relationalStore.deleteRdbStore(this.context, 'RdbTest.db', (err: BusinessError) => {
 if (err) {
    console.error(`Failed to delete RdbStore. Code:${err.code}, message:${err.message}`);
    return;
  }
  console.info('Succeeded in deleting RdbStore.');
});

FA模型示例：

relationalStore.deleteRdbStore(context, 'RdbTest.db', (err: BusinessError) => {
  if (err) {
    console.error(`Failed to delete RdbStore. Code:${err.code}, message:${err.message}`);
    return;
  }
  console.info('Succeeded in deleting RdbStore.');
});

六、示例完整代码

效果图

在这里插入图片描述

TestRdbStore.ets代码

import { relationalStore } from '@kit.ArkData'
import { common } from '@kit.AbilityKit'
import { util } from '@kit.ArkTS'
import { BusinessError } from '@kit.BasicServicesKit';
import { window } from '@kit.ArkUI';

let context = getContext(this) as common.UIAbilityContext;
let mStore: relationalStore.RdbStore | undefined = undefined;

const STORE_CONFIG: relationalStore.StoreConfig = {
  name: 'RdbTest.db', // 数据库文件名
  securityLevel: relationalStore.SecurityLevel.S3, // 数据库安全级别
  encrypt: false, // 可选参数，指定数据库是否加密，默认不加密
  customDir: 'customDir/subCustomDir', // 可选参数，数据库自定义路径。数据库将在如下的目录结构中被创建：context.databaseDir + '/rdb/' + customDir，其中context.databaseDir是应用沙箱对应的路径，'/rdb/'表示创建的是关系型数据库，customDir表示自定义的路径。当此参数不填时，默认在本应用沙箱目录下创建RdbStore实例。
  isReadOnly: false // 可选参数，指定数据库是否以只读方式打开。该参数默认为false，表示数据库可读可写。该参数为true时，只允许从数据库读取数据，不允许对数据库进行写操作，否则会返回错误码801。
};

// 判断数据库版本，如果不匹配则需进行升降级操作
// 假设当前数据库版本为3，表结构：EMPLOYEE (NAME, AGE, SALARY, CODES, IDENTITY)
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, IDENTITY UNLIMITED INT)'; // 建表Sql语句, IDENTITY为bigint类型，sql中指定类型为UNLIMITED INT

function initRdbTestDB() {
  relationalStore.getRdbStore(context, STORE_CONFIG, (err, store) => {
    if (err) {
      console.error(`获取数据库失败，Failed to get RdbStore. Code:${err.code}, message:${err.message}`);
      return;
    }
    mStore = store;
    console.info('获取数据库成功，Succeeded in getting RdbStore.');
  });
}

function createTable() {
  if (mStore == null || mStore == undefined) {
    console.log("createTable 失败 ， mStore 为空或未定义")
    return;
  }

  // 当数据库创建时，数据库默认版本为0
  if (mStore.version === 0) {
    mStore.executeSql(SQL_CREATE_TABLE); // 创建数据表
    // 设置数据库的版本，入参为大于0的整数
    // store.version = 3;
    mStore.version = 1;
    console.log("createTable 完毕")
  }

}

function alterTable1() {
  if (mStore == null || mStore == undefined) {
    console.log("alterTable1 失败 ， mStore 为空或未定义")
    return;
  }
  // 如果数据库版本不为0且和当前数据库版本不匹配，需要进行升降级操作
  // 当数据库存在并假定版本为1时，例应用从某一版本升级到当前版本，数据库需要从1版本升级到2版本
  if (mStore.version === 1) {
    // version = 1：表结构：EMPLOYEE (NAME, SALARY, CODES, ADDRESS) => version = 2：表结构：EMPLOYEE (NAME, AGE, SALARY, CODES, ADDRESS)
    mStore.executeSql('ALTER TABLE EMPLOYEE ADD COLUMN AGE INTEGER');
    mStore.version = 2;
    console.log("alterTable1 完毕")
  }
}

function alterTable2() {
  if (mStore == null || mStore == undefined) {
    console.log("alterTable2 失败 ， mStore 为空或未定义")
    return;
  }
  // 当数据库存在并假定版本为2时，例应用从某一版本升级到当前版本，数据库需要从2版本升级到3版本
  if (mStore.version === 2) {
    // version = 2：表结构：EMPLOYEE (NAME, AGE, SALARY, CODES, ADDRESS) => version = 3：表结构：EMPLOYEE (NAME, AGE, SALARY, CODES)
    (mStore as relationalStore.RdbStore).executeSql('ALTER TABLE EMPLOYEE DROP COLUMN ADDRESS TEXT');
    mStore.version = 3;
    console.log("alterTable2 完毕")
  }
}

/**
 * 获取到RdbStore后，调用insert()接口插入数据。
 */
function insertData() {
  let value1 = 'Lisa';
  let value2 = 18;
  let value3 = 100.5;
  let value4 = new Uint8Array([1, 2, 3, 4, 5]);
  let value5 = BigInt('15822401018187971961171');
  // 以下三种方式可用
  const valueBucket1: relationalStore.ValuesBucket = {
    'NAME': value1,
    'AGE': value2,
    'SALARY': value3,
    'CODES': value4,
    'IDENTITY': value5,
  };
  const valueBucket2: relationalStore.ValuesBucket = {
    NAME: value1,
    AGE: value2,
    SALARY: value3,
    CODES: value4,
    IDENTITY: value5,
  };
  const valueBucket3: relationalStore.ValuesBucket = {
    "NAME": value1,
    "AGE": value2,
    "SALARY": value3,
    "CODES": value4,
    "IDENTITY": value5,
  };

  if (mStore !== undefined) {
    (mStore as relationalStore.RdbStore).insert('EMPLOYEE', valueBucket1, (err: BusinessError, rowId: number) => {
      if (err) {
        console.error(`插入数据失败：Failed to insert data. Code:${err.code}, message:${err.message}`);
        return;
      }
      console.info(`插入数据成功：Succeeded in inserting data. rowId:${rowId}`);
    })
  }
}

/**
 * 根据谓词指定的实例对象，对数据进行修改或删除。

 调用update()方法修改数据，调用delete()方法删除数据
 */
function updateData() {
  let value6 = 'Rose';
  let value7 = 22;
  let value8 = 200.5;
  let value9 = new Uint8Array([1, 2, 3, 4, 5]);
  let value10 = BigInt('15822401018187971967863');
  // 以下三种方式可用
  const valueBucket4: relationalStore.ValuesBucket = {
    'NAME': value6,
    'AGE': value7,
    'SALARY': value8,
    'CODES': value9,
    'IDENTITY': value10,
  };
  const valueBucket5: relationalStore.ValuesBucket = {
    NAME: value6,
    AGE: value7,
    SALARY: value8,
    CODES: value9,
    IDENTITY: value10,
  };
  const valueBucket6: relationalStore.ValuesBucket = {
    "NAME": value6,
    "AGE": value7,
    "SALARY": value8,
    "CODES": value9,
    "IDENTITY": value10,
  };

  // 修改数据
  let predicates1 = new relationalStore.RdbPredicates('EMPLOYEE'); // 创建表'EMPLOYEE'的predicates
  predicates1.equalTo('NAME', 'Lisa'); // 匹配表'EMPLOYEE'中'NAME'为'Lisa'的字段
  if (mStore !== undefined) {
    (mStore as relationalStore.RdbStore).update(valueBucket4, predicates1, (err: BusinessError, rows: number) => {
      if (err) {
        console.error(`修改数据 Failed to update data. Code:${err.code}, message:${err.message}`);
        return;
      }
      console.info(`修改数据 Succeeded in updating data. row count: ${rows}`);
    })
  }
}

/**
 * 删除数据
 */
function deleteData() {
  let predicates1 = new relationalStore.RdbPredicates('EMPLOYEE'); // 创建表'EMPLOYEE'的predicates
  // 删除数据
  predicates1 = new relationalStore.RdbPredicates('EMPLOYEE');
  predicates1.equalTo('NAME', 'Lisa');
  if (mStore !== undefined) {
    (mStore as relationalStore.RdbStore).delete(predicates1, (err: BusinessError, rows: number) => {
      if (err) {
        console.error(`删除数据 Failed to delete data. Code:${err.code}, message:${err.message}`);
        return;
      }
      console.info(`删除数据 Delete rows: ${rows}`);
    })
  }
}

/**
 * 根据谓词指定的查询条件查找数据。
 调用query()方法查找数据，返回一个ResultSet结果集。

 说明
 当应用完成查询数据操作，不再使用结果集（ResultSet）时，请及时调用close方法关闭结果集，释放系统为其分配的内存。
 */
function queryData() {
  let predicates2 = new relationalStore.RdbPredicates('EMPLOYEE');
  predicates2.equalTo('NAME', 'Rose');
  if (mStore !== undefined) {
    (mStore as relationalStore.RdbStore).query(predicates2, ['ID', 'NAME', 'AGE', 'SALARY', 'IDENTITY'],
      (err: BusinessError, resultSet) => {
        if (err) {
          console.error(`查找数据 Failed to query data. Code:${err.code}, message:${err.message}`);
          return;
        }
        console.info(`查找数据 ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`);
        // resultSet是一个数据集合的游标，默认指向第-1个记录，有效的数据从0开始。
        while (resultSet.goToNextRow()) {
          const id = resultSet.getLong(resultSet.getColumnIndex('ID'));
          const name = resultSet.getString(resultSet.getColumnIndex('NAME'));
          const age = resultSet.getLong(resultSet.getColumnIndex('AGE'));
          const salary = resultSet.getDouble(resultSet.getColumnIndex('SALARY'));
          const identity = resultSet.getValue(resultSet.getColumnIndex('IDENTITY'));
          console.info(`id=${id}, name=${name}, age=${age}, salary=${salary}, identity=${identity}`);
        }
        // 释放数据集的内存
        resultSet.close();
      })
  }
}

/**
 * 在同路径下备份数据库。关系型数据库支持两种手动备份和自动备份（仅系统应用可用）两种方式，具体可见关系型数据库备份。

 此处以手动备份为例：
 */
function backupData() {
  if (mStore !== undefined) {
    // "Backup.db"为备份数据库文件名，默认在RdbStore同路径下备份。也可指定路径：customDir + "backup.db"
    (mStore as relationalStore.RdbStore).backup("Backup.db", (err: BusinessError) => {
      if (err) {
        console.error(`备份数据库 Failed to backup RdbStore. Code:${err.code}, message:${err.message}`);
        return;
      }
      console.info(`备份数据库 Succeeded in backing up RdbStore.`);
    })
  }
}

/**
 * 从备份数据库中恢复数据。关系型数据库支持两种方式：恢复手动备份数据和恢复自动备份数据（仅系统应用可用），具体可见关系型数据库数据恢复。

 此处以调用restore接口恢复手动备份数据为例：
 */

function restoreData() {
  if (mStore !== undefined) {
    (mStore as relationalStore.RdbStore).restore("Backup.db", (err: BusinessError) => {
      if (err) {
        console.error(`从备份数据库中恢复数据 Failed to restore RdbStore. Code:${err.code}, message:${err.message}`);
        return;
      }
      console.info(`从备份数据库中恢复数据 Succeeded in restoring RdbStore.`);
    })
  }
}

/**
 * 删除数据库。

 调用deleteRdbStore()方法，删除数据库及数据库相关文件。示例代码如下：

 Stage模型示例：
 */
function deleteDB() {
  relationalStore.deleteRdbStore(context, 'RdbTest.db', (err: BusinessError) => {
    if (err) {
      console.error(`Failed to delete RdbStore. Code:${err.code}, message:${err.message}`);
      return;
    }
    console.info('Succeeded in deleting RdbStore.');
  });
}

@Entry
@Component
struct TestRdbStore {
  @State message: string = '通过关系型数据库实现数据持久化';

  build() {
    Column({ space: 10 }) {
      Text(this.message)
        .id('TestRdbStoreHelloWorld')
        .fontSize(20)
        .fontWeight(FontWeight.Bold)
      Button("初始化数据库")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          initRdbTestDB()
        })
      Button("创建数据表")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          createTable()
        })

      Button("修改数据表1")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          alterTable1()
        })
      Button("修改数据表2")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          alterTable2()
        })

      Button("插入数据")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          insertData()
        })
      Button("更新数据")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          updateData()
        })
      Button("删除数据")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          deleteData()
        })
      Button("查询数据")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          queryData()
        })
      Button("备份数据")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          backupData()
        })
      Button("从备份数据库中恢复数据")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          restoreData()
        })

      Button("删除数据库")
        .fontColor(Color.White)
        .fontSize(20)
        .fontWeight(FontWeight.Medium)
        .onClick(() => {
          deleteDB()
        })
    }

    .height('100%')
    .width('100%')
  }
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2281335.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

豆包MarsCode 蛇年编程大作战 | 高效开发“蛇年运势预测系统”

豆包MarsCode 蛇年编程大作战 | 高效开发“蛇年运势预测系统”

🌟 嗨，我是LucianaiB！ 🌍 总有人间一两风，填我十万八千梦。 🚀 路漫漫其修远兮，吾将上下而求索。 豆包MarsCode 蛇年编程大作战 | 🐍 蛇年运势预测 在线体验地址：蛇年…
阅读更多...
JAVA-快速排序

JAVA-快速排序

一、快速排序基本思想 快速排序是 Hoare 于 1962 年提出的一种二叉树结构的交换排序方法，其基本思想为： 任取待排序元素序列中的某元 素作为基准值，按照该排序码将待排序集合分割成两子序列，左子序列中所有元素均小于基准值&#…
阅读更多...
acm培训 part 1（题解）

acm培训 part 1（题解）

第一部分的培训为语法糖，stl容器以及复杂度。 题目分析 1.1 Long Loong AtCoder - abc336_a ​​ 这道题的重点在于多个o的输出。在保证前面‘L’ 的输出和后面‘ng’的输出下，输入需要输出的o的数字，来实现需要输出的效果。 代码如下 …
阅读更多...
vulfocus/fastjson-cnvd_2017_02833复现

vulfocus/fastjson-cnvd_2017_02833复现

漏洞概述 Fastjson 是阿里巴巴开发的一个高性能的 Java 库，用于将 Java 对象转换成 JSON 格式（序列化），以及将 JSON 字符串转换回 Java 对象（反序列化）。 fastjson在解析json的过程中,支持使用type字段来指…
阅读更多...
Ceisum无人机巡检直播视频投射

Ceisum无人机巡检直播视频投射

接上次的视频投影，Leader告诉我这个视频投影要用在两个地方，一个是我原先写的轨迹回放那里，另一个在无人机起飞后的地图回显，要实时播放无人机拍摄的视频，还要能转镜头，让我把这个也接一下。 我的天&#x…
阅读更多...
一句话，我让 AI 帮我做了个 P 图网站！

一句话，我让 AI 帮我做了个 P 图网站！

每到过节，不少小伙伴都会给自己的头像 P 个图，加点儿装饰。 比如圣诞节给自己头上 P 个圣诞帽，国庆节 P 个小红旗等等。这是一类比较简单、需求量却很大的 P 图场景，也有很多现成的网站和小程序，能帮你快速完成这件事…
阅读更多...
【深度学习】 自动微分

【深度学习】 自动微分

自动微分 正如上节所说，求导是几乎所有深度学习优化算法的关键步骤。 虽然求导的计算很简单，只需要一些基本的微积分。 但对于复杂的模型，手工进行更新是一件很痛苦的事情（而且经常容易出错）。 深度学习框架通过自动…
阅读更多...
Go语言中的值类型和引用类型特点

Go语言中的值类型和引用类型特点

一、值类型 值类型的数据直接包含值，当它们被赋值给一个新的变量或者作为参数传递给函数时，实际上是创建了原值的一个副本。这意味着对新变量的修改不会影响原始变量的值。 Go中的值类型包括： 基础类型：int，float64…
阅读更多...
Vue2 项目二次封装Axios

Vue2 项目二次封装Axios

引言 在现代前端开发中，HTTP请求管理是构建健壮应用的核心能力之一。Axios作为目前最流行的HTTP客户端库，其灵活性和可扩展性为开发者提供了强大的基础能力。 1. 为什么要二次封装Axios？ 1.1 统一项目管理需求 API路径标准化：…
阅读更多...
使用Layout三行布局（SemiDesign）

使用Layout三行布局（SemiDesign）

tips：Semi Design网址 ：Semi Design 1、安装Semi # 使用 npm npm i douyinfe/semi-ui# 使用 yarn yarn add douyinfe/semi-ui# 使用 pnpm pnpm add douyinfe/semi-ui 2、引入Layout布局 import { Layout } from douyinfe/semi-ui;3、开始实现三行布局…
阅读更多...
css命名规范——BEM

css命名规范——BEM

目录 引言 BEM是什么？ 块Block 元素Element 修饰语Modifier BEM解决了哪些问题？ 在流行框架的组件中使用 BEM 格式 实战 认识设计图 如何使用当前的css规范正确命名？ 引言 css样式类命名难、太难了，难于上青天，这个和js变量命名还不一样。看看项目中五花八门的样…
阅读更多...
mysql 学习2 MYSQL数据模型，mysql内部可以创建多个数据库，一个数据库中有多个表；表是真正放数据的地方，关系型数据库 。

mysql 学习2 MYSQL数据模型，mysql内部可以创建多个数据库，一个数据库中有多个表；表是真正放数据的地方，关系型数据库 。

在第一章中安装 ，启动mysql80 服务后，连接上了mysql，那么就要 使用 SQL语句来 操作mysql数据库了。那么在学习 SQL语言操作 mysql 数据库 之前，要对于 mysql数据模型有一个了解。 MYSQL数据模型 在下图中 客户端 将 SQL语言&…
阅读更多...
（十四）WebGL纹理坐标初识

（十四）WebGL纹理坐标初识

纹理坐标是 WebGL 中将 2D 图像（纹理）应用到 3D 物体表面的重要概念。在 WebGL 中，纹理坐标通常使用一个二维坐标系，称为 uv 坐标，它们决定了纹理图像如何映射到几何体上。理解纹理坐标的核心就是明白它们如何将二维纹…
阅读更多...
数据统计–图形报表（day11）

数据统计–图形报表（day11）

Apache ECharts 介绍 Apache ECharts 介绍 Apache ECharts 是一款基于 Javascript 的数据可视化图表库，提供直观，生动，可交互，可个性化定制的数据可视化图表。 官网地址：Apache ECharts 入门案例 Apache Echarts官方…
阅读更多...
小游戏源码开发搭建技术栈和服务器配置流程

小游戏源码开发搭建技术栈和服务器配置流程

近些年各种场景小游戏开发搭建版本层出不穷,山东布谷科技拥有多年海内外小游戏源码开发经验，现为从事小游戏源码开发或游戏运营的朋友们详细介绍小游戏开发及服务器配置流程。 一、可以对接到app的小游戏是如何开发的 1、小游戏源码开发的需求分析： 明…
阅读更多...
Android Studio安装配置

Android Studio安装配置

一、注意事项 想做安卓app和开发板通信，踩了大坑，Android 开发不是下载了就能直接开发的，对于新手需要注意的如下： 1、Android Studio版本，根据自己的Android Studio版本对应决定了你所兼容的AGP（Android…
阅读更多...
三分钟简单了解一些HTML的标签和语法_02

三分钟简单了解一些HTML的标签和语法_02

1.a标签演示 点击然后跳转 代码加入title 2.图片链接 3.锚点链接 点击就会跳转的当前位置 4.a标签小知识补充 该实例会跳转到顶,锚点链接则会跳转到相应的锚点 5. 结果:直接跳转到该页面的锚点处 6. 在 HTML 中&#xff0c;<tr>标签表示表格中的行&#xff08;TableRow&…
阅读更多...
【CES2025】超越界限：ThinkAR推出8小时满电可用的超轻AR眼镜AiLens

【CES2025】超越界限：ThinkAR推出8小时满电可用的超轻AR眼镜AiLens

在2025年国际消费类电子产品展览会（CES 2025）上，日本AR技术开发商ThinkAR携手超低功耗半导体和边缘AI解决方案提供商Ambiq，共同推出了名为AiLens的最新AR眼镜产品。这款设备不仅具备轻便的设计，而且拥有长达8小时的连续使用时间，为用户带来了前所未有的便捷体验。 AiLen…
阅读更多...
Vue入门(Vue基本语法、axios、组件、事件分发）

Vue入门(Vue基本语法、axios、组件、事件分发）

Vue入门 Vue概述 Vue (读音/vju/&#xff0c;类似于view)是一套用于构建用户界面的渐进式框架&#xff0c;发布于2014年2月。与其它大型框架不同的是&#xff0c;Vue被设计为可以自底向上逐层应用。Vue的核心库只关注视图层&#xff0c;不仅易于上手&#xff0c;还便于与第三…
阅读更多...
vue项目的创建

vue项目的创建

运行第一个vue-cli应用程序 创建一个基于webpack模板的vue应用程序 vue init webpack 项目名根据自己需求选择 创建好之后如下 运行 cd vue01npm run dev运行之后如下 复制访问地址 &#xff1a; http://localhost:8080 停止服务 两次ctrlC 或者 一次ctrlc然后y idea中使用…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023