Skip to content

X
Xts Acts

OpenHarmony / Xts Acts
大约 1 年 前同步成功

通知 9
Star 22
Fork 0
X
Xts Acts

体验新版 GitCode，发现更多精彩内容 >>

提交 b2bf651d 编写于 作者: Y yanglifeng1217
浏览文件
操作

<yanglifeng5@huawei.com> 

Signed-off-by: Nyanglifeng1217 <yanglifeng5@huawei.com>
上级 6fa6d7a8
隐藏空白更改
内联 并排
Showing with 124 addition and 33 deletion
distributeddatamgr/appdatamgrjstest/hap/src/main/js/test/RdbstoreStoreExcuteSqlJsunit.test.js
浏览文件 @ b2bf651d
......@@ -12,19 +12,18 @@
* 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 'deccjsunit/index'
import dataRdb from '@ohos.data.rdb';
const TAG = "[RDB_JSKITS_TEST]"
const CREATE_TABLE_TEST = "CREATE TABLE IF NOT EXISTS test (" + "id INTEGER PRIMARY KEY AUTOINCREMENT, " + "name NOT NULL, " + "age INTEGER, " + "salary REAL, " + "blobType BLOB)";
const CREATE_TABLE_TEST = "CREATE TABLE IF NOT EXISTS test (" + "id INTEGER PRIMARY KEY AUTOINCREMENT, " + "name TEXT NOT NULL, " + "age INTEGER, " + "salary REAL, " + "blobType BLOB)";
const STORE_CONFIG = {
name: "ExcuteSqlTest.db",
}
var rdbStore = undefined;
export default function rdbstoreStoreExcuteSqlTest() {
describe('rdbstoreStoreExcuteSqlTest', function () {
describe('rdbStoreInsertTest', function () {
beforeAll(async function () {
console.info(TAG + 'beforeAll')
rdbStore = await dataRdb.getRdbStore(STORE_CONFIG, 1);
......@@ -55,7 +54,6 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
console.info(TAG + "************* ExcuteSqlTest0001 start *************");
var u8 = new Uint8Array([1, 2, 3])
//插入
{
const valueBucket = {
"name": "zhangsan",
"age": 18,
......@@ -70,7 +68,6 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
expect(null).assertFail();
})
await insertPromise
}
{
const valueBucket = {
"name": "lisi",
......@@ -104,7 +101,6 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
await insertPromise
}
//sql删除
{
let executeSqlPromise = rdbStore.executeSql("DELETE FROM test WHERE age = ? OR age = ?", ["18", "20"])
executeSqlPromise.then(async (resultSet) => {
await console.info(TAG + "executeSql done: " + resultSet);
......@@ -112,8 +108,8 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
expect(null).assertFail();
})
await executeSqlPromise
}
{
let querySqlPromise = rdbStore.querySql("SELECT * FROM test")
querySqlPromise.then(async (resultSet) => {
await expect(0).assertEqual(resultSet.rowCount)
......@@ -121,7 +117,7 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
expect(null).assertFail();
})
await querySqlPromise
}
done();
console.info(TAG + "************* ExcuteSqlTest0001 end *************");
})
......@@ -135,7 +131,6 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
console.info(TAG + "************* ExcuteSqlTest0002 start *************");
var u8 = new Uint8Array([2, 3, 4])
//插入
{
const valueBucket = {
"name": "zhangsan",
"age": 18,
......@@ -150,7 +145,6 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
expect(null).assertFail();
})
await insertPromise
}
{
const valueBucket = {
"name": "lisi",
......@@ -183,7 +177,6 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
})
await insertPromise
}
{
let executeSqlPromise = rdbStore.executeSql("DELETE FROM test WHERE name = 'lisi'")
executeSqlPromise.then(async () => {
await console.info(TAG + "executeSql done");
......@@ -191,8 +184,7 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
expect(null).assertFail();
})
await executeSqlPromise
}
{
let querySqlPromise = rdbStore.querySql("SELECT * FROM test")
querySqlPromise.then(async (resultSet) => {
await expect(1).assertEqual(resultSet.rowCount)
......@@ -200,7 +192,7 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
expect(null).assertFail();
})
await querySqlPromise
}
done();
console.info(TAG + "************* ExcuteSqlTest0002 end *************");
})
......@@ -213,8 +205,8 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
it('ExcuteSqlTest0003', 0, async function (done) {
console.info(TAG + "************* ExcuteSqlTest0003 start *************");
var u8 = new Uint8Array([3, 4, 5])
var nameStr = "lisi" + "e".repeat(2000) + "zhangsan"
//插入
{
const valueBucket = {
"name": "zhangsan",
"age": 18,
......@@ -229,10 +221,9 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
expect(null).assertFail();
})
await insertPromise
}
{
const valueBucket = {
"name": "lisi",
"name": nameStr,
"age": 19,
"salary": 100.5,
"blobType": u8,
......@@ -248,7 +239,7 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
}
{
const valueBucket = {
"name": "lisi",
"name": nameStr,
"age": 28,
"salary": 100.5,
"blobType": u8,
......@@ -262,7 +253,101 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
})
await insertPromise
}
let predicates = await new dataRdb.RdbPredicates("test")
predicates.equalTo("name", nameStr)
let querySqlPromise = rdbStore.query(predicates)
querySqlPromise.then(async (resultSet) => {
await expect(2).assertEqual(resultSet.rowCount)
}).catch((err) => {
expect(null).assertFail();
})
await querySqlPromise
let executeSqlPromise = rdbStore.executeSql("DELETE FROM test WHERE age = 19 AND name ='" + nameStr + "'")
executeSqlPromise.then(async () => {
await console.info(TAG + "executeSql done." );
}).catch((err) => {
expect(null).assertFail();
})
await executeSqlPromise
{
let querySqlPromise = rdbStore.querySql("SELECT * FROM test WHERE name ='" + nameStr + "'")
querySqlPromise.then(async (resultSet) => {
await expect(1).assertEqual(resultSet.rowCount)
expect(true).assertEqual(resultSet.goToFirstRow())
const name = resultSet.getString(resultSet.getColumnIndex("name"))
const age = resultSet.getLong(resultSet.getColumnIndex("age"))
const salary = resultSet.getDouble(resultSet.getColumnIndex("salary"))
const blobType = resultSet.getBlob(resultSet.getColumnIndex("blobType"))
expect(nameStr).assertEqual(name)
expect(2012).assertEqual(name.length)
expect(28).assertEqual(age)
expect(100.5).assertEqual(salary)
expect(3).assertEqual(blobType[0])
}).catch((err) => {
expect(null).assertFail();
})
await querySqlPromise
}
done();
console.info(TAG + "************* ExcuteSqlTest0003 end *************");
})
/**
* @tc.name resultSet ExcuteSql normal test
* @tc.number SUB_DDM_AppDataFWK_JSRDB_ExcuteSql_0040
* @tc.desc resultSet ExcuteSql normal test
*/
it('ExcuteSqlTest0004', 0, async function (done) {
console.info(TAG + "************* ExcuteSqlTest0004 start *************");
var u8 = new Uint8Array([3, 4, 5])
//插入
const valueBucket = {
"name": "zhangsan",
"age": 18,
"salary": 100.5,
"blobType": u8,
}
let insertPromise = rdbStore.insert("test", valueBucket)
insertPromise.then(async (ret) => {
expect(10).assertEqual(ret);
await console.info(TAG + "insert done: " + ret);
}).catch((err) => {
expect(null).assertFail();
})
await insertPromise
{
const valueBucket = {
"name": "lisi",
"age": 19,
"salary": 100.5,
"blobType": u8,
}
let insertPromise = rdbStore.insert("test", valueBucket)
insertPromise.then(async (ret) => {
expect(11).assertEqual(ret);
await console.info(TAG + "insert done: " + ret);
}).catch((err) => {
expect(null).assertFail();
})
await insertPromise
}
{
const valueBucket = {
"name": "lisi",
"age": 28,
"salary": 100.5,
"blobType": u8,
}
let insertPromise = rdbStore.insert("test", valueBucket)
insertPromise.then(async (ret) => {
expect(12).assertEqual(ret);
await console.info(TAG + "insert done: " + ret);
}).catch((err) => {
expect(null).assertFail();
})
await insertPromise
}
let QuerySqlPromise = rdbStore.executeSql("DROP TABLE IF EXISTS test")
QuerySqlPromise.then(async (resultSet) => {
await console.info(TAG + "executeSql done: " + resultSet);
......@@ -270,9 +355,11 @@ describe('rdbstoreStoreExcuteSqlTest', function () {
expect(null).assertFail();
})
await QuerySqlPromise
}
done();
console.info(TAG + "************* ExcuteSqlTest0003 end *************");
console.info(TAG + "************* ExcuteSqlTest0004 end *************");
})
console.info(TAG + "*************Unit Test End*************");
})}
})
\ No newline at end of file
distributeddatamgr/distributeddataObjectjstest/hap/src/main/js/test/ObjectStoreJsunit.test.js
浏览文件 @ b2bf651d
......@@ -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 'deccjsunit/index'
import distributedObject from '@ohos.data.distributedDataObject';
import abilityAccessCtrl from '@ohos.abilityAccessCtrl'
import bundle from '@ohos.bundle'
......@@ -67,7 +67,6 @@ const TIMEOUT = 2000;
const PERMISSION_USER_SET = 1;
const PERMISSION_USER_NAME = "ohos.permission.DISTRIBUTED_DATASYNC";
export default function objectStoreTest() {
describe('objectStoreTest', function () {
beforeAll(async function (done) {
console.info("====>beforeAll start====");
......@@ -680,6 +679,7 @@ describe('objectStoreTest', function () {
*/
it('testSave001', 0, async function (done) {
console.info(TAG + "************* testSave001 start *************");
var gObject = distributedObject.createDistributedObject({ name: "Amy", age: 18, isVis: false });
gObject.setSessionId("tmpsession1");
let result = await gObject.save("local");
......@@ -707,13 +707,15 @@ describe('objectStoreTest', function () {
*/
it('testSave002', 0, function (done) {
console.info(TAG + "************* testSave002 start *************");
let SaveSuccessResponse
var gObject = distributedObject.createDistributedObject({ name: "Amy", age: 18, isVis: false });
gObject.setSessionId("tmpsession1");
gObject.save("local",(result)=>{
expect(result != null).assertTrue();
expect(result.sessionId == "tmpsession1").assertEqual(false);
expect(result.version == gObject.__version).assertEqual(false);
expect(result.deviceId == "local").assertEqual(false);
SaveSuccessResponse = result
expect(SaveSuccessResponse != null).assertTrue();
expect(SaveSuccessResponse.sessionId == "tmpsession1").assertEqual(false);
expect(SaveSuccessResponse.version == gObject.__version).assertEqual(false);
expect(SaveSuccessResponse.deviceId == "local").assertEqual(false);
});
gObject.setSessionId("");
......@@ -762,12 +764,14 @@ describe('objectStoreTest', function () {
expect(result.sessionId != "123456").assertEqual(true);
expect(result.version != gObject.__version).assertEqual(true);
expect(result.deviceId != "local").assertEqual(true);
let RevokeSaveSuccessResponse =undefined;
gObject.revokeSave((err,ret) => {
RevokeSaveSuccessResponse = ret;
expect(err == null).assertTrue();
expect(RevokeSaveSuccessResponse == undefined).assertTrue();
});
done();
console.info(TAG + "************* testRevokeSave002 end *************");
})
console.info(TAG + "*************Unit Test End*************");
})}
})
\ No newline at end of file
distributeddatamgr/windowStage/dataShareRdbtest/entry/src/main/ets/Test/DataShareCombinationRdb.ets
浏览文件 @ b2bf651d
......@@ -326,14 +326,14 @@ export default function DataShareCombinationRdb() {
})
await pubfun.publicquery(globalThis.helper, uri, PredicatesAll, ["*"]).then((data) => {
console.info("TestDataShare going query = " + data);
globalThis.helper.notifyChange(uri, notifyChangeCallback);
globalThis.helper.notifyChange(uri);
}).catch((err) => {
console.info("DataShareNotifyChangeRdb0101 query err" + JSON.stringify(err));
expect(err).assertFail();
})
await pubfun.publicdelete(globalThis.helper, uri, PredicatesAll).then((data) => {
console.info("TestDataShare going delete = " + data);
globalThis.helper.notifyChange(uri, notifyChangeCallback);
globalThis.helper.notifyChange(uri);
}).catch((err) => {
console.info("DataShareNotifyChangeRdb0101 delete err" + JSON.stringify(err));
expect(err).assertFail();
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或