如何利用鸿蒙系统的分布式数据库存储用户数据？

Question

如何利用鸿蒙系统的分布式数据库存储用户数据？

Swift社区

16.6k111300

发布于
2024-10-30 上海

鸿蒙提供了分布式数据库，以便多设备间的数据同步。如何在鸿蒙应用中使用分布式数据库存储和读取用户数据？

harmonyos

阅读 814

AI BotBETA

在鸿蒙系统中，利用分布式数据库存储用户数据主要涉及以下几个步骤：

一、配置与权限申请

配置文件：
- 在鸿蒙应用的配置文件中（如config.json），需要声明分布式数据同步相关的权限。
- 示例权限包括：ohos.permission.DISTRIBUTED_DATASYNC、ohos.permission.DISTRIBUTED_DEVICE_STATE_CHANGE等。
权限申请：
- 在应用的MainAbility或相关Ability的onStart方法中，通过requestPermissionsFromUser方法申请所需的权限。

二、数据库声明与获取

声明数据库：
- 在使用分布式数据库的AbilitySlice中声明数据库实例。
- 通常情况下，数据库实例会在工具类（如DBUtils）中进行初始化或获取。
获取数据库：
- 使用DBUtils等工具类中的方法，根据数据库名称获取或创建分布式数据库实例。
- 示例代码：singleKvStore = DBUtils.initOrGetDB(this, "RecordAccouontsDB");

三、数据存储与读取

存储数据：
- 使用分布式数据库实例的putString、putInt等方法存储用户数据。
- 由于分布式数据库基于KV（Key-Value）数据模型，因此存储的数据以键值对的形式存在。
- 示例代码：singleKvStore.putString("key"+id, "{\"id\":"+id+",\"money\":"+money+",...}");
读取数据：
- 使用getEntries、getString等方法根据键或查询条件读取用户数据。
- 支持谓词查询，可以构建复杂的查询条件来获取数据。
- 示例代码：
```
Query query = Query.select();
query.equalTo("$.dateYear", DateUtils.getCurrentYear()).and().greaterThanOrEqualTo("$.money", 5);
List<Entry> entries = singleKvStore.getEntries(query);
```

四、数据同步与监听

数据同步：
- 鸿蒙分布式数据库支持手动和自动两种同步方式。
- 手动同步：通过调用sync接口触发，可以指定同步的设备列表和同步模式（如PULL_ONLY、PUSH_ONLY、PUSH_PULL）。
- 自动同步：由分布式数据库自动触发，包括全量同步和按条件订阅同步。

数据监听：

使用subscribe方法监听数据库中的数据变化。
当数据发生变化时，会触发onChange回调方法，可以在回调中执行相应的业务逻辑（如刷新UI）。

示例代码：

singleKvStore.subscribe(SubscribeType.SUBSCRIBE_TYPE_ALL, new KvStoreObserver() {
    @Override
    public void onChange(ChangeNotification changeNotification) {
        // 刷新页面上的数据
        getUITaskDispatcher().asyncDispatch(new Runnable() {
            @Override
            public void run() {
                // 在这里执行页面UI组件的显示刷新
            }
        });
    }
});