Add dataability xts code

Signed-off-by: Nkirl.liu <kirl.liu@huawei.com>

aafwk/aafwk_standard/ActsDataAbilityJsTest/BUILD.gn

+# Copyright (c) 2021 Huawei Device Co., Ltd.
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import("//test/xts/tools/build/suite.gni")
+
+ohos_js_hap_suite("ActsDataAbilityJsTest") {
+  hap_name = "ActsDataAbilityJsTest"
+  hap_profile = "./entry/src/main/config.json"
+  deps = [
+    ":hjs_demo_js_assets",
+    ":hjs_demo_resources",
+  ]
+  certificate_profile = "./signature/openharmony_sx.p7b"
+}
+ohos_js_assets("hjs_demo_js_assets") {
+  source_dir = "./entry/src/main/js/default"
+}
+ohos_resources("hjs_demo_resources") {
+  sources = [ "./entry/src/main/js/resources" ]
+  hap_profile = "./entry/src/main/config.json"
+}

aafwk/aafwk_standard/ActsDataAbilityJsTest/Test.json

+{
+    "description": "Configuration for hjsunit Tests",
+    "driver": {
+        "type": "JSUnitTest",
+        "test-timeout": "100000",
+        "package": "com.example.actsdataabilityjstest",
+        "shell-timeout": "60000"
+    },
+    "kits": [
+        {
+            "test-file-name": [
+                "ActsDataAbilityJsTest.hap"
+            ],
+            "type": "AppInstallKit",
+            "cleanup-apps": true
+        }
+	]
+}

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/config.json

+{
+  "app": {
+    "bundleName": "com.example.actsdataabilityjstest",
+    "vendor": "example",
+    "version": {
+      "code": 1,
+      "name": "1.0"
+    },
+    "apiVersion": {
+      "compatible": 4,
+      "target": 5,
+      "releaseType": "Beta1"
+    }
+  },
+  "deviceConfig": {},
+  "module": {
+    "package": "com.example.actsdataabilityjstest",
+    "name": ".MyApplication",
+    "deviceType": [
+      "phone"
+    ],
+    "distro": {
+      "deliveryWithInstall": true,
+      "moduleName": "entry",
+      "moduleType": "entry"
+    },
+    "abilities": [
+      {
+        "skills": [
+          {
+            "entities": [
+              "entity.system.home"
+            ],
+            "actions": [
+              "action.system.home"
+            ]
+          }
+        ],
+        "name": "com.example.actsdataabilityjstest.MainAbility",
+        "icon": "$media:icon",
+        "description": "$string:mainability_description",
+        "label": "$string:app_name",
+        "type": "page",
+        "launchType": "singleton",
+        "visible": true
+      }
+    ],
+    "reqPermissions": [
+      {
+        "name":"ohos.permission.GET_BUNDLE_INFO_PRIVILEGED",
+        "reason":"need use ohos.permission.GET_BUNDLE_INFO_PRIVILEGED"
+      },
+      {
+        "name":"ohos.permission.GET_BUNDLE_INFO",
+        "reason":"need use ohos.permission.GET_BUNDLE_INFO"
+      },
+      {
+        "name":"ohos.permission.CHANGE_ABILITY_ENABLED_STATE",
+        "reason":"need use ohos.permission.CHANGE_ABILITY_ENABLED_STATE"
+      },
+      {
+        "name":"ohos.permission.REMOVE_CACHE_FILES",
+        "reason":"need use ohos.permission.REMOVE_CACHE_FILES"
+      },
+      {
+        "name":"ohos.permission.LISTEN_BUNDLE_CHANGE",
+        "reason":"need use ohos.permission.LISTEN_BUNDLE_CHANGE"
+      },
+      {
+        "name":"ohos.permission.INSTALL_BUNDLE",
+        "reason":"need use ohos.permission.INSTALL_BUNDLE"
+      },
+      {
+        "name":"ohos.permission.MANAGE_MISSIONS",
+        "reason":"need use ohos.permission.MANAGE_MISSIONS"
+      },
+      {
+        "name":"ohos.permission.GET_RUNNING_INFO",
+        "reason":"need use ohos.permission.GET_RUNNING_INFO"
+      },
+      {
+        "name":"ohos.permission.CLEAN_BACKGROUND_PROCESSES",
+        "reason":"need use ohos.permission.CLEAN_BACKGROUND_PROCESSES"
+      },
+      {
+        "name":"ohos.permission.CLEAN_APPLICATION_DATA",
+        "reason":"need use ohos.permission.CLEAN_APPLICATION_DATA"
+      },
+      {
+        "name":"ohos.permission.INTERACT_ACROSS_LOCAL_ACCOUNTS",
+        "reason":"need use ohos.permission.GET_RUNNING_INFO"
+      }
+    ],
+    "js": [
+      {
+        "pages": [
+          "pages/index/index"
+        ],
+        "name": "default",
+        "window": {
+          "designWidth": 720,
+          "autoDesignWidth": false
+        }
+      }
+    ]
+  }
+}
\ No newline at end of file

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/js/default/app.js

