acts add rdb cloudsync

Signed-off-by: Nwuxiaodan <wuxiaodan5@huawei.com>

distributeddatamgr/relationalStoretest/relationalStoreJstest/hap/src/main/js/test/List.test.js

@@ -12,7 +12,7 @@
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
-
+import relationalStoreCloudSyncTest from './RelationalStoreCloudSync.test.js'
 import relationalStoreDeleteTest from './RelationalStoreDeleteJsunit.test.js'
 import relationalStoreDistributedTest from './RelationalStoreDistributedJsunit.test.js'
 import relationalStoreInsertTest from './RelationalStoreInsertJsunit.test.js'
@@ -30,6 +30,7 @@ import relationalStoreBackupRestoreWithFAContextTest from './RelationalStoreBack
 import relationalStoreBackupRestoreCallbackTest from './RelationalStoreBackupRestoreCallbackJsunit.test.js'
 import relationalStoreAssetResultSetTest from './RelationalStoreAssetResultSetJsunit.test.js'
 export default function testsuite() {
+    relationalStoreCloudSyncTest()
     relationalStoreDeleteTest()
     relationalStoreDistributedTest()
     relationalStoreInsertTest()

distributeddatamgr/relationalStoretest/relationalStoreJstest/hap/src/main/js/test/RelationalStoreCloudSync.test.js

+/*
+ * Copyright (C) 2023 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 relationalStore from '@ohos.data.relationalStore';
+import ability_featureAbility from '@ohos.ability.featureAbility'
+
+const TAG = "[RELATIONAL_STORE_JSKITS_TEST]"
+const STORE_NAME = "cloud_sync_rdb.db"
+var rdbStore = undefined;
+var context = ability_featureAbility.getContext()
+
+function Progess(ProgressDetail) {
+    console.log(TAG + ` Progess:` + JSON.stringify(ProgressDetail));
+    try{
+        expect( ProgressDetail != undefined ).assertTrue();
+        expect( ProgressDetail["schedule"] == relationalStore.Progress.SYNC_FINISH ).assertTrue();
+        expect( ProgressDetail["code"] != 0 ).assertTrue();
+    }catch(e){
+        console.log(TAG + `expect fail, err code is ${err.code}, message is ${err.message}.`);
+    }
+}
+
+export default function relationalStoreCloudSyncTest() {
+describe('relationalStoreCloudSyncTest', function () {
+    beforeAll(async function (done) {
+        console.info(TAG + 'beforeAll')
+        const config = {
+            "name": STORE_NAME,
+            securityLevel: relationalStore.SecurityLevel.S1,
+        }
+        try {
+            console.log(TAG + "create rdb store before")
+            try{
+                rdbStore = await relationalStore.getRdbStore(context, config);
+                console.log(TAG + "create rdb store success")
+            }catch(err){
+                console.log(TAG + "create rdb store failed" + `, error code is ${err.code}, message is ${err.message}`)
+                expect(null).assertFail()
+                done();
+            }
+
+            let sql_text = "CREATE TABLE IF NOT EXISTS cloud_text (" +
+                "data TEXT, " +
+                "recycled BOOLEAN, " +
+                "recycledTime INTEGER, " +
+                "uuid TEXT PRIMARY KEY)";
+            let sql_int = "CREATE TABLE IF NOT EXISTS cloud_int (" +
+                "data TEXT, " +
+                "recycled BOOLEAN, " +
+                "recycledTime INTEGER, " +
+                "uuid INTEGER PRIMARY KEY)";
+            let sql_integer = "CREATE TABLE IF NOT EXISTS cloud_integer (" +
+                "data TEXT, " +
+                "recycled BOOLEAN, " +
+                "recycledTime INTEGER, " +
+                "uuid INTEGER PRIMARY KEY)";
+            try {
+                await rdbStore.executeSql(sql_text, null);
+                await rdbStore.executeSql(sql_int, null);
+                await rdbStore.executeSql(sql_integer, null);
+                console.log(TAG + "create table cloud_text cloud_int cloud_integer success");
+            } catch (err) {
+                console.log(TAG + "create table cloud_text cloud_int cloud_integer failed" + `, error code is ${err.code}, message is ${err.message}`)
+                expect(null).assertFail();
+            }
+
+            let tableArray = ["cloud_text", "cloud_integer"];
+            const setConfig = {
+                autoSync: false,
+            }
+            let promise = rdbStore.setDistributedTables(
+                tableArray, relationalStore.DistributedType.DISTRIBUTED_CLOUD, setConfig);
+            await promise.then(() => {
+                console.log(TAG + "set disTable success");
+            }).catch((err) => {
+                console.log(TAG + "set disTable fail" + `, error code is ${err.code}, message is ${err.message}`)
+            })
+            let vBucketArray1 = new Array();
+            for (let i = 0; i < 5; i++) {
+                let valueBucket = {
+                    "data": "cloud_sync_insert",
+                    "recycled": true,
+                    "recycledTime": 12345,
+                    "uuid": "test_key" + i.toString(),
+                }
+                vBucketArray1.push(valueBucket);
+            }
+            await rdbStore.batchInsert("cloud_text", vBucketArray1);
+            let vBucketArray2 = new Array();
+            for (let i = 0; i < 5; i++) {
+                let valueBucket = {
+                    "data": "cloud_sync_insert",
+                    "recycled": true,
+                    "recycledTime": 12345,
+                    "uuid": i,
+                }
+                vBucketArray2.push(valueBucket);
+            }
+            await rdbStore.batchInsert("cloud_integer", vBucketArray2);
+            console.log(TAG + "create rdb store success");
+        } catch (err) {
+            console.log(TAG + "create rdb store failed" + `, error code is ${err.code}, message is ${err.message}`)
+            expect(null).assertFail()
+        }
+        done();
+    })
+
+    beforeEach(async function () {
+        console.info(TAG + 'beforeEach')
+    })
+
+    afterEach(async function () {
+        console.info(TAG + 'afterEach')
+    })
+
+    afterAll(async function () {
+        console.info(TAG + 'afterAll')
+        rdbStore = null
+        await rdbStore.deleteRdbStore(context, STORE_NAME);
+    })
+
+    console.log(TAG + "*************Unit Test Begin*************");
+
+    /**
+     * @tc.name get modify time using wrong primary key type
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0001
+     * @tc.desc rdb get modify time using wrong primary key type
+     */
+    it('testRdbStoreCloudSync0001', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0001 start *************");
+        try {
+            let key = new Array();
+            let PRIKey = [key, "test_key1", "test_key2"];
+            rdbStore.getModifyTime("cloud_text", "uuid", PRIKey, function (err, modifyTime) {
+                console.log(TAG + 'modifyTime:' + JSON.stringify(modifyTime));
+                expect(null).assertFail();
+            });
+        } catch (err) {
+            console.log(TAG + `get modify time, err code is ${err.code}, message is ${err.message}.`);
+            expect(err.code).assertEqual('401');
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0001 end *************");
+    })
+
+    /**
+     * @tc.name get modify time using string primary key type and callback method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0002
+     * @tc.desc get modify time using string primary key type and callback method
+     */
+    it('testRdbStoreCloudSync0002', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0002 start *************");
+        try {
+            let PRIKey = ["test_key1", "test_key2"];
+            rdbStore.getModifyTime("cloud_text", "uuid", PRIKey, function (err, data) {
+                console.log(TAG + 'modifyTime:' + JSON.stringify(data));
+                expect( data != undefined ).assertTrue();
+                expect( data["test_key1"] != undefined ).assertTrue();
+                expect( data["test_key2"] != undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `get modify time fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0002 end *************");
+    })
+
+    /**
+     * @tc.name get modify time using string primary key type and promise method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0003
+     * @tc.desc get modify time using string primary key type and promise method
+     */
+    it('testRdbStoreCloudSync0003', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0003 start *************");
+        try {
+            let PRIKey = ["test_key1", "test_key2"];
+            await rdbStore.getModifyTime("cloud_text", "uuid", PRIKey).then((data) => {
+                console.log(TAG + `modifyTime:` + JSON.stringify(data));
+                expect( data != undefined ).assertTrue();
+                expect( data["test_key1"] != undefined ).assertTrue();
+                expect( data["test_key2"] != undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `get modify time fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0003 end *************");
+    })
+
+    /**
+     * @tc.name get modify time using rowid and callback method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0004
+     * @tc.desc get modify time using rowid and callback method
+     */
+    it('testRdbStoreCloudSync0004', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0004 start *************");
+        try {
+            let PRIKey = [1, 3, 4];
+            rdbStore.getModifyTime("cloud_text", "rowid", PRIKey, function (err, data) {
+                console.log(TAG + `modifyTime:` + JSON.stringify(data));
+                expect( data != undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `get modify time fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0004 end *************");
+    })
+
+    /**
+     * @tc.name get modify time using rowid and promise method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0005
+     * @tc.desc get modify time using rowid and promise method
+     */
+    it('testRdbStoreCloudSync0005', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0005 start *************");
+        try {
+            let PRIKey = [2, 4];
+            await rdbStore.getModifyTime("cloud_text", "roWId", PRIKey).then((data) => {
+                console.log(TAG + `modifyTime:` + JSON.stringify(data));
+                expect( data != undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `get modify time fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0005 end *************");
+    })
+
+    /**
+     * @tc.name get modify time, but not set distributed table
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0006
+     * @tc.desc get modify time, but not set distributed table
+     */
+    it('testRdbStoreCloudSync0006', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0006 start *************");
+        try {
+            for (let i = 0; i < 5; i++) {
+                let valueBucket = {
+                    "data": "cloud_sync_insert",
+                    "recycled": true,
+                    "recycledTime": 12345,
+                    "uuid": i,
+                }
+                let vBucketArray = new Array();
+                vBucketArray.push(valueBucket);
+                await rdbStore.batchInsert("cloud_int", vBucketArray);
+            }
+            let PRIKey = [0, 1, 2];
+            await rdbStore.getModifyTime("cloud_int", "uuid", PRIKey).then((data) => {
+                console.log(TAG + `modifyTime:` + JSON.stringify(data));
+                expect(null).assertFail();
+            })
+        } catch (err) {
+            console.log(TAG + `get modify time fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(err.code == 14800000).assertTrue();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0006 end *************");
+    })
+
+    /**
+     * @tc.name get modify time using int primary key type and callback method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0007
+     * @tc.desc get modify time using int primary key type and callback method
+     */
+    it('testRdbStoreCloudSync0007', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0007 start *************");
+        try {
+            let PRIKey = [1, 2, 4];
+            rdbStore.getModifyTime("cloud_integer", "uuid", PRIKey, function (err, data) {
+                console.log(TAG + `modifyTime:` + JSON.stringify(data));
+                expect( data != undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `get modify time fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0007 end *************");
+    })
+
+    /**
+     * @tc.name get modify time using int primary key type and promise method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0008
+     * @tc.desc get modify time using int primary key type and promise method
+     */
+    it('testRdbStoreCloudSync0008', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0008 start *************");
+        try {
+            let PRIKey = [2, 4];
+            await rdbStore.getModifyTime("cloud_integer", "uuid", PRIKey).then((data) => {
+                console.log(TAG + `modifyTime:` + JSON.stringify(data));
+                expect( data != undefined ).assertTrue();
+                expect( data[2] != undefined ).assertTrue();
+                expect( data[4] != undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `get modify time fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0008 end *************");
+    })
+
+    /**
+     * @tc.name cloud sync with no table, SyncMode is SYNC_MODE_TIME_FIRST and callback method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0009
+     * @tc.desc cloud sync with no table, SyncMode is SYNC_MODE_TIME_FIRST and callback method
+     */
+    it('testRdbStoreCloudSync0009', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0009 start *************");
+        try {
+            rdbStore.cloudSync(relationalStore.SyncMode.SYNC_MODE_TIME_FIRST, Progess , function (err, data) {
+                console.log(TAG + `cloud sync success:`);
+                expect( (err == undefined) && (data == undefined) ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `cloud sync fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0009 end *************");
+    })
+
+    /**
+     * @tc.name cloud sync with no table, SyncMode is SYNC_MODE_TIME_FIRST and promise method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0010
+     * @tc.desc cloud sync with no table, SyncMode is SYNC_MODE_TIME_FIRST and promise method
+     */
+    it('testRdbStoreCloudSync0010', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0010 start *************");
+        try {
+            await rdbStore.cloudSync(relationalStore.SyncMode.SYNC_MODE_TIME_FIRST, Progess).then((data) => {
+                console.log(TAG + `cloud sync success:` + data);
+                expect( data == undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `cloud sync fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0010 end *************");
+    })
+
+    /**
+     * @tc.name cloud sync with table, SyncMode is SYNC_MODE_TIME_FIRST and callback method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0011
+     * @tc.desc cloud sync with table, SyncMode is SYNC_MODE_TIME_FIRST and callback method
+     */
+    it('testRdbStoreCloudSync0011', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0011 start *************");
+        try {
+            let tableArray = ["cloud_text"];
+            rdbStore.cloudSync(relationalStore.SyncMode.SYNC_MODE_TIME_FIRST, tableArray, Progess , function (err, data) {
+                console.log(TAG + `cloud sync success:` + err);
+                expect( (err == undefined) && (data == undefined) ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `cloud sync fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0011 end *************");
+    })
+
+    /**
+     * @tc.name cloud sync with table, SyncMode is SYNC_MODE_TIME_FIRST and promise method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0012
+     * @tc.desc cloud sync with table, SyncMode is SYNC_MODE_TIME_FIRST and promise method
+     */
+    it('testRdbStoreCloudSync0012', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0012 start *************");
+        try {
+            let tableArray = ["cloud_text"];
+            await rdbStore.cloudSync(
+                relationalStore.SyncMode.SYNC_MODE_TIME_FIRST, tableArray, Progess).then((data) => {
+                console.log(TAG + `cloud sync success:` + data);
+                expect( data == undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `cloud sync fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0012 end *************");
+    })
+
+    /**
+     * @tc.name cloud sync with table, SyncMode is SYNC_MODE_NATIVE_FIRST and promise method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0013
+     * @tc.desc cloud sync with table, SyncMode is SYNC_MODE_NATIVE_FIRST and promise method
+     */
+    it('testRdbStoreCloudSync0013', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0013 start *************");
+        try {
+            let tableArray = ["cloud_text"];
+            await rdbStore.cloudSync(
+                relationalStore.SyncMode.SYNC_MODE_NATIVE_FIRST, tableArray, Progess).then((data) => {
+                console.log(TAG + `cloud sync success:` + data);
+                expect( data == undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `cloud sync fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0013 end *************");
+    })
+
+    /**
+     * @tc.name cloud sync with table, SyncMode is SYNC_MODE_CLOUD_FIRST and promise method
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0014
+     * @tc.desc cloud sync with table, SyncMode is SYNC_MODE_CLOUD_FIRST and promise method
+     */
+    it('testRdbStoreCloudSync0014', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0014 start *************");
+        try {
+            let tableArray = ["cloud_text"];
+            await rdbStore.cloudSync(
+                relationalStore.SyncMode.SYNC_MODE_CLOUD_FIRST, tableArray, Progess).then((data) => {
+                console.log(TAG + `cloud sync success:` + data);
+                expect( data == undefined ).assertTrue();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `cloud sync fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(null).assertFail();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0014 end *************");
+    })
+
+    /**
+     * @tc.name cloud sync with no SyncMode
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0015
+     * @tc.desc cloud sync with table, SyncMode is SYNC_MODE_CLOUD_FIRST and promise method
+     */
+    it('testRdbStoreCloudSync0015', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0015 start *************");
+        try {
+            await rdbStore.cloudSync( Progess ).then((data) => {
+                console.log(TAG + `cloud sync success:` + data);
+                expect(null).assertFail();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `cloud sync fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(err.code == 401).assertTrue();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0015 end *************");
+    })
+
+     /**
+     * @tc.name cloud sync with SyncMode err
+     * @tc.number SUB_DDM_AppDataFWK_JSRDB_CLOUD_SYNC_0016
+     * @tc.desc cloud sync with table, SyncMode is SYNC_MODE_CLOUD_FIRST and promise method
+     */
+    it('testRdbStoreCloudSync0016', 0, async function (done) {
+        console.log(TAG + "************* testRdbStoreCloudSync0016 start *************");
+        try {
+            let tableArray = ["cloud_text"];
+            await rdbStore.cloudSync(
+                relationalStore.SyncMode.SYNC_MODE, tableArray, Progess).then((data) => {
+                console.log(TAG + `cloud sync success:` + data);
+                expect(null).assertFail();
+                done();
+            });
+        } catch (err) {
+            console.log(TAG + `cloud sync fail, err code is ${err.code}, message is ${err.message}.`);
+            expect(err.code == 401).assertTrue();
+            done();
+        }
+        console.log(TAG + "************* testRdbStoreCloudSync0016 end *************");
+    })
+
+    console.log(TAG + "*************Unit Test End*************");
+})}