通过数据管理服务实现数据共享静默访问

场景介绍

典型跨应用访问数据的用户场景下，数据提供方会存在多次被拉起的情况。

为了降低数据提供方拉起次数，提高访问速度，OpenHarmony提供了一种不拉起数据提供方直接访问数据库的方式，即静默数据访问。

静默数据访问通过数据管理服务进行数据的访问和修改，无需拉起数据提供方。

数据管理服务仅支持数据库的基本访问或数据托管，如果有业务处理，需要将业务处理封装成接口，给数据访问方调用。

如果业务过于复杂，无法放到数据访问方，建议通过DataShareExtensionAbility拉起数据提供方实现功能。

运作机制

可以通过数据管理服务进行代理访问的数据分为以下两种：

• 持久化数据：归属于数据提供方的数据库，这类数据存储于数据提供方的沙箱，可以在数据提供方中通过声明的方式进行共享，按表为粒度配置为可以被其他应用访问的数据表。

• 过程数据：托管在数据管理服务上的过程数据，这类数据存储于数据管理服务的沙箱，格式为json或byte数据，无人订阅10天后自动删除。

​

图1 静默数据访问视图

• 和跨应用数据共享方式不同的是，静默数据访问借助数据管理服务通过目录映射方式直接读取数据提供方的配置，按规则进行预处理后，并访问数据库。

• 数据访问方如果使用静默数据访问方式，URI需严格按照如下格式： datashareproxy://{bundleName}/{dataPath}

数据管理服务会读取对应bundleName作为数据提供方应用，读取配置，进行权限校验并访问对应数据。

dataPath为数据标识，可以自行定义，在同一个数据提供方应用中需要保持唯一。

约束与限制

• 目前持久化数据中仅关系型数据库支持静默数据访问方式。
• 整个系统最多同时并发16路查询，有多出来的查询请求需要排队处理。
• 持久化数据不支持代理创建数据库，如果需要创建数据库，需要拉起数据提供方。
• 数据提供方如果是normal级别签名的应用，配置的数据读写权限必须为system_basic及以上权限。

接口说明

以下是静默数据访问的相关接口，大部分为异步接口。异步接口均有callback和Promise两种返回形式，下表均以callback形式为例，更多接口及使用方式请见数据共享。

通用接口

持久化数据

过程数据

持久化数据实现说明

首先，以共享一个关系型数据库为例，说明开发步骤。

数据提供方应用的开发

1. 数据提供方需要在module.json5中的proxyDatas节点定义要共享的表的标识，读写权限和基本信息。

表1 module.json5中proxyDatas节点对应的属性字段

|属性名称 |备注说明 |必填 | |———————–|—————————————-|—-| |uri |数据使用的URI，是跨应用数据访问的唯一标识。 |是 | |requiredReadPermission|标识从该数据代理读取数据时所需要的权限，不配置默认不允许其他APP访问数据。支持权限可参考权限列表。 |否 | |requiredWritePermission|标识从该数据代理修改数据时所需要的权限，不配置默认不允许其他APP修改数据。支持权限可参考权限列表。 |否 | |metadata |数据源的信息，包含name和resource字段。
name类型固定为”dataProperties”，是配置的唯一标识。
resource类型固定为”$profile:{fileName}“，表示配置文件的名称为{fileName}.json。|是 |

module.json5配置样例：

   "proxyDatas":[
     {
       "uri": "datashareproxy://com.acts.ohos.data.datasharetest/test",
       "requiredReadPermission": "ohos.permission.GET_BUNDLE_INFO",
       "requiredWritePermission": "ohos.permission.KEEP_BACKGROUND_RUNNING",
       "metadata": {
         "name": "dataProperties",
         "resource": "$profile:my_config"
       }
     }
   ]

表2 my_config.json对应属性字段

