• sql：原生用于查询的sql语句。
• selectionArgs：sql语句中占位符参数的值，若select语句中没有使用占位符，该参数可以设置为null。

查询结果集的使用

关系型数据库提供了查询返回的结果集ResultSet，其指向查询结果中的一行数据，供用户对查询结果进行遍历和访问。ResultSet对外API如下所示。

表7 结果集API |类名|接口名|描述| | —-| —-| —-| |ResultSet|int GoTo(int offset)|从结果集当前位置移动指定偏移量。| |ResultSet|int GoToRow(int position)|将结果集移动到指定位置。| |ResultSet|int GoToNextRow()|将结果集向后移动一行。| |ResultSet|int GoToPreviousRow()|将结果集向前移动一行。| |ResultSet|int IsStarted(bool &result)|判断结果集是否被移动过。| |ResultSet|int IsEnded(bool &result)|判断结果集是否被移动到最后一行之后。| |ResultSet|int IsAtFirstRow(bool &result)|判断结果集当前位置是否在第一行。| |ResultSet|int IsAtLastRow(bool &result)|判断结果集当前位置是否在最后一行。| |ResultSet|int GetRowCount(int &count)|获取当前结果集中的记录条数。| |ResultSet|int GetColumnCount(int &count)|获取结果集中的列数。| |ResultSet|int GetString(int columnIndex, std::string &value)|获取当前行指定列的值，以String类型返回。| |ResultSet|int GetBlob(int columnIndex, std::vector<uint8_t> &blob)|获取当前行指定列的值，以字节数组形式返回。| |ResultSet|int GetDouble(int columnIndex, double &value)|获取当前行指定列的值，以double型返回。|

设置分布式列表

用户可以对当前数据库中的列表设置为分布式列表。

表8 设置分布式列表 |类名|接口名|描述| | —-| —-| —-| |RdbStore|bool SetDistributedTables(const std::vectorstd::string& tables)|设置分布式列表。

• tables：要设置的分布式列表表名

根据本地表名获取指定远程设备的分布式表名

用户根据本地表名获取指定远程设备的分布式表名。在查询远程设备数据库时，需要使用分布式表名。

表9 根据本地表名获取指定远程设备的分布式表名 |类名|接口名|描述| | —-| —-| —-| |RdbStore|std::string ObtainDistributedTableName(const std::string& device, const std::string& table)|根据本地表名获取指定远程设备的分布式表名。在查询远程设备数据库时，需要使用分布式表名。

• device：远程设备ID
• table：本地表名

在设备之间同步数据

表10 在设备之间同步数据 |类名|接口名|描述| | —-| —-| —-| |RdbStore|bool Sync(const SyncOption& option, const AbsRdbPredicates& predicate, const SyncCallback& callback)|在设备之间同步数据。

• option：同步选项；mode：同步模式(PUSH表示数据从本地设备推送到远程设备/PULL表示数据从远程设备拉至本地设备)；isBlock：是否阻塞
• callback：指定的callback回调函数

注册数据库的观察者

表11 注册数据库的观察者 |类名|接口名|描述| | —-| —-| —-| |RdbStore|bool Subscribe(const SubscribeOption& option, RdbStoreObserver *observer)|注册数据库的观察者。当分布式数据库中的数据发生更改时，将调用回调。

• option：订阅类型；
• observer：指分布式数据库中数据更改事件的观察者

从数据库中删除指定类型的指定观察者

表12 从数据库中删除指定类型的指定观察者 |类名|接口名|描述| | —-| —-| —-| |RdbStore|bool UnSubscribe(const SubscribeOption& option, RdbStoreObserver *observer)|从数据库中删除指定类型的指定观察者。

• option：订阅类型；
• observer：指已注册的数据更改观察者

数据库的备份和恢复

关系型数据库提供对本地数据库文件的备份和恢复能力，相关API如下所示。

• 备份

关系型数据库提供了备份数据库文件的接口，通过databasePath指定的备份文件名（支持路径）备份当前数据库文件。通过返回值判断是否备份成功，成功时返回0，失败时则返回相应的错误码。

表13 数据库备份API

• 恢复

关系型数据库提供了恢复数据库文件的接口，通过backupPath指定的备份文件名（支持路径）恢复当前数据库文件。通过返回值判断是否恢复成功，成功时返回0，失败时则返回相应的错误码。

表14 数据库恢复API

事务

事务（Transaction）是一个对数据库执行工作单元。通过返回值判断事务是否成功，成功时返回0，失败时则返回相应的错误码。

表15 事务API

约束与限制

无。

开发步骤

