未验证 提交 d91fe104 编写于 作者: O openharmony_ci 提交者: Gitee

!2251 新增dataabilityXTS代码

Merge pull request !2251 from kirl75/master_xts_0308
# 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"
}
{
"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
}
]
}
{
"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
/*
* 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');
}
};
{
"strings": {
"hello": "Hello",
"world": "World"
}
}
\ No newline at end of file
{
"strings": {
"hello": "您好",
"world": "世界"
}
}
\ No newline at end of file
.container {
flex-direction: column;
justify-content: center;
align-items: center;
}
.title {
font-size: 100px;
}
.btn {
width: 200px;
height: 80px;
}
<div class="container">
<text class="title">
{{ $t('strings.hello') }} {{ title }}
</text>
<button class="btn" type="capsule" value="start" onclick="start"></button>
</div>
/*
* 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));
}
}
{
"string": [
{
"name": "app_name",
"value": "actsparticleabilitytest"
},
{
"name": "mainability_description",
"value": "JS_Phone_Empty Feature Ability"
}
]
}
\ No newline at end of file
/*
* 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
/*
* 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
......@@ -17,6 +17,7 @@ group("aafwk_standard") {
testonly = true
if (is_standard_system) {
deps = [
"ActsDataAbilityJsTest:ActsDataAbilityJsTest",
"ActsKillProcessWithAccountApi7:ActsKillProcessWithAccountApi7",
"abilitymanager:actsabilitymanagertest",
"actsabilitydistributetest:ActsAbilityDistributeTest",
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册