鸿蒙OS 分布式数据服务开发指导

场景介绍

分布式数据服务主要实现对用户设备中应用程序的数据内容的分布式同步。当设备 1 上的应用 A 在分布式数据库中增、删、改数据后，设备2上的应用 A 也可以获取到该数据库变化。可在分布式图库、信息、通讯录、文件管理器等场景中使用。

接口说明

HarmonyOS 系统中的分布式数据服务模块为开发者提供下面几种功能：

功能分类	接口名称	描述
分布式数据库创建、打开、关闭和删除。	isCreateIfMissing()	数据库不存在时是否创建。
setCreateIfMissing(boolean isCreateIfMissing)	数据库不存在时是否创建。
isEncrypt()	获取数据库是否加密。
setEncrypt(boolean isEncrypt)	设置数据库是否加密。
getStoreType()	获取分布式数据库的类型。
setStoreType(KvStoreType storeType)	设置分布式数据库的类型。
KvStoreType.DEVICE_COLLABORATION	设备协同分布式数据库类型。
KvStoreType.SINGLE_VERSION	单版本分布式数据库类型。
getKvStore(Options options, String storeId)	根据Options配置创建和打开标识符为 storeId 的分布式数据库。
closeKvStore(KvStore kvStore)	关闭分布式数据库。
deleteKvStore(String storeId)	删除分布式数据库。
分布式数据增、删、改、查。	getStoreId()	根据配置构造帐号键值数据库管理类实例。
putBoolean(String key, boolean value)putInt(String key, int value)putFloat(String key, float value)putDouble(String key, double value)putString(String key, String value)putByteArray(String key, byte[] value)putBatch(List<Entry> entries)	插入和更新数据。
delete(String key)deleteBatch(List<String> keys)	删除数据。
getInt(String key)getFloat(String key)getDouble(String key)getString(String key)getByteArray(String key)getEntries(String keyPrefix)	查询数据。
分布式数据谓词查询。	select()reset()equalTo(String field, int value)equalTo(String field, long value)equalTo(String field, double value)equalTo(String field, String value)equalTo(String field, boolean value)notEqualTo(String field, int value)notEqualTog(String field, long value)notEqualTo(String field, boolean value)notEqualTo(String field, String value)notEqualTo(String field, double value)greaterThan(String field, int value)greaterThan(String field, long value)greaterThan(String field, double value)greaterThan(String field, String value)lessThan(String field, int value)lessThan(String field, long value)lessThan(String field, double value)lessThan(String field, String value)greaterThanOrEqualTo(String field, int value)greaterThanOrEqualTo(String field, long value)greaterThanOrEqualTo(String field, double value)greaterThanOrEqualTo(String field, String value)lessThanOrEqualTo(String field, int value)lessThanOrEqualTo(String field, long value)lessThanOrEqualTo(String field, double value)lessThanOrEqualTo(String field, String value)isNull(String field)orderByDesc(String field)orderByAsc(String field)limit(int number, int offset)like(String field, String value)unlike(String field, String value)inInt(String field, List<Integer> valueList)inLong(String field, List<Long> valueList)inDouble(String field, List<Double> valueList)inString(String field, List<String> valueList)notInInt(String field, List<Integer> valueList)notInLong(String field, List<Long> valueList)notInDouble(String field, List<Double> valueList)notInString(String field, List<String> valueList)and()or()	对于Schema数据库谓词查询数据。
订阅分布式数据变化。	subscribe(SubscribeType subscribeType, KvStoreObserver observer)	订阅数据库中数据的变化。
分布式数据同步。	sync(List<String> deviceIdList, SyncMode mode)	在手动模式下，触发数据库同步。

开发步骤

以单版本分布式数据库为例，说明开发步骤。

1. 根据配置构造分布式数据库管理类实例。

1. 根据应用上下文创建 KvManagerConfig 对象。
2. 创建分布式数据库管理器实例。

以下为创建分布式数据库管理器的代码示例：

   Context context;
   ...
   KvManagerConfig config = new KvManagerConfig(context);
   KvManager kvManager = KvManagerFactory.getInstance().createKvManager(config);

1. 获取/创建单版本分布式数据库。

1. 声明需要创建的单版本分布式数据库 ID 描述。
2. 创建单版本分布式数据库。

以下为创建单版本分布式数据库的代码示例：

   Options CREATE = new Options();

    
   CREATE.setCreateIfMissing(true).setEncrypt(false).setKvStoreType(KvStoreType.SINGLE_VERSION);
   String storeID = "testApp";
   SingleKvStore singleKvStore = kvManager.getKvStore(CREATE, storeID);

1. 订阅分布式数据变化。

\1. 客户端需要实现KvStoreObserver接口。

\2. 构造并注册KvStoreObserver实例。

以下为订阅单版本分布式数据库所有（本地及远端）数据变化通知的代码示例：

   class KvStoreObserverClient implements KvStoreObserver() {
       @Override
       public void onChange(ChangeNotification notification) {
           List<Entry> insertEntries = notification.getInsertEntries();
           List<Entry> updateEntries = notification.getUpdateEntries();
           List<Entry> deleteEntries = notification.getDeleteEntries();
       }
   }

    
   KvStoreObserver kvStoreObserverClient = new KvStoreObserverClient();
   singleKvStore.subscribe(SubscribeType.SUBSCRIBE_TYPE_ALL, kvStoreObserverClient);

1. 将数据写入单版本分布式数据库。

1. 构造需要写入单版本分布式数据库的 Key (键)和 Value (值)。
2. 将键值数据写入单版本分布式数据库。

以下为将字符串类型键值数据写入单版本分布式数据库的代码示例：

   String key = "todayWeather";
   String value = "Sunny";
   singleKvStore.putString(key, value);

1. 查询单版本分布式数据库数据。

1. 构造需要从单版本分布式数据库快照中查询的 Key(键)。
2. 从单版本分布式数据库快照中获取数据。

以下为从单版本分布式数据库中查询字符串类型数据的代码示例：

   String key = "todayWeather";String value = singleKvStore.getString(key);

1. 同步数据到其他设备。

\1. 获取已连接的设备列表。

\2. 选择同步方式进行数据同步。

以下为单版本分布式数据库进行数据同步的代码示例，其中同步方式为 PUSH_ONLY：

   List<DeviceInfo> deviceInfoList = kvManager.getConnectedDevicesInfo(DeviceFilterStrategy.NO_FILTER);
   List<String> deviceIdList = new ArrayList<>();
   for (DeviceInfo deviceInfo : deviceInfoList) {
       deviceIdList.add(deviceInfo.getId());
   }
   singleKvStore.sync(deviceIdList, SyncMode.PUSH_ONLY);

1. 关闭单版本分布式数据库。以下为关闭单版本分布式数据库的代码示例：

   kvManager.closeKvStore(singleKvStore);

1. 删除单版本分布式数据库。以下为删除单版本分布式数据库的代码示例：

   kvManager.deleteKvStore(storeID);