openharmony/xts_dcts
1
0
Fork 0
mirror of https://gitee.com/openharmony/xts_dcts synced 2024-11-27 01:40:46 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

rdb用例修改

Browse Source 
Signed-off-by: yuxiaoya2 <yuxiaoya@huawei.com>
Change-Id: Ie037ec55cb4101e2bd91227131d6b2644e6712cf
This commit is contained in:
yuxiaoya2 2023-03-28 11:28:13 +08:00
parent 47f1878c05
commit 0f3e22d2c1
1 changed files with 58 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
distributeddatamgr/jstest/distributed_rdb_store/client/hap/src/main/js/test/RdbStoreSyncFirstLevelJsunit.test.js
View File

@ -1386,6 +1386,64 @@ export default function rdbSyncFirstLevelTest(){
console.info(logTag + "************* testRdbSyncTest0170 end *************");
})
/**
* @tc.number SUB_DISTRIBUTEDDATAMGR_SyncRDBTest_1800
* @tc.name testRdbSyncTest0180
* @tc.desc Server rdbStore Insert first and synchronize, Pass null in synchronous mode
*/
it("testRdbSyncTest0180", 0, async function (done) {
console.info(logTag + "testRdbSyncTest0180 start");
var u8 = new Uint8Array([1, 2, 3]);
{
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8
}
await rdbStore.insert("test", valueBucket);
console.info("testRdbSyncTest0180 insert success");
}
let predicates = new data_Rdb.RdbPredicates('test');
predicates.equalTo("name", "zhangsan");
let resultSet = await rdbStore.query(predicates);
try {
expect(true).assertEqual(resultSet.goToFirstRow());
const id = resultSet.getLong(resultSet.getColumnIndex("id"));
const name = resultSet.getString(resultSet.getColumnIndex("name"));
console.info(logTag + "testRdbSyncTest0180 id=" + id + ", name=" + name);
expect("zhangsan").assertEqual(name);
} catch (e) {
console.info("testRdbSyncTest0180 insert error " + e);
expect().assertFail();
}
resultSet = null;
try {
predicates.inDevices(syncDeviceIds);
let promise = rdbStore.sync(null, predicates);
promise.then((result) => {
console.log('testRdbSyncTest0180 sync done.');
for (let i = 0; i < result.length; i++) {
console.log('testRdbSyncTest0180 device=' + result[i][0] + ' status=' + result[i][1]);
let status = result[i][1];
expect(status == 0).assertFail();
}
done();
}).catch((err) => {
console.log('testRdbSyncTest0180 sync failed' + JSON.stringify(err));
expect().assertFail();
done();
})
} catch (error) {
console.log('testRdbSyncTest0180 sync failed error.code message: ' + error.code + error.message);
expect(error.code == 401).assertTrue();
done();
}
// await promise;
console.info(logTag + "************* testRdbSyncTest0180 end *************");
})
/**
* @tc.number SUB_DISTRIBUTEDDATAMGR_SyncRDBTest_1900
* @tc.name testRdbSyncTest0190