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

!6909 【Distributeddatamgr】【monthly_20221018】适配api变更

Merge pull request !6909 from yanglifeng/monthly_20221018
...@@ -76,12 +76,7 @@ describe('deviceKvStoreCallbackTest', function () { ...@@ -76,12 +76,7 @@ describe('deviceKvStoreCallbackTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll config:'+ JSON.stringify(config)); console.info('beforeAll config:'+ JSON.stringify(config));
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config);
kvManager = manager;
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`);
});
await kvManager.getKVStore(TEST_STORE_ID, options).then((store) => { await kvManager.getKVStore(TEST_STORE_ID, options).then((store) => {
kvStore = store; kvStore = store;
console.info('beforeAll getKVStore for getDeviceId success'); console.info('beforeAll getKVStore for getDeviceId success');
......
...@@ -76,12 +76,7 @@ describe('deviceKvStorePromiseTest', function () { ...@@ -76,12 +76,7 @@ describe('deviceKvStorePromiseTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll config:'+ JSON.stringify(config)); console.info('beforeAll config:'+ JSON.stringify(config));
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config);
kvManager = manager;
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`);
});
await kvManager.getKVStore(TEST_STORE_ID, options).then((store) => { await kvManager.getKVStore(TEST_STORE_ID, options).then((store) => {
kvStore = store; kvStore = store;
console.info('beforeAll getKVStore for getDeviceId success'); console.info('beforeAll getKVStore for getDeviceId success');
......
...@@ -42,11 +42,9 @@ describe('kvManagerCallbackTest', function () { ...@@ -42,11 +42,9 @@ describe('kvManagerCallbackTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll'); console.info('beforeAll');
await factory.createKVManager(config, function (err, manager) { kvManager = factory.createKVManager(config);
kvManager = manager;
done();
});
console.info('beforeAll end'); console.info('beforeAll end');
done();
}) })
afterAll(async function (done) { afterAll(async function (done) {
...@@ -498,5 +496,85 @@ describe('kvManagerCallbackTest', function () { ...@@ -498,5 +496,85 @@ describe('kvManagerCallbackTest', function () {
done(); done();
} }
}) })
/**
* @tc.number SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0100
* @tc.desc Test Js Api createKVManager() testcase 001
* @tc.type: FUNC
* @tc.name Test Js Api createKVManager() testcase 001
*/
it('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0100', 0, async function (done) {
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0100 start');
let kvManagerConfig = {
bundleName : [TEST_BUNDLE_NAME],
context: context
}
try{
factory.createKVManager(kvManagerConfig);
expect(false).assertTrue();
}catch(err){
console.info(`Create kvManager error: error code is ${err.code}, error message is ${err.message}`);
expect(err.code).assertEqual("401");
}
done();
})
/**
* @tc.number SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0200
* @tc.desc Test Js Api createKVManager() testcase 002
* @tc.type: FUNC
* @tc.name Test Js Api createKVManager() testcase 002
*/
it('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0200', 0, async function (done) {
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0200 start ');
let kvManagerConfig = {
bundleName : TEST_BUNDLE_NAME,
context: "context"
}
try{
factory.createKVManager(kvManagerConfig);
expect(false).assertTrue();
}catch(err){
console.info(`Create kvManager error: error code is ${err.code}, error message is ${err.message}`);
expect(err.code).assertEqual("401");
}
done();
})
/**
* @tc.number SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0300
* @tc.desc Test Js Api createKVManager() testcase 003
* @tc.type: FUNC
* @tc.name Test Js Api createKVManager() testcase 003
*/
it('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0300', 0, async function (done) {
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0300 start ');
try{
factory.createKVManager("kvManagerConfig");
expect(false).assertTrue();
}catch(err){
console.info(`Create kvManager error: error code is ${err.code}, error message is ${err.message}`);
expect(err.code).assertEqual("401");
}
done();
})
/**
* @tc.number SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0400
* @tc.desc Test Js Api createKVManager() testcase 004
* @tc.type: FUNC
* @tc.name Test Js Api createKVManager() testcase 004
*/
it('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0400', 0, async function (done) {
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_0400 start ');
try{
factory.createKVManager();
expect(false).assertTrue();
}catch(err){
console.info(`Create kvManager error: error code is ${err.code}, error message is ${err.message}`);
expect(err.code).assertEqual("401");
}
done();
})
}) })
} }
\ No newline at end of file
...@@ -45,17 +45,12 @@ describe('KVManagerPromiseTest', function () { ...@@ -45,17 +45,12 @@ describe('KVManagerPromiseTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll'); console.info('beforeAll');
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config)
kvManager = manager; kvManager.getKVStore(TEST_STORE_ID, options).then((store) => {
console.info('beforeAll createKVManager success'); console.info("beforeAll getKVStore success");
kvManager.getKVStore(TEST_STORE_ID, options).then((store) => { kvStoreNew = store;
console.info("beforeAll getKVStore success");
kvStoreNew = store;
}).catch((err) => {
console.info("beforeAll getKVStore err: " + JSON.stringify(err));
});
}).catch((err) => { }).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`); console.info("beforeAll getKVStore err: " + JSON.stringify(err));
}); });
console.info('beforeAll end'); console.info('beforeAll end');
done(); done();
...@@ -394,36 +389,30 @@ describe('KVManagerPromiseTest', function () { ...@@ -394,36 +389,30 @@ describe('KVManagerPromiseTest', function () {
context:context context:context
} }
try { try {
await factory.createKVManager(config).then(async (manager) => { kvManager = factory.createKVManager(config)
kvManager = manager; kvManager.getKVStore(TEST_STORE_ID, options).then(async (store) => {
expect(manager !=null).assertTrue(); console.info("testcreateKVManager001 getKVStore success");
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 createKVManager success'); store.put(STORE_KEY, STORE_VALUE).then(async (data) => {
await kvManager.getKVStore(TEST_STORE_ID, options).then(async (store) => { console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 put data success');
console.info("testcreateKVManager001 getKVStore success"); store.get(STORE_KEY).then((data) => {
await store.put(STORE_KEY, STORE_VALUE).then(async (data) => { console.info("testcreateKVManager001 get data success");
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 put data success'); expect(data).assertEqual(STORE_VALUE);
await store.get(STORE_KEY).then((data) => { done();
console.info("testcreateKVManager001 get data success");
expect(data).assertEqual(STORE_VALUE);
}).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 get data err' + `, error code is ${err.code}, message is ${err.message}`);
});
}).catch((err) => { }).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 put data err' + `, error code is ${err.code}, message is ${err.message}`); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 get data err' + `, error code is ${err.code}, message is ${err.message}`);
}); });
}).catch((err) => { }).catch((err) => {
console.info("testcreateKVManager001 getKVStore err: " + JSON.stringify(err)); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 put data err' + `, error code is ${err.code}, message is ${err.message}`);
expect(null).assertFail();
}); });
}).catch((err) => { }).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`); console.info("testcreateKVManager001 getKVStore err: " + JSON.stringify(err));
expect(null).assertFail() expect(null).assertFail();
}); });
}catch (e) { }catch (e) {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 promise delete fail err' + `, error code is ${err.code}, message is ${err.message}`); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0100 promise delete fail err' + `, error code is ${e.code}, message is ${e.message}`);
expect(null).assertFail(); expect(null).assertFail();
} }
done();
}) })
/** /**
...@@ -439,35 +428,31 @@ describe('KVManagerPromiseTest', function () { ...@@ -439,35 +428,31 @@ describe('KVManagerPromiseTest', function () {
context:contextApplication context:contextApplication
} }
try { try {
await factory.createKVManager(config).then(async (manager) => { kvManager = factory.createKVManager(config)
kvManager = manager; kvManager.getKVStore(TEST_STORE_ID, options).then(async (store) => {
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 createKVManager success'); console.info("testcreateKVManager002 getKVStore success");
await kvManager.getKVStore(TEST_STORE_ID, options).then(async (store) => { store.put(STORE_KEY, STORE_VALUE).then(async (data) => {
console.info("testcreateKVManager002 getKVStore success"); console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 put data success');
await store.put(STORE_KEY, STORE_VALUE).then(async (data) => { store.get(STORE_KEY).then((data) => {
console.info('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 put data success'); console.info("testcreateKVManager002 get data success");
await store.get(STORE_KEY).then((data) => { expect(data).assertEqual(STORE_VALUE);
console.info("testcreateKVManager002 get data success"); done();
expect(data).assertEqual(STORE_VALUE);
}).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 get data err' + `, error code is ${err.code}, message is ${err.message}`);
});
}).catch((err) => { }).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 put data err' + `, error code is ${err.code}, message is ${err.message}`); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 get data err' + `, error code is ${err.code}, message is ${err.message}`);
}); });
}).catch((err) => { }).catch((err) => {
console.info("testcreateKVManager002 getKVStore err: " + JSON.stringify(err)); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 put data err' + `, error code is ${err.code}, message is ${err.message}`);
expect(null).assertFail();
}); });
}).catch((err) => { }).catch((err) => {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`); console.info("testcreateKVManager002 getKVStore err: " + JSON.stringify(err));
expect(null).assertFail() expect(null).assertFail();
}); });
}catch (e) { }catch (e) {
console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 promise delete fail err' + `, error code is ${err.code}, message is ${err.message}`); console.error('SUB_DDM_DKV_KVMANAGER_CREATEKVMANAGER_PROMISE_0200 promise delete fail err' + `, error code is ${err.code}, message is ${err.message}`);
expect(null).assertFail(); expect(null).assertFail();
} }
done();
}) })
}) })
} }
\ No newline at end of file
...@@ -35,25 +35,16 @@ function sleep(ms) { ...@@ -35,25 +35,16 @@ function sleep(ms) {
function publicgetKvStore(optionsp){ function publicgetKvStore(optionsp){
console.log(`Test getKvStore `) console.log(`Test getKvStore `)
return new Promise(function(resolve, reject) { return new Promise(function(resolve, reject) {
distributedData.createKVManager(mKVMgrConfig, (err, data) => { kvManager = distributedData.createKVManager(mKVMgrConfig);
console.info('Test createKVManager begin') kvManager.getKVStore(STORE_ID, optionsp, (err, data) => {
console.info('Test getKVStore begin')
if (err) { if (err) {
console.info('Test createKVManager err = ' + err ); console.info('Test getKVStore err = ' + err);
reject(err); reject(err);
} }
console.info('Test createKVManager data = ' + data); console.info('Test getKVStore data = ' + data);
kvStore = data;
kvManager = data; resolve(data);
data.getKVStore(STORE_ID, optionsp, (err, data) => {
console.info('Test getKVStore begin')
if (err) {
console.info('Test getKVStore err = ' + err);
reject(err);
}
console.info('Test getKVStore data = ' + data);
kvStore = data;
resolve(data);
});
}); });
}) })
} }
......
...@@ -32,25 +32,16 @@ let mKVMgrConfig = { ...@@ -32,25 +32,16 @@ let mKVMgrConfig = {
function publicgetKvStore(optionsp){ function publicgetKvStore(optionsp){
console.log(`Test getKvStore `) console.log(`Test getKvStore `)
return new Promise(function(resolve, reject) { return new Promise(function(resolve, reject) {
distributedData.createKVManager(mKVMgrConfig, (err, data) => { kvManager = distributedData.createKVManager(mKVMgrConfig);
console.info('Test createKVManager begin') kvManager.getKVStore(STORE_ID, optionsp, (err, data) => {
console.info('Test getKVStore begin')
if (err) { if (err) {
console.info('Test createKVManager err = ' + err ); console.info('Test getKVStore err = ' + err);
reject(err); reject(err);
} }
console.info('Test createKVManager data = ' + data); console.info('Test getKVStore data = ' + data);
kvStore = data;
kvManager = data; resolve(data);
data.getKVStore(STORE_ID, optionsp, (err, data) => {
console.info('Test getKVStore begin')
if (err) {
console.info('Test getKVStore err = ' + err);
reject(err);
}
console.info('Test getKVStore data = ' + data);
kvStore = data;
resolve(data);
});
}); });
}) })
} }
......
...@@ -42,12 +42,7 @@ export default function KvStoreResultSetTest(){ ...@@ -42,12 +42,7 @@ export default function KvStoreResultSetTest(){
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll'); console.info('beforeAll');
console.info('beforeAll config:' + JSON.stringify(config)); console.info('beforeAll config:' + JSON.stringify(config));
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config);
kvManager = manager;
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`);
});
await kvManager.getAllKVStoreId(TEST_BUNDLE_NAME).then(async (data) => { await kvManager.getAllKVStoreId(TEST_BUNDLE_NAME).then(async (data) => {
console.info('beforeAll getAllKVStoreId size = ' + data.length); console.info('beforeAll getAllKVStoreId size = ' + data.length);
for (var i = 0; i < data.length; i++) { for (var i = 0; i < data.length; i++) {
......
...@@ -1932,12 +1932,12 @@ describe('queryTest', function() { ...@@ -1932,12 +1932,12 @@ describe('queryTest', function() {
}) })
/** /**
* @tc.number: SUB_DDM_DKV_QUERY_PREFIXKEY_PROMISE_0200 * @tc.number: SUB_DDM_DKV_QUERY_SETSUGGESTINDEX_PROMISE_0200
* @tc.desc: Test Js Api Query.SetSuggestIndex() testcase 002 * @tc.desc: Test Js Api Query.SetSuggestIndex() testcase 002
* @tc.type: FUNC * @tc.type: FUNC
* @tc.name Test Js Api Query.SetSuggestIndex() testcase 002 * @tc.name Test Js Api Query.SetSuggestIndex() testcase 002
*/ */
it('SUB_DDM_DKV_QUERY_PREFIXKEY_PROMISE_0200', 0, async function(done) { it('SUB_DDM_DKV_QUERY_SETSUGGESTINDEX_PROMISE_0200', 0, async function(done) {
var query = null; var query = null;
try { try {
query = new ddm.Query(); query = new ddm.Query();
...@@ -1953,12 +1953,12 @@ describe('queryTest', function() { ...@@ -1953,12 +1953,12 @@ describe('queryTest', function() {
}) })
/** /**
* @tc.number: SUB_DDM_DKV_QUERY_PREFIXKEY_PROMISE_0300 * @tc.number: SUB_DDM_DKV_QUERY_SETSUGGESTINDEX_PROMISE_0300
* @tc.desc: Test Js Api Query.SetSuggestIndex() testcase 003 * @tc.desc: Test Js Api Query.SetSuggestIndex() testcase 003
* @tc.type: FUNC * @tc.type: FUNC
* @tc.name Test Js Api Query.SetSuggestIndex() testcase 003 * @tc.name Test Js Api Query.SetSuggestIndex() testcase 003
*/ */
it('SUB_DDM_DKV_QUERY_PREFIXKEY_PROMISE_0300', 0, async function(done) { it('SUB_DDM_DKV_QUERY_SETSUGGESTINDEX_PROMISE_0300', 0, async function(done) {
var query = null; var query = null;
try { try {
query = new ddm.Query(); query = new ddm.Query();
......
...@@ -104,18 +104,14 @@ describe('schemaTest', function() { ...@@ -104,18 +104,14 @@ describe('schemaTest', function() {
beforeAll(async function (done) { beforeAll(async function (done) {
try { try {
console.info("beforeAll: createKVManager (single) with " + JSON.stringify(options)); console.info("beforeAll: createKVManager (single) with " + JSON.stringify(config));
await ddm.createKVManager(config).then((manager) => { kvManager = ddm.createKVManager(config);
kvManager = manager; done();
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.info('beforeAll createKVManager err ' + err);
});
} catch (e) { } catch (e) {
console.info("fail on exception: " + e); console.info("fail on exception: " + e);
expect(null).assertFail(); expect(null).assertFail();
} }
done();
}) })
afterAll(async function (done) { afterAll(async function (done) {
......
...@@ -75,11 +75,8 @@ describe('SingleKvStoreCallbackTest', function () { ...@@ -75,11 +75,8 @@ describe('SingleKvStoreCallbackTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll config:'+ JSON.stringify(config)); console.info('beforeAll config:'+ JSON.stringify(config));
await factory.createKVManager(config, function (err, manager) { kvManager = factory.createKVManager(config);
kvManager = manager; done();
console.info('beforeAll createKVManager success');
done();
})
}) })
afterAll(async function (done) { afterAll(async function (done) {
......
...@@ -75,12 +75,7 @@ describe('SingleKvStorePromiseTest', function () { ...@@ -75,12 +75,7 @@ describe('SingleKvStorePromiseTest', function () {
beforeAll(async function (done) { beforeAll(async function (done) {
console.info('beforeAll config:'+ JSON.stringify(config)); console.info('beforeAll config:'+ JSON.stringify(config));
await factory.createKVManager(config).then((manager) => { kvManager = factory.createKVManager(config);
kvManager = manager;
console.info('beforeAll createKVManager success');
}).catch((err) => {
console.error('beforeAll createKVManager err ' + `, error code is ${err.code}, message is ${err.message}`);
});
console.info('beforeAll end'); console.info('beforeAll end');
done(); done();
}) })
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册