+/*
+ * Copyright (c) 2021 Huawei Device Co., Ltd.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+export default {
+    onCreate() {
+        console.info('ActsProcessManageJsTest onCreate');
+    },
+    onDestroy() {
+        console.info('ActsProcessManageJsTest onDestroy');
+    },
+    onShow() {
+        console.info('ActsProcessManageJsTest onShow');
+    },
+    onHide() {
+        console.info('ActsProcessManageJsTest onHide');
+    }
+};

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/js/default/i18n/en-US.json

+{
+  "strings": {
+    "hello": "Hello",
+    "world": "World"
+  }
+}
\ No newline at end of file

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/js/default/i18n/zh-CN.json

+{
+  "strings": {
+    "hello": "您好",
+    "world": "世界"
+  }
+}
\ No newline at end of file

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/js/default/pages/index/index.css

+.container {
+    flex-direction: column;
+    justify-content: center;
+    align-items: center;
+}
+
+.title {
+    font-size: 100px;
+}
+
+.btn {
+    width: 200px;
+    height: 80px;
+}

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/js/default/pages/index/index.hml

+<div class="container">
+    <text class="title">
+        {{ $t('strings.hello') }} {{ title }}
+    </text>
+    <button class="btn" type="capsule" value="start" onclick="start"></button>
+</div>

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/js/default/pages/index/index.js

+/*
+ * Copyright (c) 2021 Huawei Device Co., Ltd.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+import { Core, ExpectExtend } from 'deccjsunit/index'
+
+const injectRef = Object.getPrototypeOf(global) || global
+injectRef.regeneratorRuntime = require('@babel/runtime/regenerator')
+
+export default {
+    data: {
+        title: "",
+        testTime: 0
+    },
+    onInit() {
+        console.info('Acts_DataAbilityJSTest onInit');
+        this.title = this.$t('strings.world');
+    },
+    onShow() {
+        console.info('Acts_DataAbilityJSTest onShow');
+        console.info('Acts_DataAbilityJSTest testTime' + this.testTime);
+        if (this.testTime == 0) {
+            const core = Core.getInstance()
+            const expectExtend = new ExpectExtend({
+                'id': 'extend'
+            })
+            core.addService('expect', expectExtend)
+            core.init()
+            const configService = core.getDefaultService('config')
+            this.timeout = 30000;
+            configService.setConfig(this)
+
+            require('../../../test/List.test')
+            core.execute()
+        }
+        this.testTime++;
+    },
+    onReady() {
+        console.info('Acts_DataAbilityJSTest onReady');
+    },
+    onActive() {
+        console.info('Acts_DataAbilityJSTest onActive');
+    },
+    onInactive() {
+        console.info('Acts_DataAbilityJSTest onInactive');
+    },
+    onHide() {
+        console.info('Acts_DataAbilityJSTest onHide');
+    },
+    onDestroy() {
+        console.info('Acts_DataAbilityJSTest onDestroy');
+    },
+    onBackPress() {
+        console.info('Acts_DataAbilityJSTest onBackPress');
+    },
+    onNewRequest() {
+        console.info('Acts_DataAbilityJSTest onNewRequest');
+    },
+    onStartContinuation() {
+        console.info('Acts_DataAbilityJSTest onStartContinuation');
+    },
+    onSaveData(value) {
+        console.info('Acts_DataAbilityJSTest onSaveData:' + JSON.stringify(value));
+    },
+    onRestoreData(value) {
+        console.info('Acts_DataAbilityJSTest onRestoreData:' + JSON.stringify(value));
+    },
+    onCompleteContinuation(code) {
+        console.info('Acts_DataAbilityJSTest onCompleteContinuation:' + JSON.stringify(code));
+    },
+    onConfigurationUpdated(configuration) {
+        console.info('Acts_DataAbilityJSTest onConfigurationUpdated:' + JSON.stringify(configuration));
+    }
+}

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/js/resources/base/element/string.json

+{
+  "string": [
+    {
+      "name": "app_name",
+      "value": "actsparticleabilitytest"
+    },
+    {
+      "name": "mainability_description",
+      "value": "JS_Phone_Empty Feature Ability"
+    }
+  ]
+}
\ No newline at end of file

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/js/test/ActsDataAbilityJsTest.test.js

+/*
+ * Copyright (C) 2021 Huawei Device Co., Ltd.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from "deccjsunit/index"
+import featureAbility from '@ohos.ability.featureAbility'
+import ohosDataAbility from '@ohos.data.dataability'
+
+describe('ActsDataAbilityJsTest', function () {
+let dataAbilityUri = ("dataability:///com.example.myapplication.DataAbility");
+let DAHelper;
+let gSetTimeout = 500;
+var valueBucket = {
+    "name": "ActsDataAbilityHelperTest",
+    "age": 24,
+    "salary": 2024.20,
+}
+
+beforeAll(async (done) => {
+    console.debug('= ACTS_beforeAll 1425 ====<begin');
+    try {
+        DAHelper = featureAbility.acquireDataAbilityHelper(dataAbilityUri);
+        console.debug('ACTS_beforeAll DAHelper ====>: ' + DAHelper + " ,JSON. " + JSON.stringify(DAHelper));
+        if(DAHelper == null){
+            console.debug('ACTS_beforeAll DAHelper ====>: DAHelper == null');
+        }
+    } catch (err) {
+        console.error('=ACTS_beforeAll acquireDataAbilityHelper catch(err)====>:' + err);
+    }
+    console.debug('= ACTS_beforeAll ====<end');
+    done();
+})
+beforeEach(async (done) => {
+    console.debug('= ACTS_beforeEach ====<begin');
+    setTimeout(function () {
+        console.debug('= ACTS_beforeEach ====<end');
+        done();
+    }, gSetTimeout);
+})
+afterEach(async (done) => {
+    console.debug('= ACTS_afterEach ====<begin');
+    setTimeout(function () {
+        console.debug('= ACTS_afterEach ====<end');
+        done();
+    }, gSetTimeout);
+})
+afterAll((done) => {
+    console.debug('= ACTS_afterAll ====<begin');
+    setTimeout(function () {
+        console.debug('= ACTS_afterAll ====<end');
+        featureAbility.terminateSelf();
+        done();
+    }, gSetTimeout);
+})
+    
+/*
+* @tc.number: ACTS_featureAbilityEnum_0100
+* @tc.name: Enum the client resource of the Data ability.
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_featureAbilityEnum_0100', 0, async function (done) {
+    console.log('ACTS_featureAbilityEnum_0100====<begin');
+    try {
+        expect(featureAbility.ContinuationState.LOCAL_RUNNING).assertEqual(0);
+        expect(featureAbility.ContinuationState.REMOTE_RUNNING).assertEqual(1);
+        expect(featureAbility.ContinuationState.REPLICA_RUNNING).assertEqual(2);
+        
+        expect(abilityManager.ProcessErrCode.NO_ERROR).assertEqual(0);
+        expect(abilityManager.ProcessErrCode.CRASHED).assertEqual(1);
+        expect(abilityManager.ProcessErrCode.NO_RESPONSE).assertEqual(2);
+
+        console.log('ACTS_featureAbilityEnum_0100====<end');
+        done();
+    } catch (err) {
+        console.log('ACTS_featureAbilityEnum_0100====<end catch(err)=' + err);
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_Insert_0400
+* @tc.name: Insert : Indicates the path of the data to operate
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_Insert_0400', 0, async function (done) {
+    console.log('ACTS_Insert_0400====<begin');
+    console.log('featureAbility getDataAbilityHelper ====>: ' + DAHelper)
+    try {
+        await DAHelper.insert(dataAbilityUri, valueBucket,
+            (err, data) => {
+                console.debug("=ACTS_Insert_0400 err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data) + (" 】;"));
+                expect(data).assertEqual(1);
+                console.log('ACTS_Insert_0400====<end');
+                done();
+            }
+        );
+    } catch (err) {
+        console.error('=ACTS_Insert_0400 catch(err)====>:' + err);
+        console.log('ACTS_Insert_0400====<end catch');
+        done();
+    }
+    
+})
+
+/*
+* @tc.number: ACTS_BatchInsert_0600
+* @tc.name: Inserts multiple data records into the database
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_BatchInsert_0600', 0, async function (done) {
+    console.log('ACTS_BatchInsert_0600====<begin');
+    console.log('featureAbility BatchInsert getDataAbilityHelper ====>: ' + DAHelper)
+    var valueBucketArray = new Array({ "name": "ActsDataAbilityHelperTest", "age": 24, "salary": 2024.20, },
+        { "name": "ActsDataAbilityHelperTest", "age": 24, "salary": 2024.20, },
+        { "name": "ActsDataAbilityHelperTest", "age": 24, "salary": 2024.20, })
+    try {
+        await DAHelper.batchInsert(
+            dataAbilityUri,
+            valueBucketArray,
+            (err, data) => {
+                console.debug("=ACTS_BatchInsert_0600 err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data) + (" 】;"));
+                expect(data).assertEqual(3);
+                console.log('ACTS_BatchInsert_0600====<end');
+                done();
+            },
+        );
+    } catch (err) {
+        console.error('=ACTS_BatchInsert_0600 catch(err)====>:' + err);
+        console.log('ACTS_BatchInsert_0600====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_Query_0400
+* @tc.name: Queries one or more data records in the database
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_Query_0400', 0, async function (done) {
+    console.log('ACTS_Query_0400====<begin');
+    var columnsArray = new Array("value1", "value2", "value3", "value4")
+    try {
+        let predicates = new ohosDataAbility.DataAbilityPredicates();
+        predicates.equalTo('contact_id', 1);
+        predicates.limitAs(10);
+        predicates.orderByAsc("order_by_class");
+        predicates.offsetAs(1);
+        await DAHelper.query(
+            dataAbilityUri,
+            columnsArray,
+            predicates,
+            (err, data) => {
+                console.debug("=ACTS_Query_0400 query err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【")
+                    + JSON.stringify(data) + (" 】;") + " , " + data);
+                expect(typeof (data)).assertEqual("object");
+                console.log('ACTS_Query_0400====<end');
+                done();
+            });
+    } catch (err) {
+        console.error('=ACTS_Query_0400 catch(err)====>:' + err);
+        console.log('ACTS_Query_0400====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_Update_0400
+* @tc.name: Updates one or more data records in the database.
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_Update_0400', 0, async function (done) {
+    console.log('ACTS_Update_0400====<begin');
+    console.log('featureAbility Update getDataAbilityHelper ====>: ' + DAHelper)
+    try {
+        let predicates = new ohosDataAbility.DataAbilityPredicates();
+        predicates.equalTo('contact_id', 1);
+        predicates.limitAs(10);
+        predicates.orderByAsc("order_by_class");
+        predicates.offsetAs(1);
+        console.debug("=ACTS_Update_0400 predicates====>"
+            + ("json predicates 【") + JSON.stringify(predicates) + (" 】") + " , " + predicates);
+        await DAHelper.update(
+            dataAbilityUri,
+            valueBucket,
+            predicates,
+            (err, data) => {
+                console.debug("=ACTS_Update_0400 err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data) + (" 】;"));
+                expect(data).assertEqual(1);
+                console.log('ACTS_Update_0400====<end');
+                done();
+            },
+        );
+    } catch (err) {
+        console.error('=ACTS_Update_0400 catch(err)====>:' + err);
+        console.log('ACTS_Update_0400====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_Delete_0400
+* @tc.name: Deletes one or more data records. This method should be implemented by a Data ability.
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_Delete_0400', 0, async function (done) {
+    console.log('ACTS_Delete_0400====<begin');
+    console.log('featureAbility getDataAbilityHelper ====>: ' + DAHelper)
+    try {
+        let predicates = new ohosDataAbility.DataAbilityPredicates();
+        predicates.equalTo('contact_id', 1);
+        predicates.limitAs(10);
+        predicates.orderByAsc("order_by_class");
+        predicates.offsetAs(1);
+        console.debug("=ACTS_Delete_0400 predicates====>"
+            + ("json predicates 【") + JSON.stringify(predicates) + (" 】") + " , " + predicates);
+        await DAHelper.delete(
+            dataAbilityUri,
+            predicates,
+            (err, data) => {
+                console.debug("=ACTS_Delete_0400 err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data) + (" 】;"));
+                expect(data).assertEqual(0);
+                console.log('ACTS_Delete_0400====<end');
+                done();
+            });
+    } catch (err) {
+        console.error('=ACTS_Delete_0400 catch(err)====>:' + err);
+        console.log('ACTS_Delete_0400====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_GetFileTypes_0200
+* @tc.name: Obtains the MIME type of files.
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_GetFileTypes_0200', 0, async function (done) {
+    console.log('ACTS_GetFileTypes_0200====<begin');
+    console.log('featureAbility getFileTypes getDataAbilityHelper ====>: ' + DAHelper)
+    let mimeTypeFilter = '*/*'
+    try {
+        await DAHelper.getFileTypes(
+            dataAbilityUri,
+            mimeTypeFilter,
+            (err, data) => {
+                console.debug("=ACTS_GetFileTypes_0200 getFileTypes err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data) + (" 】;"));
+                console.log('=ACTS_GetFileTypes_0200 data.length ====>: ' + data.length);
+                for (var i = 0; i < data.length; i++) {
+                    expect(typeof (data[i])).assertEqual("string");
+                    console.log('=ACTS_GetFileTypes_0200 for data ====>: ' + err.code +
+                        " data[" + i + "]: " + data[i]);
+                    if (i == 0) {
+                         expect(data[i]).assertEqual("hap");
+                    } else if (i == 1) {
+                         expect(data[i]).assertEqual("jpg");
+                    } else if (i == 2) {
+                         expect(data[i]).assertEqual("image/png");
+                    }
+                }
+                console.log('ACTS_GetFileTypes_0200====<end');
+                done();
+            },
+        );
+    } catch (err) {
+        console.error('=ACTS_GetFileTypes_0200 getFileTypes AsyncCallback catch(err)====>:' + err);
+        console.log('ACTS_GetFileTypes_0200====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_GetType_0200
+* @tc.name: Obtains the MIME type matching the data specified by the URI of the Data ability.
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_GetType_0200', 0, async function (done) {
+    console.log('ACTS_GetType_0200====<begin');
+    console.log('featureAbility GetType getDataAbilityHelper ====>: ' + DAHelper)
+    try {
+        await DAHelper.getType(
+            dataAbilityUri,
+            (err, data) => {
+                console.debug("=ACTS_GetType_0200 err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data) + (" 】;"));
+                expect(data).assertEqual(dataAbilityUri);
+                console.log('ACTS_GetType_0200====<end');
+                done();
+            },
+        );
+    } catch (err) {
+        console.error('=ACTS_GetType_0200 getType AsyncCallback catch(err)====>:' + err);
+        console.log('ACTS_GetType_0200====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_OpenFile_0700
+* @tc.name: Opens a file. This method should be implemented by a Data ability.
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_OpenFile_0700', 0, async function (done) {
+    console.log('ACTS_OpenFile_0700====<begin');
+    let ret = false;
+    console.log('featureAbility ACTS_OpenFile_0700 OpenFile getDataAbilityHelper ====>: ' + DAHelper)
+    var mode = "r";
+    try {
+        DAHelper.openFile(
+            dataAbilityUri,
+            mode,
+            (err, data) => {
+                console.debug("=ACTS_OpenFile_0700 err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data) + (" 】;"));
+                expect(typeof (data)).assertEqual("number");
+                console.log('DataAbilityHelper ACTS_OpenFile_0700 OpenFile asyncCallback errCode ====>: '
+                    + err.code + " data: " + data);
+                ret = true
+                done();
+            },
+        );
+    } catch (err) {
+        console.error('=ACTS_OpenFile_0700 getType AsyncCallback catch(err)====>:' + err);
+        ret = false
+        done();
+    }
+    setTimeout(function () {
+        console.log('setTimeout function====<');
+    }, gSetTimeout);
+    console.log('ACTS_OpenFile_0700====<end');
+})
+
+/*
+* @tc.number: ACTS_NormalizeUri_0200
+* @tc.name: Converts the given uri that refer to the Data ability into a normalized URI.
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_NormalizeUri_0200', 0, async function (done) {
+    console.log('ACTS_NormalizeUri_0200====<begin');
+    let ret = false;
+    console.log('featureAbility normalizeUri getDataAbilityHelper ====>: ' + DAHelper)
+    try {
+        DAHelper.normalizeUri(
+            dataAbilityUri,
+            (err, data) => {
+                console.debug("=ACTS_NormalizeUri_0200 err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data) + (" 】;"));
+                expect(data).assertEqual(dataAbilityUri);
+                console.log('ACTS_NormalizeUri_0200====<end');
+                done();
+            },
+        );
+    } catch (err) {
+        console.error('=ACTS_NormalizeUri_0200 normalizeUri AsyncCallback catch(err)====>:' + err);
+        console.log('ACTS_NormalizeUri_0200====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_DenormalizeUri_0200
+* @tc.name: Converts the given normalized uri generated by normalizeUri into a denormalized one.
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_DenormalizeUri_0200', 0, async function (done) {
+    console.log('ACTS_DenormalizeUri_0200====<begin');
+    let ret = false;
+    console.log('featureAbility DenormalizeUri getDataAbilityHelper ====>: ' + DAHelper)
+    try {
+        DAHelper.denormalizeUri(
+            dataAbilityUri,
+            (err, data) => {
+                console.debug("=ACTS_DenormalizeUri_0200 err,data=======>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data) + (" 】;"));
+                expect(data).assertEqual(dataAbilityUri);
+                console.log('ACTS_DenormalizeUri_0200====<end');
+                done();
+            },
+        );
+    } catch (err) {
+        console.error('=ACTS_DenormalizeUri_0200 denormalizeUri AsyncCallback catch(err)====>:' + err);
+        console.log('ACTS_DenormalizeUri_0200====<end catch');
+        done();
+    }
+})
+
+
+/*
+* @tc.number: ACTS_OnOff_0100
+* @tc.name: On/Off : Registers an observer to observe data specified by the given Uri
+* @tc.desc: Check the return value of the interface ()
+*/
+it('ACTS_OnOff_0100', 0, async function (done) {
+    console.log('ACTS_OnOff_0100====<begin');
+    gSetTimeout = 2000;
+    try {
+        var currentAlertTimeout;
+        function onAsyncCallback0100(err) {
+            expect(err.code).assertEqual(0);
+            DAHelper.off("dataChange", dataAbilityUri, onAsyncCallback0100);
+            console.log('ACTS_OnOff_0100====<end');
+            gSetTimeout = 500;
+            done();
+        }
+        DAHelper.on("dataChange", dataAbilityUri, onAsyncCallback0100);
+
+        setTimeout(mySetTimeout, gSetTimeout);
+        function mySetTimeout() {
+            console.debug('ACTS_OnOff_0100====< mySetTimeout');
+            DAHelper.notifyChange(
+                dataAbilityUri,
+                (err) => {
+                    console.debug("=ACTS_OnOff_0100 err=======>"
+                        + ("err【") + JSON.stringify(err) + (" 】") + " , " + err);
+                    expect(err.code).assertEqual(0);
+                }
+            );
+        }
+    } catch (err) {
+        console.error('=ACTS_OnOff_0100  catch(err)====>:' + err);
+        console.log('ACTS_OnOff_0100====<end catch');
+        gSetTimeout = 500;
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_OnOff_0200
+* @tc.name: On/Off : Registers an observer to observe data specified by the given Uri
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_OnOff_0200', 0, async function (done) {
+    console.log('ACTS_OnOff_0200====<begin');
+    gSetTimeout = 2000;
+    try {
+        var currentAlertTimeout;
+        function onAsyncCallback0200(err) {
+            console.debug("=ACTS_OnOff_0200 onAsyncCallback0200=======>");
+            expect(false).assertTrue();
+            clearTimeout(currentAlertTimeout);
+            console.log('ACTS_OnOff_0200====<end callback_0200');
+            done();
+        }
+        DAHelper.on("dataChange", dataAbilityUri, onAsyncCallback0200);
+
+        DAHelper.off("dataChange", dataAbilityUri, onAsyncCallback0200);
+
+        setTimeout(mySetTimeout, gSetTimeout);
+        function mySetTimeout() {
+            DAHelper.notifyChange(
+                dataAbilityUri,
+                (err) => {
+                    if (err.code != 0) {
+                        console.debug("=ACTS_OnOff_0200 err=======>"
+                            + ("err【") + JSON.stringify(err) + (" 】") + " , " + err);
+                        expect(false).assertTrue();
+                        console.log('ACTS_OnOff_0200====<end err.code');
+                        done();
+                    } else {
+                        currentAlertTimeout = setTimeout(() => {
+                            expect(err.code).assertEqual(0);
+                            console.log('ACTS_OnOff_0200====<end');
+                            done();
+                        }, gSetTimeout);
+                    }
+                }
+            );
+        }
+    } catch (err) {
+        console.error('=ACTS_OnOff_0200  catch(err)====>:' + err);
+        console.log('ACTS_OnOff_0200====<end catch');
+        done();
+    }
+})
+
+
+/*
+* @tc.number: ACTS_ExecuteBatch_Insert_0400
+* @tc.name: ExecuteBatch : Preforms batch operations on the database
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_ExecuteBatch_Insert_0400', 0, async function (done) {
+    console.debug('ACTS_ExecuteBatch_Insert_0400====<begin');
+    try {
+        DAHelper.executeBatch(dataAbilityUri,
+            [
+                {
+                    uri: dataAbilityUri,
+                    type: featureAbility.DataAbilityOperationType.TYPE_INSERT,
+                    valuesBucket: valueBucket,
+                    predicates: null,
+                    expectedCount: 1,
+                    PredicatesBackReferences: {},
+                    interrupted: true,
+                }
+            ],
+            (err, data) => {
+                console.debug("=ACTS_ExecuteBatch_Insert_0400 executeBatch err,data====>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data)
+                    + (" 】;") + data.length);
+                expect(err.code).assertEqual(0);
+                expect(data.length).assertEqual(0);
+                console.debug('ACTS_ExecuteBatch_Insert_0400====<end');
+                done();
+            }
+        );
+    } catch (err) {
+        console.error('=ACTS_ExecuteBatch_Insert_0400 catch(err)====>:'
+            + ("json err 【") + JSON.stringify(err) + (" 】 ,") + err);
+        console.debug('ACTS_ExecuteBatch_Insert_0400====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_ExecuteBatch_Update_0400
+* @tc.name: ExecuteBatch : Preforms batch operations on the database
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_ExecuteBatch_Update_0400', 0, async function (done) {
+    console.debug('ACTS_ExecuteBatch_Update_0400====<begin');
+    try {
+        let predicates = new ohosDataAbility.DataAbilityPredicates();
+        predicates.equalTo('contact_id', 1);
+        predicates.limitAs(10);
+        predicates.orderByAsc("order_by_class");
+        predicates.offsetAs(1);
+
+        DAHelper.executeBatch(dataAbilityUri,
+            [
+                {
+                    uri: dataAbilityUri,
+                    type: featureAbility.DataAbilityOperationType.TYPE_UPDATE,
+                    valuesBucket: valueBucket,
+                    predicates: predicates,
+                    expectedCount: 1,
+                    PredicatesBackReferences: {},
+                    interrupted: true,
+                }
+            ],
+            (err, DataAbilityResult) => {
+                console.debug("=ACTS_ExecuteBatch_Update_0400 executeBatch err,data====>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【")
+                    + JSON.stringify(DataAbilityResult) + (" 】;") + DataAbilityResult.length);
+                for (var i = 0; i < DataAbilityResult.length; i++) {
+                    console.debug('=ACTS_ExecuteBatch_Update_0400 for data[' + i + '].uri ====>: '
+                        + DataAbilityResult[i].uri)
+                    expect(DataAbilityResult[i].uri).assertEqual(dataAbilityUri);
+                    console.debug('=ACTS_ExecuteBatch_Update_0400 for data[' + i + '].count ====>: '
+                        + DataAbilityResult[i].count)
+                    expect(DataAbilityResult[i].count).assertEqual(1);
+                }
+                console.debug('ACTS_ExecuteBatch_Update_0400====<end');
+                done();
+            }
+        );
+    } catch (err) {
+        console.error('=ACTS_ExecuteBatch_Update_0400 catch(err)====>:'
+            + ("json err 【") + JSON.stringify(err) + (" 】 ,") + err);
+        console.debug('ACTS_ExecuteBatch_Update_0400====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_ExecuteBatch_Assert_0400
+* @tc.name: ExecuteBatch : Preforms batch operations on the database
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_ExecuteBatch_Assert_0400', 0, async function (done) {
+    console.debug('ACTS_ExecuteBatch_Assert_0400====<begin');
+    try {
+        let predicates = new ohosDataAbility.DataAbilityPredicates();
+        predicates.equalTo('contact_id', 1);
+        predicates.limitAs(10);
+        predicates.orderByAsc("order_by_class");
+        predicates.offsetAs(1);
+
+        DAHelper.executeBatch(dataAbilityUri,
+            [
+                {
+                    uri: dataAbilityUri,
+                    type: featureAbility.DataAbilityOperationType.TYPE_ASSERT,
+                    valuesBucket: valueBucket,
+                    predicates: predicates,
+                    expectedCount: 1,
+                    PredicatesBackReferences: {},
+                    interrupted: true,
+                }
+            ],
+            (err, data) => {
+                console.debug("=ACTS_ExecuteBatch_Assert_0400 executeBatch err,data====>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(data)
+                    + (" 】;") + data.length);
+                expect(data.length).assertEqual(0);
+                console.debug('ACTS_ExecuteBatch_Assert_0400====<end');
+                done();
+            }
+        );
+    } catch (err) {
+        console.error('=ACTS_ExecuteBatch_Assert_0400 catch(err)====>:'
+            + ("json err 【") + JSON.stringify(err) + (" 】 ,") + err);
+        console.debug('ACTS_ExecuteBatch_Assert_0400====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_ExecuteBatch_Delete_0400
+* @tc.name: ExecuteBatch : Preforms batch operations on the database
+* @tc.desc: Check the return value of the interface (by AsyncCallback)
+*/
+it('ACTS_ExecuteBatch_Delete_0400', 0, async function (done) {
+    console.debug('ACTS_ExecuteBatch_Delete_0400====<begin');
+    try {
+        let predicates = new ohosDataAbility.DataAbilityPredicates();
+        predicates.equalTo('contact_id', 1);
+        predicates.limitAs(10);
+        predicates.orderByAsc("order_by_class");
+        predicates.offsetAs(1);
+
+        DAHelper.executeBatch(dataAbilityUri,
+            [
+                {
+                    uri: dataAbilityUri,
+                    type: featureAbility.DataAbilityOperationType.TYPE_DELETE,
+                    valuesBucket: valueBucket,
+                    predicates: predicates,
+                    expectedCount: 1,
+                    PredicatesBackReferences: {},
+                    interrupted: true,
+                }
+            ],
+            (err, DataAbilityResult) => {
+                console.debug("=ACTS_ExecuteBatch_Delete_0400 executeBatch err,data====>"
+                    + ("json err【") + JSON.stringify(err) + (" 】json data【") + JSON.stringify(DataAbilityResult)
+                    + (" 】;") + DataAbilityResult.length);
+                for (var i = 0; i < DataAbilityResult.length; i++) {
+                    console.debug('=ACTS_ExecuteBatch_Delete_0400 for data[' + i + '].uri ====>: '
+                        + DataAbilityResult[i].uri)
+                    expect(DataAbilityResult[i].uri).assertEqual(dataAbilityUri);
+                    console.debug('=ACTS_ExecuteBatch_Delete_0400 for data[' + i + '].count ====>: '
+                        + DataAbilityResult[i].count)
+                    expect(DataAbilityResult[i].count).assertEqual(1);
+                }
+                console.debug('ACTS_ExecuteBatch_Delete_0400====<end');
+                done();
+            }
+        );
+    } catch (err) {
+        console.error('=ACTS_ExecuteBatch_Delete_0400 catch(err)====>:'
+            + ("json err 【") + JSON.stringify(err) + (" 】 ,") + err);
+        console.debug('ACTS_ExecuteBatch_Delete_0400====<end catch');
+        done();
+    }
+})
+
+/*
+* @tc.number: ACTS_Release_0100
+* @tc.name: Releases the client resource of the Data ability.
+* @tc.desc: Check the return value of the interface (by promise)
+*/
+it('ACTS_Release_0100', 0, async function (done) {
+    console.log('ACTS_Release_0100====<begin');
+    var rDAHelper
+    try {
+        rDAHelper = featureAbility.acquireDataAbilityHelper(dataAbilityUri);
+        console.debug('ACTS_beforeAll rDAHelper ====>: ' + rDAHelper + " ,JSON. " + JSON.stringify(rDAHelper));
+        expect(typeof (rDAHelper)).assertEqual("object");
+        rDAHelper.release().then((data) => {
+            console.debug("=ACTS_Release_0100 then data====>"
+                + ("json data 【") + JSON.stringify(data) + (" 】") + " , " + data);
+            expect(data).assertEqual(true);
+            console.log('ACTS_Release_0100====<end');
+            done();
+        }).catch(err => {
+            console.debug("=ACTS_Release_0100 catch err ====>"
+                + ("json err 【") + JSON.stringify(err) + (" 】 "));
+            expect(false).assertTrue();
+            console.log('ACTS_Release_0100====<end .catch');
+            done();
+        });
+    } catch (err) {
+        console.error('=ACTS_Release_0100 release promise catch(err)====>:' + err);
+        console.log('ACTS_Release_0100====<end catch(err)');
+        done();
+    }
+})
+
+})
\ No newline at end of file

aafwk/aafwk_standard/ActsDataAbilityJsTest/entry/src/main/js/test/List.test.js

+/*
+ * Copyright (c) 2021 Huawei Device Co., Ltd.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+require('./ActsDataAbilityJsTest.test.js')
\ No newline at end of file

aafwk/aafwk_standard/BUILD.gn

@@ -17,6 +17,7 @@ group("aafwk_standard") {
   testonly = true
   if (is_standard_system) {
     deps = [
+      "ActsDataAbilityJsTest:ActsDataAbilityJsTest",
       "abilitymanager:actsabilitymanagertest",
       "actsabilitydistributetest:ActsAbilityDistributeTest",
       "actsabilitydistributetest:ActsAbilityDistributeTest",