|属性名称|备注说明 |必填 | |—–|—————————————-|—-| |path|指定数据源路径，目前支持关系型数据库，配置为库名/表名 |是 | |type|标识数据库类型，目前支持配置为rdb，表示关系型数据库。 |是 | |scope|数据库所在范围。
1.module表示数据库位于本模块下；
2.application表示数据库位于本应用下。|否 |

my_config.json配置样例

   {
     "path": "DB00/TBL00",
     "type": "rdb",
     "scope": "application"
   }

数据访问方应用的开发

1. 导入基础依赖包。

   import dataShare from '@ohos.data.dataShare';
   import dataSharePredicates from '@ohos.data.dataSharePredicates';
   import UIAbility from '@ohos.app.ability.UIAbility';
   import { ValuesBucket } from '@ohos.data.ValuesBucket';
   import window from '@ohos.window';
   import { BusinessError } from '@ohos.base';

1. 定义与数据提供方通信的URI字符串。

   let dseUri = ('datashareproxy://com.acts.ohos.data.datasharetest/test');

1. 创建工具接口类对象。

   let dsHelper: dataShare.DataShareHelper|undefined = undefined;
   let abilityContext: Context;

   export default class EntryAbility extends UIAbility {
     onWindowStageCreate(windowStage: window.WindowStage) {
       abilityContext = this.context;
       dataShare.createDataShareHelper(abilityContext, "", {
         isProxy: true
       }, (err, data) => {
         dsHelper = data;
       });
     }
   }

1. 获取到接口类对象后，便可利用其提供的接口访问提供方提供的服务，如进行数据的增、删、改、查等。

   // 构建一条数据
   let key1 = 'name';
   let key2 = 'age';
   let key3 = 'isStudent';
   let key4 = 'Binary';
   let valueName1 = 'ZhangSan';
   let valueName2 = 'LiSi';
   let valueAge1 = 21;
   let valueAge2 = 18;
   let valueIsStudent1 = false;
   let valueIsStudent2 = true;
   let valueBinary = new Uint8Array([1, 2, 3]);
   let valuesBucket: ValuesBucket = { key1: valueName1, key2: valueAge1, key3: valueIsStudent1, key4: valueBinary };
   let updateBucket: ValuesBucket = { key1: valueName2, key2: valueAge2, key3: valueIsStudent2, key4: valueBinary };
   let predicates = new dataSharePredicates.DataSharePredicates();
   let valArray = ['*'];
   if (dsHelper != undefined) {
     // 插入一条数据
     (dsHelper as dataShare.DataShareHelper).insert(dseUri, valuesBucket, (err, data) => {
       console.info(`dsHelper insert result:${data}`);
     });
     // 更新数据
     (dsHelper as dataShare.DataShareHelper).update(dseUri, predicates, updateBucket, (err, data) => {
       console.info(`dsHelper update result:${data}`);
     });
     // 查询数据
     (dsHelper as dataShare.DataShareHelper).query(dseUri, predicates, valArray, (err, data) => {
       console.info(`dsHelper query result:${data}`);
     });
     // 删除指定的数据
     (dsHelper as dataShare.DataShareHelper).delete(dseUri, predicates, (err, data) => {
       console.info(`dsHelper delete result:${data}`);
     });
   }

1. 对指定的数据进行订阅。

   function onCallback(err: BusinessError, node: dataShare.RdbDataChangeNode) {
     console.info("uri " + JSON.stringify(node.uri));
     console.info("templateId " + JSON.stringify(node.templateId));
     console.info("data length " + node.data.length);
     for (let i = 0; i < node.data.length; i++) {
       console.info("data " + node.data[i]);
     }
   }

   let key21: string = "p1";
   let value21: string = "select * from TBL00";
   let key22: string = "p2";
   let value22: string = "select name from TBL00";
   let template: dataShare.Template = {
     predicates: {
       key21: value21,
       key22: value22,
     },
     scheduler: ""
   }
   if(dsHelper != undefined)
   {
     (dsHelper as dataShare.DataShareHelper).addTemplate(dseUri, "111", template);
   }
   let templateId: dataShare.TemplateId = {
     subscriberId: "111",
     bundleNameOfOwner: "com.acts.ohos.data.datasharetestclient"
   }
   if(dsHelper != undefined) {
     // 使用数据管理服务修改数据时触发onCallback回调，回调内容是template中的规则查到的数据
     let result: Array<dataShare.OperationResult> = (dsHelper as dataShare.DataShareHelper).on("rdbDataChange", [dseUri], templateId, onCallback);
   }