1. 创建数据库。

   a. 配置数据库相关信息，包括数据库的名称、存储模式、是否为只读模式等。

   b. 初始化数据库表结构和相关数据。

   c. 创建数据库。

   示例代码如下：

   const std::string DATABASE_NAME = RDB_TEST_PATH + "RdbStoreTest.db";
   const std::string CREATE_TABLE_TEST = "CREATE TABLE IF NOT EXISTS test (id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT, age INTEGER, salary REAL, blobType BLOB)";
   
   
   class OpenCallback : public RdbOpenCallback {
   public:
       int OnCreate(RdbStore &rdbStore) override;
       int OnUpgrade(RdbStore &rdbStore, int oldVersion, int newVersion) override;
   };
   
   
   int OpenCallback::OnCreate(RdbStore &store)
   {
       return store.ExecuteSql(CREATE_TABLE_TEST);
   }
   
   
   RdbStoreConfig config(DATABASE_NAME);
   OpenCallback callback;
   
   
   std::shared_ptr<RdbStore> store = RdbHelper::GetRdbStore(config, 1, callback, 0); 
   

2. 插入数据。

   a. 构造要插入的数据，以ValuesBucket形式存储。

   b. 调用关系型数据库提供的插入接口。

   c. 创建数据库。

   示例代码如下：

   ValuesBucket values;
   
   
   values.PutInt("id", 1);
   values.PutString("name", std::string("Tom"));
   values.PutInt("age", 18);
   values.PutDouble("salary", 100.5);
   values.PutBlob("blobType", std::vector<uint8_t>{ 1, 2, 3 });
   store->Insert(id, "test", values);
   

3. 查询数据。

   a. 构造用于查询的谓词对象，设置查询条件。

   b. 指定查询返回的数据列。

   c. 调用查询接口查询数据。

   d. 调用结果集接口，遍历返回结果。

   示例代码如下：

   std::vector<std::string> columns = {"id", "name", "age", "salary"};
   
   
   RdbPredicates predicates("test");
   predicates.EqualTo("age", "25")->OrderByAsc("salary");
   std::unique_ptr<ResultSet> resultSet  = store->Query(predicates, columns)
   resultSet.goToNextRow();
   

4. 设置分布式同步表

   a. 调用接口设置分布式同步表。

   示例代码如下：

   store->SetDistributedTables("test");
   

5. 分布式数据同步

   a. 定义同步模式和阻塞状态。

   b. 构造用于同步分布式表的谓词对象，指定组网内的远程设备。

   c. 调用接口同步数据。

   示例代码如下：

   SyncOption option;
   option.mode = PUSH;
   option.isBlock = true;
   AbsRdbPredicates predicate("test");
   predicate.InAllDevices();
   store->Sync(option, predicate, []（const SyncResult& result) {
       for (const auto& [device, status] : result) {
           LogI("device=%s status=%d", device.c_str(), status);
       }
   });
   

6. 分布式数据订阅

   a. 重写数据更改观察者OnChange()函数。

   b. 定义分布式数据订阅类型。

   c. 调用接口实现分布式数据订阅，或取消订阅。

   示例代码如下：

   class MyObserver : public RdbStoreObserver {
   public:
       void OnChange(const std::vector<std::string>& devices) override {
           for (const auto& device : devices) {
               LOGI("device=%s data change", device.c_str());
           }
       }
   };
   
   
   SubscribeOption option;
   option.mode = SubscribeMode::REMOTE;
   MyObserver observer;
   store->Subscribe(option, &observer);  // 分布式数据订阅
   
   
   store->UnSubscribe(option, &observer);  // 取消订阅
   

7. 跨设备查询

a. 根据本地表名获取指定远程设备的分布式表名。

b. 根据指定SQL语句查询数据库中的数据。

示例代码如下： c++ std::string tableName = store->ObtainDistributedTableName("123456789abcd", "test"); auto resultSet = store->QuerySql("SELECT * from ?;", tableName);

1. 数据库的备份和恢复

a. 根据指定的数据库备份文件名备份当前数据库。

b. 根据指定的数据库备份文件恢复当前数据库。

示例代码如下： c++ std::string backupName = "backup.db"; // 指定数据库的备份文件名 std::vector<uint8_t> key; // 数据库的加密密钥 int errno = store->Backup(backupName, key); errno = store->Restore(backupName, key);

你可能感兴趣的鸿蒙文章

harmony 鸿蒙subsystems

harmony 鸿蒙AI框架开发指导

harmony 鸿蒙应用特权配置指南

harmony 鸿蒙开发实例

harmony 鸿蒙搭建环境

harmony 鸿蒙开发指导

harmony 鸿蒙概述

harmony 鸿蒙ArkCompiler开发指导

harmony 鸿蒙appspawn应用孵化组件

harmony 鸿蒙bootstrap服务启动组件