Skip to content

X
Xts Acts

OpenHarmony / Xts Acts
1 年多 前同步成功

通知 9
Star 22
Fork 0
X
Xts Acts
提交 912d89d6 编写于 作者: L liuhaonan2
浏览文件
操作

<liuhaonan8@huawei.com> 

Signed-off-by: Nliuhaonan2 <liuhaonan8@huawei.com>
上级 858ccd15
隐藏空白更改
内联 并排
Showing with 1265 addition and 180 deletion
distributeddatamgr/relationalStoretest/relationalStoreJstest/hap/src/main/js/test/RelationalStoreUpdateJsunit.test.js
浏览文件 @ 912d89d6
......@@ -12,7 +12,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from '@ohos/hypium'
import { describe, beforeAll, beforeEach, afterEach, afterAll, it, expect } from '@ohos/hypium'
import data_Rdb from '@ohos.data.relationalStore';
import ability_featureAbility from '@ohos.ability.featureAbility';
var context = ability_featureAbility.getContext();
......@@ -26,68 +26,394 @@ const STORE_CONFIG = {
var rdbStore = undefined;
export default function relationalStoreUpdateTest() {
describe('relationalStoreUpdateTest', function () {
beforeAll(function () {
console.info(TAG + 'beforeAll')
})
describe('relationalStoreUpdateTest', function () {
beforeAll(function () {
console.info(TAG + 'beforeAll')
})
beforeEach(async function () {
console.info(TAG + 'beforeEach')
rdbStore = await data_Rdb.getRdbStore(context, STORE_CONFIG);
await rdbStore.executeSql(CREATE_TABLE_TEST, null);
})
beforeEach(async function () {
console.info(TAG + 'beforeEach')
rdbStore = await data_Rdb.getRdbStore(context, STORE_CONFIG);
await rdbStore.executeSql(CREATE_TABLE_TEST, null);
})
afterEach(async function () {
console.info(TAG + 'afterEach')
await rdbStore.executeSql("DELETE FROM test");
rdbStore = null
await data_Rdb.deleteRdbStore(context, "UpdataTest.db");
})
afterEach(async function () {
console.info(TAG + 'afterEach')
await rdbStore.executeSql("DELETE FROM test");
rdbStore = null
await data_Rdb.deleteRdbStore(context, "UpdataTest.db");
})
afterAll(async function () {
console.info(TAG + 'afterAll')
})
afterAll(async function () {
console.info(TAG + 'afterAll')
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRelationalStore_Update_0010
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdate0001', 0, async function (done) {
console.info(TAG + "************* testRdbStoreUpdate0001 start *************");
var u8 = new Uint8Array([1, 2, 3])
//插入
{
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
let insertPromise = rdbStore.insert("test", valueBucket)
insertPromise.then(async (ret) => {
expect(1).assertEqual(ret);
console.info(TAG + "update done: " + ret);
}).catch((err) => {
expect(null).assertFail();
})
await insertPromise
}
//更新
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"name": "lisi",
"age": 20,
"salary": 200.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
predicates.equalTo("id", "1")
let updatePromise = rdbStore.update(valueBucket, predicates)
await updatePromise.then(async (ret) => {
expect(1).assertEqual(ret);
console.info(TAG + "update done: " + ret);
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRelationalStore_Update_0010
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdate0001', 0, async function (done) {
console.info(TAG + "************* testRdbStoreUpdate0001 start *************");
var u8 = new Uint8Array([1, 2, 3])
//插入
{
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
let insertPromise = rdbStore.insert("test", valueBucket)
insertPromise.then(async (ret) => {
expect(1).assertEqual(ret);
console.info(TAG + "update done: " + ret);
}).catch((err) => {
expect(null).assertFail();
})
await insertPromise
}
//更新
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"name": "lisi",
"age": 20,
"salary": 200.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
predicates.equalTo("id", "1")
let updatePromise = rdbStore.update(valueBucket, predicates)
await updatePromise.then(async (ret) => {
expect(1).assertEqual(ret);
console.info(TAG + "update done: " + ret);
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
expect(1).assertEqual(id);
expect("lisi").assertEqual(name);
expect(20).assertEqual(age);
expect(200.5).assertEqual(salary);
expect(4).assertEqual(blobType[0]);
expect(5).assertEqual(blobType[1]);
expect(6).assertEqual(blobType[2]);
console.info(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary=" + salary + ", blobType=" + blobType);
expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
}).catch((err) => {
console.info(TAG + "update error");
expect(null).assertFail();
})
//await updatePromise
}
done();
console.info(TAG + "************* testRdbStoreUpdate0001 end *************");
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRelationalStore_Update_0020
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdate0002', 0, async function (done) {
console.info(TAG + "************* testRdbStoreUpdate0002 start *************");
//更新
{
let errInfo = undefined;
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
try {
let predicates = new data_Rdb.RdbPredicates("")
let updatePromise = rdbStore.update(valueBucket, predicates)
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
}).catch((err) => {
console.info(TAG + "update with null table name");
})
} catch (err) {
errInfo = err
}
{
const emptyBucket = {};
let predicates = await new data_Rdb.RdbPredicates("test")
let updatePromise = rdbStore.update(emptyBucket, predicates)
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
}).catch((err) => {
console.info(TAG + "update with wrong valueBucket");
})
}
{
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("aaa", "null")
let updatePromise = rdbStore.update(valueBucket, predicates)
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
}).catch((err) => {
console.info(TAG + "update with wrong condition");
})
}
expect(errInfo.code).assertEqual("401")
}
done();
console.info(TAG + "************* testRdbStoreUpdate0002 end *************");
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRelationalStore_Update_0030
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdate0003', 0, async function (done) {
console.info(TAG + "************* testRdbStoreUpdate0003 start *************");
//更新
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
"wrongColumn": 100.5,
}
{
let predicates = new data_Rdb.RdbPredicates("wrongTable")
let updatePromise = rdbStore.update(valueBucket, predicates)
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
}).catch((err) => {
console.info(TAG + "update with wrong table name");
})
//await updatePromise
}
{
let predicates = await new data_Rdb.RdbPredicates("test")
let updatePromise = rdbStore.update(valueBucket, predicates)
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
}).catch((err) => {
console.info(TAG + "update with wrong column name");
})
//await updatePromise
}
}
done();
console.info(TAG + "************* testRdbStoreUpdate0003 end *************");
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRelationalStore_Update_0040
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdate0004', 0, async function (done) {
console.info(TAG + "************* testRdbStoreUpdate0004 start *************");
//更新
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
{
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("aaa", "null")
let updatePromise = rdbStore.update(valueBucket, predicates)
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
}).catch((err) => {
console.info(TAG + "update with wrong condition");
})
//await updatePromise
}
{
const emptyBucket = {};
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("name", "zhangsan")
await predicates.equalTo("age", 18)
await predicates.equalTo("null", 100.5)
let updatePromise = rdbStore.update(valueBucket, predicates)
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
}).catch((err) => {
console.info(TAG + "update with wrong condition");
})
}
}
done();
console.info(TAG + "************* testRdbStoreUpdate0004 end *************");
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_UpdateWithConflictResolution_0001
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdateWithConflictResolution0001', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0001 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([7, 8, 9])
const valueBucket = {
"id": 3,
"name": "wangjing",
"age": 20,
"salary": 300.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates)
updatePromise.then(async (ret) => {
await expect(1).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0001 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(1).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(18).assertEqual(age);
await expect(100.5).assertEqual(salary);
await expect(1).assertEqual(blobType[0]);
await expect(2).assertEqual(blobType[1]);
await expect(3).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(true).assertEqual(resultSet.goToNextRow())
const id_1 = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name_1 = await resultSet.getString(resultSet.getColumnIndex("name"))
const age_1 = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary_1 = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType_1 = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(3).assertEqual(id_1);
await expect("wangjing").assertEqual(name_1);
await expect(20).assertEqual(age_1);
await expect(300.5).assertEqual(salary_1);
await expect(7).assertEqual(blobType_1[0]);
await expect(8).assertEqual(blobType_1[1]);
await expect(9).assertEqual(blobType_1[2]);
console.log(TAG + "{id=" + id_1 + ", name=" + name_1 + ", age=" + age_1 + ", salary="
+ salary_1 + ", blobType=" + blobType_1);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done();
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0001 end *************");
}
}).catch((err) => {
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0001 error");
expect(null).assertFail();
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0001 end *************");
})
}
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_UpdateWithConflictResolution_0002
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdateWithConflictResolution0002', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0002 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([7, 8, 9])
const valueBucket = {
"id": 3,
"name": "zhangsan",
"age": 20,
"salary": 300.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_NONE);
updatePromise.then(async (ret) => {
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0002 done: " + ret);
expect(null).assertFail();
}).catch((err) => {
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0002 error");
expect(null).assertFail();
})
done()
}
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
......@@ -97,174 +423,933 @@ describe('relationalStoreUpdateTest', function () {
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
expect(1).assertEqual(id);
expect("lisi").assertEqual(name);
expect(20).assertEqual(age);
expect(200.5).assertEqual(salary);
expect(4).assertEqual(blobType[0]);
expect(5).assertEqual(blobType[1]);
expect(6).assertEqual(blobType[2]);
console.info(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary=" + salary + ", blobType=" + blobType);
expect(false).assertEqual(resultSet.goToNextRow())
await expect(1).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(18).assertEqual(age);
await expect(100.5).assertEqual(salary);
await expect(1).assertEqual(blobType[0]);
await expect(2).assertEqual(blobType[1]);
await expect(3).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(true).assertEqual(resultSet.goToNextRow())
const id_1 = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name_1 = await resultSet.getString(resultSet.getColumnIndex("name"))
const age_1 = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary_1 = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType_1 = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(2).assertEqual(id_1);
await expect("lisi").assertEqual(name_1);
await expect(19).assertEqual(age_1);
await expect(200.5).assertEqual(salary_1);
await expect(4).assertEqual(blobType_1[0]);
await expect(5).assertEqual(blobType_1[1]);
await expect(6).assertEqual(blobType_1[2]);
console.log(TAG + "{id=" + id_1 + ", name=" + name_1 + ", age=" + age_1 + ", salary="
+ salary_1 + ", blobType=" + blobType_1);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
}).catch((err) => {
console.info(TAG + "update error");
expect(null).assertFail();
})
//await updatePromise
}
done();
console.info(TAG + "************* testRdbStoreUpdate0001 end *************");
})
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0002 end *************");
}
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRelationalStore_Update_0020
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdate0002', 0, async function (done) {
console.info(TAG + "************* testRdbStoreUpdate0002 start *************");
//更新
{
let errInfo = undefined;
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
try{
let predicates = new data_Rdb.RdbPredicates("")
let updatePromise = rdbStore.update(valueBucket, predicates)
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_UpdateWithConflictResolution_0003
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdateWithConflictResolution0003', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0003 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([7, 8, 9])
const valueBucket = {
"id": 3,
"name": "wangjing",
"age": 20,
"salary": 300.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_ROLLBACK);
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
await expect(1).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0003 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(1).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(18).assertEqual(age);
await expect(100.5).assertEqual(salary);
await expect(1).assertEqual(blobType[0]);
await expect(2).assertEqual(blobType[1]);
await expect(3).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(true).assertEqual(resultSet.goToNextRow())
const id_1 = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name_1 = await resultSet.getString(resultSet.getColumnIndex("name"))
const age_1 = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary_1 = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType_1 = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(3).assertEqual(id_1);
await expect("wangjing").assertEqual(name_1);
await expect(20).assertEqual(age_1);
await expect(300.5).assertEqual(salary_1);
await expect(7).assertEqual(blobType_1[0]);
await expect(8).assertEqual(blobType_1[1]);
await expect(9).assertEqual(blobType_1[2]);
console.log(TAG + "{id=" + id_1 + ", name=" + name_1 + ", age=" + age_1 + ", salary="
+ salary_1 + ", blobType=" + blobType_1);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done();
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0003 end *************");
}
}).catch((err) => {
console.info(TAG + "update with null table name");
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0003 error");
expect(null).assertFail();
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0003 end *************");
})
}catch(err){
errInfo = err
}
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_UpdateWithConflictResolution_0004
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdateWithConflictResolution0004', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0004 start *************");
{
const emptyBucket = {};
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([7, 8, 9])
const valueBucket = {
"id": 3,
"name": "zhangsan",
"age": 20,
"salary": 300.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
let updatePromise = rdbStore.update(emptyBucket, predicates)
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_ROLLBACK);
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
aexpect(null).assertFail();
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0004 done: " + ret);
}).catch((err) => {
console.info(TAG + "update with wrong valueBucket");
expect(null).assertFail();
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0004 error");
})
done()
}
{
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("aaa", "null")
let updatePromise = rdbStore.update(valueBucket, predicates)
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(1).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(18).assertEqual(age);
await expect(100.5).assertEqual(salary);
await expect(1).assertEqual(blobType[0]);
await expect(2).assertEqual(blobType[1]);
await expect(3).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(true).assertEqual(resultSet.goToNextRow())
const id_1 = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name_1 = await resultSet.getString(resultSet.getColumnIndex("name"))
const age_1 = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary_1 = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType_1 = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(2).assertEqual(id_1);
await expect("lisi").assertEqual(name_1);
await expect(19).assertEqual(age_1);
await expect(200.5).assertEqual(salary_1);
await expect(4).assertEqual(blobType_1[0]);
await expect(5).assertEqual(blobType_1[1]);
await expect(6).assertEqual(blobType_1[2]);
console.log(TAG + "{id=" + id_1 + ", name=" + name_1 + ", age=" + age_1 + ", salary="
+ salary_1 + ", blobType=" + blobType_1);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0004 end *************");
}
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_UpdateWithConflictResolution_0005
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdateWithConflictResolution0005', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0005 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([7, 8, 9])
const valueBucket = {
"id": 3,
"name": "wangjing",
"age": 20,
"salary": 300.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_REPLACE);
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
await expect(1).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0005 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(1).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(18).assertEqual(age);
await expect(100.5).assertEqual(salary);
await expect(1).assertEqual(blobType[0]);
await expect(2).assertEqual(blobType[1]);
await expect(3).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(true).assertEqual(resultSet.goToNextRow())
const id_1 = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name_1 = await resultSet.getString(resultSet.getColumnIndex("name"))
const age_1 = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary_1 = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType_1 = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(3).assertEqual(id_1);
await expect("wangjing").assertEqual(name_1);
await expect(20).assertEqual(age_1);
await expect(300.5).assertEqual(salary_1);
await expect(7).assertEqual(blobType_1[0]);
await expect(8).assertEqual(blobType_1[1]);
await expect(9).assertEqual(blobType_1[2]);
console.log(TAG + "{id=" + id_1 + ", name=" + name_1 + ", age=" + age_1 + ", salary="
+ salary_1 + ", blobType=" + blobType_1);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0005 end *************");
}
}).catch((err) => {
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0005 error");
expect(null).assertFail();
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0005 end *************");
})
}
})
it('testRdbStoreUpdateWithConflictResolution0006', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0006 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
const valueBucket = {
"name": "zhangsan",
"age": 20,
"salary": 300.5,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_REPLACE);
updatePromise.then(async (ret) => {
await expect(1).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0006 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(2).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(20).assertEqual(age);
await expect(300.5).assertEqual(salary);
await expect(4).assertEqual(blobType[0]);
await expect(5).assertEqual(blobType[1]);
await expect(6).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0006 end *************");
}
}).catch((err) => {
console.info(TAG + "update with wrong condition");
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0006 error");
expect(null).assertFail();
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0006 end *************");
})
}
expect(errInfo.code).assertEqual("401")
}
done();
console.info(TAG + "************* testRdbStoreUpdate0002 end *************");
})
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRelationalStore_Update_0030
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdate0003', 0, async function (done) {
console.info(TAG + "************* testRdbStoreUpdate0003 start *************");
//更新
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
"wrongColumn": 100.5,
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_UpdateWithConflictResolution_0007
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdateWithConflictResolution0007', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0007 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
let predicates = new data_Rdb.RdbPredicates("wrongTable")
let updatePromise = rdbStore.update(valueBucket, predicates)
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([7, 8, 9])
const valueBucket = {
"id": 3,
"name": "wangjing",
"age": 20,
"salary": 300.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_ABORT);
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
await expect(1).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0007 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(1).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(18).assertEqual(age);
await expect(100.5).assertEqual(salary);
await expect(1).assertEqual(blobType[0]);
await expect(2).assertEqual(blobType[1]);
await expect(3).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(true).assertEqual(resultSet.goToNextRow())
const id_1 = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name_1 = await resultSet.getString(resultSet.getColumnIndex("name"))
const age_1 = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary_1 = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType_1 = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(3).assertEqual(id_1);
await expect("wangjing").assertEqual(name_1);
await expect(20).assertEqual(age_1);
await expect(300.5).assertEqual(salary_1);
await expect(7).assertEqual(blobType_1[0]);
await expect(8).assertEqual(blobType_1[1]);
await expect(9).assertEqual(blobType_1[2]);
console.log(TAG + "{id=" + id_1 + ", name=" + name_1 + ", age=" + age_1 + ", salary="
+ salary_1 + ", blobType=" + blobType_1);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0007 end *************");
}
}).catch((err) => {
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0007 error");
expect(null).assertFail();
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0007 end *************");
})
}
})
it('testRdbStoreUpdateWithConflictResolution0008', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0008 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
const valueBucket = {
"name": "zhangsan",
"age": 20,
"salary": 300.5,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_ABORT);
updatePromise.then(async (ret) => {
await expect(1).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0008 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(2).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(20).assertEqual(age);
await expect(300.5).assertEqual(salary);
await expect(4).assertEqual(blobType[0]);
await expect(5).assertEqual(blobType[1]);
await expect(6).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0008 end *************");
}
}).catch((err) => {
console.info(TAG + "update with wrong table name");
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0008 error");
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0008 end *************");
})
//await updatePromise
}
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_UpdateWithConflictResolution_0009
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdateWithConflictResolution0009', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0009 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([7, 8, 9])
const valueBucket = {
"id": 3,
"name": "wangjing",
"age": 20,
"salary": 300.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
let updatePromise = rdbStore.update(valueBucket, predicates)
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_IGNORE);
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
await expect(1).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0009 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(1).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(18).assertEqual(age);
await expect(100.5).assertEqual(salary);
await expect(1).assertEqual(blobType[0]);
await expect(2).assertEqual(blobType[1]);
await expect(3).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(true).assertEqual(resultSet.goToNextRow())
const id_1 = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name_1 = await resultSet.getString(resultSet.getColumnIndex("name"))
const age_1 = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary_1 = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType_1 = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(3).assertEqual(id_1);
await expect("wangjing").assertEqual(name_1);
await expect(20).assertEqual(age_1);
await expect(300.5).assertEqual(salary_1);
await expect(7).assertEqual(blobType_1[0]);
await expect(8).assertEqual(blobType_1[1]);
await expect(9).assertEqual(blobType_1[2]);
console.log(TAG + "{id=" + id_1 + ", name=" + name_1 + ", age=" + age_1 + ", salary="
+ salary_1 + ", blobType=" + blobType_1);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0009 end *************");
}
}).catch((err) => {
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0009 error");
expect(null).assertFail();
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0009 end *************");
})
}
})
it('testRdbStoreUpdateWithConflictResolution0010', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0010 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
const valueBucket = {
"name": "zhangsan",
"age": 20,
"salary": 300.5,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_IGNORE);
updatePromise.then(async (ret) => {
await expect(0).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0010 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(1).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(18).assertEqual(age);
await expect(100.5).assertEqual(salary);
await expect(1).assertEqual(blobType[0]);
await expect(2).assertEqual(blobType[1]);
await expect(3).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(true).assertEqual(resultSet.goToNextRow())
resultSet = null
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0010 end *************");
}
}).catch((err) => {
console.info(TAG + "update with wrong column name");
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0010 error");
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0010 end *************");
})
//await updatePromise
}
}
done();
console.info(TAG + "************* testRdbStoreUpdate0003 end *************");
})
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRelationalStore_Update_0040
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdate0004', 0, async function (done) {
console.info(TAG + "************* testRdbStoreUpdate0004 start *************");
//更新
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_UpdateWithConflictResolution_0011
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdateWithConflictResolution0011', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0011 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([7, 8, 9])
const valueBucket = {
"id": 3,
"name": "wangjing",
"age": 20,
"salary": 300.5,
"blobType": u8,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("aaa", "null")
let updatePromise = rdbStore.update(valueBucket, predicates)
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_FAIL);
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
await expect(1).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0011 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(1).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(18).assertEqual(age);
await expect(100.5).assertEqual(salary);
await expect(1).assertEqual(blobType[0]);
await expect(2).assertEqual(blobType[1]);
await expect(3).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(true).assertEqual(resultSet.goToNextRow())
const id_1 = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name_1 = await resultSet.getString(resultSet.getColumnIndex("name"))
const age_1 = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary_1 = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType_1 = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(3).assertEqual(id_1);
await expect("wangjing").assertEqual(name_1);
await expect(20).assertEqual(age_1);
await expect(300.5).assertEqual(salary_1);
await expect(7).assertEqual(blobType_1[0]);
await expect(8).assertEqual(blobType_1[1]);
await expect(9).assertEqual(blobType_1[2]);
console.log(TAG + "{id=" + id_1 + ", name=" + name_1 + ", age=" + age_1 + ", salary="
+ salary_1 + ", blobType=" + blobType_1);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0011 end *************");
}
}).catch((err) => {
console.info(TAG + "update with wrong condition");
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0011 error");
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0011 end *************");
})
//await updatePromise
}
})
it('testRdbStoreUpdateWithConflictResolution0012', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0012 start *************");
{
var u8 = new Uint8Array([1, 2, 3])
const valueBucket = {
"id": 1,
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
var u8 = new Uint8Array([4, 5, 6])
const valueBucket = {
"id": 2,
"name": "lisi",
"age": 19,
"salary": 200.5,
"blobType": u8,
}
await rdbStore.insert("test", valueBucket)
}
{
const emptyBucket = {};
const valueBucket = {
"name": "zhangsan",
"age": 20,
"salary": 300.5,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("name", "zhangsan")
await predicates.equalTo("age", 18)
await predicates.equalTo("null", 100.5)
let updatePromise = rdbStore.update(valueBucket, predicates)
await predicates.equalTo("age", "19")
let updatePromise = rdbStore.update(valueBucket, predicates, data_Rdb.ConflictResolution.ON_CONFLICT_FAIL);
updatePromise.then(async (ret) => {
console.info(TAG + "update done: " + ret);
expect(null).assertFail();
await expect(1).assertEqual(ret);
await console.log(TAG + "testRdbStoreUpdateWithConflictResolution0012 done: " + ret);
{
let predicates = await new data_Rdb.RdbPredicates("test")
let resultSet = await rdbStore.query(predicates)
expect(true).assertEqual(resultSet.goToFirstRow())
const id = await resultSet.getLong(resultSet.getColumnIndex("id"))
const name = await resultSet.getString(resultSet.getColumnIndex("name"))
const age = await resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = await resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = await resultSet.getBlob(resultSet.getColumnIndex("blobType"))
await expect(2).assertEqual(id);
await expect("zhangsan").assertEqual(name);
await expect(20).assertEqual(age);
await expect(300.5).assertEqual(salary);
await expect(4).assertEqual(blobType[0]);
await expect(5).assertEqual(blobType[1]);
await expect(6).assertEqual(blobType[2]);
console.log(TAG + "{id=" + id + ", name=" + name + ", age=" + age + ", salary="
+ salary + ", blobType=" + blobType);
await expect(false).assertEqual(resultSet.goToNextRow())
resultSet = null
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0012 end *************");
}
}).catch((err) => {
console.info(TAG + "update with wrong condition");
console.log(TAG + "testRdbStoreUpdateWithConflictResolution0012 error");
done()
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0012 end *************");
})
}
}
done();
console.info(TAG + "************* testRdbStoreUpdate0004 end *************");
})
/**
* @tc.name resultSet Update test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_UpdateWithConflictResolution_0013
* @tc.desc resultSet Update test
*/
it('testRdbStoreUpdateWithConflictResolution0013', 0, async function (done) {
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0013 start *************");
try {
const valueBucket = {
"name": "zhangsan",
"age": 20,
"salary": 300.5,
}
let predicates = await new data_Rdb.RdbPredicates("test")
await predicates.equalTo("age", "19")
rdbStore.update(valueBucket, predicates, 6);
expect(null).assertFail();
} catch (err) {
console.log("catch err: failed, err: code=" + err.code + " message=" + err.message)
expect("401").assertEqual(err.code)
console.log(TAG + "************* testRdbStoreUpdateWithConflictResolution0013 end *************");
done()
}
})
console.info(TAG + "*************Unit Test End*************");
})
console.info(TAG + "*************Unit Test End*************");
})
}
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或