过程数据实现说明

以托管一份过程数据为例，说明开发步骤。

数据提供方应用的开发（可选）

数据提供方需要在module.json5中的proxyDatas节点定义过程数据的标识，读写权限和基本信息。

注意：

• 该步骤为可选，可以不对module.json5中的proxyDatas进行配置。
• 不配置proxyDatas时，托管数据不允许其他应用访问。
• 不配置proxyDatas时，数据标识可以为简写，发布、订阅、查询数据可以使用简写的数据标识，如weather，可以不用全写为datashareproxy://com.acts.ohos.data.datasharetest/weather

表3 module.json5中proxyDatas节点对应的属性字段

module.json5配置样例：

"proxyDatas": [
  {
    "uri": "datashareproxy://com.acts.ohos.data.datasharetest/weather",
    "requiredReadPermission": "ohos.permission.GET_BUNDLE_INFO",
    "requiredWritePermission": "ohos.permission.KEEP_BACKGROUND_RUNNING"
  }
]

数据访问方应用的开发

1. 导入基础依赖包。

   import dataShare from '@ohos.data.dataShare';
   import UIAbility from '@ohos.app.ability.UIAbility';
   import window from '@ohos.window';
   import { BusinessError } from '@ohos.base';

1. 创建工具接口类对象。

   let dsHelper: dataShare.DataShareHelper|undefined = undefined;
   let abilityContext: Context;

   export default class EntryAbility extends UIAbility {
     onWindowStageCreate(windowStage: window.WindowStage) {
       abilityContext = this.context;
       dataShare.createDataShareHelper(abilityContext, "", {isProxy : true}, (err, data) => {
         dsHelper = data;
       });
     }
   }

1. 获取到接口类对象后，便可利用其提供的接口访问提供方提供的服务，如进行数据的增、删、改、查等。

   // 构建两条数据，第一条为免配置的数据，仅自己使用
   let data : Array<dataShare.PublishedItem> = [
     {key:"city", subscriberId:"11", data:"xian"},
     {key:"datashareproxy://com.acts.ohos.data.datasharetest/weather", subscriberId:"11", data:JSON.stringify("Qing")}];
   // 发布数据
   if (dsHelper != undefined) {
     let result: Array<dataShare.OperationResult> = await (dsHelper as dataShare.DataShareHelper).publish(data, "com.acts.ohos.data.datasharetestclient");
   }

1. 对指定的数据进行订阅。

   function onPublishCallback(err: BusinessError, node:dataShare.PublishedDataChangeNode) {
     console.info("onPublishCallback");
   }
   let uris:Array<string> = ["city", "datashareproxy://com.acts.ohos.data.datasharetest/weather"];
   if (dsHelper != undefined) {
     let result: Array<dataShare.OperationResult> = (dsHelper as dataShare.DataShareHelper).on("publishedDataChange", uris, "11", onPublishCallback);
   }

​

你可能感兴趣的鸿蒙文章

harmony 鸿蒙数据管理

harmony 鸿蒙基于设备分类和数据分级的访问控制

harmony 鸿蒙应用数据持久化概述

harmony 鸿蒙数据库备份与恢复

harmony 鸿蒙数据库加密

harmony 鸿蒙数据管理概述

harmony 鸿蒙通过键值型数据库实现数据持久化

harmony 鸿蒙通过用户首选项实现数据持久化

harmony 鸿蒙通过关系型数据库实现数据持久化

harmony 鸿蒙数据可靠性与安全性概述