未验证 提交 381508e2 编写于 作者: O openharmony_ci 提交者: Gitee

!22990 8.25 arkts warning

Merge pull request !22990 from maruiqazqaz/master
...@@ -18,6 +18,8 @@ ...@@ -18,6 +18,8 @@
```js ```js
import data_rdb from '@ohos.data.rdb'; import data_rdb from '@ohos.data.rdb';
import { BusinessError } from "@ohos.base"
import window from '@ohos.window';
``` ```
## data_rdb.getRdbStore ## data_rdb.getRdbStore
...@@ -43,11 +45,11 @@ FA模型示例: ...@@ -43,11 +45,11 @@ FA模型示例:
```js ```js
// 获取context // 获取context
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
let context = featureAbility.getContext() let context: Context;
// 获取context后调用getRdbStore // 获取context后调用getRdbStore
const STORE_CONFIG = { name: "RdbTest.db"} const STORE_CONFIG = { name: "RdbTest.db"}
data_rdb.getRdbStore(context, STORE_CONFIG, 1, function (err, rdbStore) { data_rdb.getRdbStore(context, STORE_CONFIG, 1, (err, rdbStore) => {
if (err) { if (err) {
console.info("Get RdbStore failed, err: " + err) console.info("Get RdbStore failed, err: " + err)
return return
...@@ -62,22 +64,23 @@ Stage模型示例: ...@@ -62,22 +64,23 @@ Stage模型示例:
// 获取context // 获取context
import UIAbility from '@ohos.app.ability.UIAbility'; import UIAbility from '@ohos.app.ability.UIAbility';
let context; let context: Context;
class EntryAbility extends UIAbility { interface storeConfig {
onWindowStageCreate(windowStage){ name: string
context = this.context
}
} }
// 获取context后调用getRdbStore class EntryAbility extends UIAbility {
const STORE_CONFIG = { name: "RdbTest.db"} onWindowStageCreate(windowStage: window.WindowStage){
data_rdb.getRdbStore(context, STORE_CONFIG, 1, function (err, rdbStore) { let STORE_CONFIG: storeConfig = { name: "RdbTest.db"};
data_rdb.getRdbStore(this.context, STORE_CONFIG, 1, (err: BusinessError, rdbStore: data_rdb.RdbStore) => {
if (err) { if (err) {
console.info("Get RdbStore failed, err: " + err) console.info("Get RdbStore failed, err: " + err)
return return
} }
console.log("Get RdbStore successfully.") console.log("Get RdbStore successfully.")
}) })
}
}
``` ```
## data_rdb.getRdbStore ## data_rdb.getRdbStore
...@@ -109,7 +112,7 @@ FA模型示例: ...@@ -109,7 +112,7 @@ FA模型示例:
```js ```js
// 获取context // 获取context
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
let context = featureAbility.getContext() let context: Context;
// 获取context后调用getRdbStore // 获取context后调用getRdbStore
const STORE_CONFIG = { name: "RdbTest.db" } const STORE_CONFIG = { name: "RdbTest.db" }
...@@ -127,19 +130,22 @@ Stage模型示例: ...@@ -127,19 +130,22 @@ Stage模型示例:
// 获取context // 获取context
import UIAbility from '@ohos.app.ability.UIAbility'; import UIAbility from '@ohos.app.ability.UIAbility';
let context; let context: Context;
interface storeConfig {
name: string
}
class EntryAbility extends UIAbility { class EntryAbility extends UIAbility {
onWindowStageCreate(windowStage){ onWindowStageCreate(windowStage: window.WindowStage){
context = this.context context = this.context
} }
} }
// 获取context后调用getRdbStore // 获取context后调用getRdbStore
const STORE_CONFIG = { name: "RdbTest.db" } let STORE_CONFIG: storeConfig = { name: "RdbTest.db"};
let promise = data_rdb.getRdbStore(context, STORE_CONFIG, 1); let promise = data_rdb.getRdbStore(context, STORE_CONFIG, 1);
promise.then(async (rdbStore) => { promise.then(async (rdbStore: data_rdb.RdbStore) => {
console.log("Get RdbStore successfully.") console.log("Get RdbStore successfully.")
}).catch((err) => { }).catch((err: BusinessError) => {
console.log("Get RdbStore failed, err: " + err) console.log("Get RdbStore failed, err: " + err)
}) })
``` ```
...@@ -167,10 +173,10 @@ FA模型示例: ...@@ -167,10 +173,10 @@ FA模型示例:
```js ```js
// 获取context // 获取context
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
let context = featureAbility.getContext() let context: Context;
// 获取context后调用deleteRdbStore // 获取context后调用deleteRdbStore
data_rdb.deleteRdbStore(context, "RdbTest.db", function (err) { data_rdb.deleteRdbStore(context, "RdbTest.db", (err) => {
if (err) { if (err) {
console.info("Delete RdbStore failed, err: " + err) console.info("Delete RdbStore failed, err: " + err)
return return
...@@ -185,15 +191,15 @@ Stage模型示例: ...@@ -185,15 +191,15 @@ Stage模型示例:
// 获取context // 获取context
import UIAbility from '@ohos.app.ability.UIAbility'; import UIAbility from '@ohos.app.ability.UIAbility';
let context; let context: Context;
class EntryAbility extends UIAbility { class EntryAbility extends UIAbility {
onWindowStageCreate(windowStage){ onWindowStageCreate(windowStage: window.WindowStage){
context = this.context context = this.context
} }
} }
// 获取context后调用deleteRdbStore // 获取context后调用deleteRdbStore
data_rdb.deleteRdbStore(context, "RdbTest.db", function (err) { data_rdb.deleteRdbStore(context, "RdbTest.db", (err) => {
if (err) { if (err) {
console.info("Delete RdbStore failed, err: " + err) console.info("Delete RdbStore failed, err: " + err)
return return
...@@ -230,7 +236,7 @@ FA模型示例: ...@@ -230,7 +236,7 @@ FA模型示例:
```js ```js
// 获取context // 获取context
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
let context = featureAbility.getContext() let context: Context;
// 获取context后调用deleteRdbStore // 获取context后调用deleteRdbStore
let promise = data_rdb.deleteRdbStore(context, "RdbTest.db") let promise = data_rdb.deleteRdbStore(context, "RdbTest.db")
...@@ -247,9 +253,9 @@ Stage模型示例: ...@@ -247,9 +253,9 @@ Stage模型示例:
// 获取context // 获取context
import UIAbility from '@ohos.app.ability.UIAbility'; import UIAbility from '@ohos.app.ability.UIAbility';
let context; let context: Context;
class EntryAbility extends UIAbility { class EntryAbility extends UIAbility {
onWindowStageCreate(windowStage){ onWindowStageCreate(windowStage: window.WindowStage){
context = this.context context = this.context
} }
} }
...@@ -258,7 +264,7 @@ class EntryAbility extends UIAbility { ...@@ -258,7 +264,7 @@ class EntryAbility extends UIAbility {
let promise = data_rdb.deleteRdbStore(context, "RdbTest.db") let promise = data_rdb.deleteRdbStore(context, "RdbTest.db")
promise.then(()=>{ promise.then(()=>{
console.log("Delete RdbStore successfully.") console.log("Delete RdbStore successfully.")
}).catch((err) => { }).catch((err: BusinessError) => {
console.info("Delete RdbStore failed, err: " + err) console.info("Delete RdbStore failed, err: " + err)
}) })
``` ```
...@@ -371,8 +377,8 @@ inDevices(devices: Array<string>): RdbPredicates ...@@ -371,8 +377,8 @@ inDevices(devices: Array<string>): RdbPredicates
```js ```js
import deviceManager from '@ohos.distributedHardware.deviceManager'; import deviceManager from '@ohos.distributedHardware.deviceManager';
let dmInstance = null; let dmInstance: deviceManager.DeviceManager = null;
let deviceIds = []; let deviceIds: Array<string> = [];
deviceManager.createDeviceManager("com.example.appdatamgrverify", (err, manager) => { deviceManager.createDeviceManager("com.example.appdatamgrverify", (err, manager) => {
if (err) { if (err) {
...@@ -381,7 +387,7 @@ deviceManager.createDeviceManager("com.example.appdatamgrverify", (err, manager) ...@@ -381,7 +387,7 @@ deviceManager.createDeviceManager("com.example.appdatamgrverify", (err, manager)
} }
dmInstance = manager; dmInstance = manager;
let devices = dmInstance.getTrustedDeviceListSync(); let devices = dmInstance.getTrustedDeviceListSync();
for (var i = 0; i < devices.length; i++) { for (let i = 0; i < devices.length; i++) {
deviceIds[i] = devices[i].deviceId; deviceIds[i] = devices[i].deviceId;
} }
}) })
......
...@@ -16,6 +16,10 @@ ...@@ -16,6 +16,10 @@
```js ```js
import relationalStore from '@ohos.data.relationalStore' import relationalStore from '@ohos.data.relationalStore'
import window from '@ohos.window';
import deviceManager from '@ohos.distributedHardware.deviceManager';
import { ValuesBucket } from '@ohos.data.ValuesBucket';
import { BusinessError } from "@ohos.base"
``` ```
## relationalStore.getRdbStore ## relationalStore.getRdbStore
...@@ -54,17 +58,17 @@ FA模型示例: ...@@ -54,17 +58,17 @@ FA模型示例:
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
var store; let store: relationalStore.RdbStore;
// 获取context // 获取context
let context = featureAbility.getContext(); let context = featureAbility.getContext();
const STORE_CONFIG = { const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
relationalStore.getRdbStore(context, STORE_CONFIG, function (err, rdbStore) { relationalStore.getRdbStore(this.context, STORE_CONFIG, (err: BusinessError, rdbStore: relationalStore.RdbStore) => {
store = rdbStore; store = rdbStore;
if (err) { if (err) {
console.error(`Get RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Get RdbStore failed, code is ${err.code},message is ${err.message}`);
...@@ -80,14 +84,14 @@ Stage模型示例: ...@@ -80,14 +84,14 @@ Stage模型示例:
import UIAbility from '@ohos.app.ability.UIAbility' import UIAbility from '@ohos.app.ability.UIAbility'
class EntryAbility extends UIAbility { class EntryAbility extends UIAbility {
onWindowStageCreate(windowStage) { onWindowStageCreate(windowStage: window.WindowStage) {
var store; let store: relationalStore.RdbStore;
const STORE_CONFIG = { const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
relationalStore.getRdbStore(this.context, STORE_CONFIG, function (err, rdbStore) { relationalStore.getRdbStore(this.context, STORE_CONFIG, (err: BusinessError, rdbStore: relationalStore.RdbStore) => {
store = rdbStore; store = rdbStore;
if (err) { if (err) {
console.error(`Get RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Get RdbStore failed, code is ${err.code},message is ${err.message}`);
...@@ -139,21 +143,21 @@ FA模型示例: ...@@ -139,21 +143,21 @@ FA模型示例:
```js ```js
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
var store; let store: relationalStore.RdbStore;
// 获取context // 获取context
let context = featureAbility.getContext(); let context = featureAbility.getContext();
const STORE_CONFIG = { const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
let promise = relationalStore.getRdbStore(context, STORE_CONFIG); let promise = relationalStore.getRdbStore(this.context, STORE_CONFIG);
promise.then(async (rdbStore) => { promise.then(async (rdbStore: relationalStore.RdbStore) => {
store = rdbStore; store = rdbStore;
console.info(`Get RdbStore successfully.`); console.info(`Get RdbStore successfully.`)
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Get RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Get RdbStore failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -164,18 +168,18 @@ Stage模型示例: ...@@ -164,18 +168,18 @@ Stage模型示例:
import UIAbility from '@ohos.app.ability.UIAbility' import UIAbility from '@ohos.app.ability.UIAbility'
class EntryAbility extends UIAbility { class EntryAbility extends UIAbility {
onWindowStageCreate(windowStage) { onWindowStageCreate(windowStage: window.WindowStage) {
var store; let store: relationalStore.RdbStore;
const STORE_CONFIG = { const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
let promise = relationalStore.getRdbStore(this.context, STORE_CONFIG); let promise = relationalStore.getRdbStore(this.context, STORE_CONFIG);
promise.then(async (rdbStore) => { promise.then(async (rdbStore: relationalStore.RdbStore) => {
store = rdbStore; store = rdbStore;
console.info(`Get RdbStore successfully.`) console.info(`Get RdbStore successfully.`)
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Get RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Get RdbStore failed, code is ${err.code},message is ${err.message}`);
}) })
} }
...@@ -216,12 +220,12 @@ FA模型示例: ...@@ -216,12 +220,12 @@ FA模型示例:
```js ```js
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
var store; let store: relationalStore.RdbStore;
// 获取context // 获取context
let context = featureAbility.getContext() let context = featureAbility.getContext()
relationalStore.deleteRdbStore(context, "RdbTest.db", function (err) { relationalStore.deleteRdbStore(this.context, "RdbTest.db", (err: BusinessError) => {
if (err) { if (err) {
console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -236,11 +240,11 @@ Stage模型示例: ...@@ -236,11 +240,11 @@ Stage模型示例:
```ts ```ts
import UIAbility from '@ohos.app.ability.UIAbility' import UIAbility from '@ohos.app.ability.UIAbility'
var store; let store: relationalStore.RdbStore;
class EntryAbility extends UIAbility { class EntryAbility extends UIAbility {
onWindowStageCreate(windowStage){ onWindowStageCreate(windowStage: window.WindowStage){
relationalStore.deleteRdbStore(this.context, "RdbTest.db", function (err) { relationalStore.deleteRdbStore(this.context, "RdbTest.db", (err: BusinessError) => {
if (err) { if (err) {
console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -291,16 +295,16 @@ FA模型示例: ...@@ -291,16 +295,16 @@ FA模型示例:
```js ```js
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
var store; let store: relationalStore.RdbStore;
// 获取context // 获取context
let context = featureAbility.getContext(); let context = featureAbility.getContext();
let promise = relationalStore.deleteRdbStore(context, "RdbTest.db"); let promise = relationalStore.deleteRdbStore(this.context, "RdbTest.db");
promise.then(()=>{ promise.then(()=>{
store = null; store = null;
console.info(`Delete RdbStore successfully.`); console.info(`Delete RdbStore successfully.`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -310,15 +314,15 @@ Stage模型示例: ...@@ -310,15 +314,15 @@ Stage模型示例:
```ts ```ts
import UIAbility from '@ohos.app.ability.UIAbility' import UIAbility from '@ohos.app.ability.UIAbility'
var store; let store: relationalStore.RdbStore;
class EntryAbility extends UIAbility { class EntryAbility extends UIAbility {
onWindowStageCreate(windowStage){ onWindowStageCreate(windowStage: window.WindowStage){
let promise = relationalStore.deleteRdbStore(this.context, "RdbTest.db"); let promise = relationalStore.deleteRdbStore(this.context, "RdbTest.db");
promise.then(()=>{ promise.then(()=>{
store = null; store = null;
console.info(`Delete RdbStore successfully.`); console.info(`Delete RdbStore successfully.`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`);
}) })
} }
...@@ -361,16 +365,16 @@ FA模型示例: ...@@ -361,16 +365,16 @@ FA模型示例:
```js ```js
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
var store; let store: relationalStore.RdbStore;
// 获取context // 获取context
let context = featureAbility.getContext() let context = featureAbility.getContext()
const STORE_CONFIG = { const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
relationalStore.deleteRdbStore(context, STORE_CONFIG, function (err) { relationalStore.deleteRdbStore(this.context, STORE_CONFIG, (err: BusinessError) => {
if (err) { if (err) {
console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -385,15 +389,15 @@ Stage模型示例: ...@@ -385,15 +389,15 @@ Stage模型示例:
```ts ```ts
import UIAbility from '@ohos.app.ability.UIAbility' import UIAbility from '@ohos.app.ability.UIAbility'
var store; let store: relationalStore.RdbStore;
class EntryAbility extends UIAbility { class EntryAbility extends UIAbility {
onWindowStageCreate(windowStage){ onWindowStageCreate(windowStage: window.WindowStage){
const STORE_CONFIG = { const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
relationalStore.deleteRdbStore(this.context, STORE_CONFIG, function (err) { relationalStore.deleteRdbStore(this.context, STORE_CONFIG, (err: BusinessError) => {
if (err) { if (err) {
console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -446,20 +450,20 @@ FA模型示例: ...@@ -446,20 +450,20 @@ FA模型示例:
```js ```js
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
var store; let store: relationalStore.RdbStore;
// 获取context // 获取context
let context = featureAbility.getContext(); let context = featureAbility.getContext();
const STORE_CONFIG = { const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
let promise = relationalStore.deleteRdbStore(context, STORE_CONFIG); let promise = relationalStore.deleteRdbStore(this.context, STORE_CONFIG);
promise.then(()=>{ promise.then(()=>{
store = null; store = null;
console.info(`Delete RdbStore successfully.`); console.info(`Delete RdbStore successfully.`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -469,11 +473,11 @@ Stage模型示例: ...@@ -469,11 +473,11 @@ Stage模型示例:
```ts ```ts
import UIAbility from '@ohos.app.ability.UIAbility' import UIAbility from '@ohos.app.ability.UIAbility'
var store; let store: relationalStore.RdbStore;
class EntryAbility extends UIAbility { class EntryAbility extends UIAbility {
onWindowStageCreate(windowStage){ onWindowStageCreate(windowStage: window.WindowStage){
const STORE_CONFIG = { const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
...@@ -481,7 +485,7 @@ class EntryAbility extends UIAbility { ...@@ -481,7 +485,7 @@ class EntryAbility extends UIAbility {
promise.then(()=>{ promise.then(()=>{
store = null; store = null;
console.info(`Delete RdbStore successfully.`); console.info(`Delete RdbStore successfully.`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`Delete RdbStore failed, code is ${err.code},message is ${err.message}`);
}) })
} }
...@@ -820,13 +824,13 @@ inDevices(devices: Array&lt;string&gt;): RdbPredicates ...@@ -820,13 +824,13 @@ inDevices(devices: Array&lt;string&gt;): RdbPredicates
```js ```js
import deviceManager from '@ohos.distributedDeviceManager'; import deviceManager from '@ohos.distributedDeviceManager';
let dmInstance = null; let dmInstance: deviceManager.DeviceManager = null;
let deviceIds = []; let deviceIds: Array<string> = [];
try { try {
dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify"); dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify");
let devices = dmInstance.getAvailableDeviceListSync(); let devices = dmInstance.getAvailableDeviceListSync();
for (var i = 0; i < devices.length; i++) { for (let i = 0; i < devices.length; i++) {
deviceIds[i] = devices[i].networkId; deviceIds[i] = devices[i].networkId;
} }
} catch (err) { } catch (err) {
...@@ -1640,6 +1644,7 @@ predicates.notIn("NAME", ["Lisa", "Rose"]); ...@@ -1640,6 +1644,7 @@ predicates.notIn("NAME", ["Lisa", "Rose"]);
**示例:** **示例:**
```js ```js
let store: relationalStore.RdbStore;
// 设置数据库版本 // 设置数据库版本
store.version = 3; store.version = 3;
// 获取数据库版本 // 获取数据库版本
...@@ -1674,13 +1679,21 @@ insert(table: string, values: ValuesBucket, callback: AsyncCallback&lt;number&gt ...@@ -1674,13 +1679,21 @@ insert(table: string, values: ValuesBucket, callback: AsyncCallback&lt;number&gt
**示例:** **示例:**
```js ```js
const valueBucket = { let key1 = "NAME";
"NAME": "Lisa", let key2 = "AGE";
"AGE": 18, let key3 = "SALARY";
"SALARY": 100.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Lisa";
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
store.insert("EMPLOYEE", valueBucket, function (err, rowId) { store.insert("EMPLOYEE", valueBucket, (err, rowId) => {
if (err) { if (err) {
console.error(`Insert is failed, code is ${err.code},message is ${err.message}`); console.error(`Insert is failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -1718,13 +1731,21 @@ insert(table: string, values: ValuesBucket, conflict: ConflictResolution, callb ...@@ -1718,13 +1731,21 @@ insert(table: string, values: ValuesBucket, conflict: ConflictResolution, callb
**示例:** **示例:**
```js ```js
const valueBucket = { let key1 = "NAME";
"NAME": "Lisa", let key2 = "AGE";
"AGE": 18, let key3 = "SALARY";
"SALARY": 100.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Lisa";
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
store.insert("EMPLOYEE", valueBucket, relationalStore.ConflictResolution.ON_CONFLICT_REPLACE, function (err, rowId) { store.insert("EMPLOYEE", valueBucket, relationalStore.ConflictResolution.ON_CONFLICT_REPLACE, (err, rowId) => {
if (err) { if (err) {
console.error(`Insert is failed, code is ${err.code},message is ${err.message}`); console.error(`Insert is failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -1766,16 +1787,24 @@ insert(table: string, values: ValuesBucket):Promise&lt;number&gt; ...@@ -1766,16 +1787,24 @@ insert(table: string, values: ValuesBucket):Promise&lt;number&gt;
**示例:** **示例:**
```js ```js
const valueBucket = { let key1 = "NAME";
"NAME": "Lisa", let key2 = "AGE";
"AGE": 18, let key3 = "SALARY";
"SALARY": 100.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Lisa";
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
let promise = store.insert("EMPLOYEE", valueBucket); let promise = store.insert("EMPLOYEE", valueBucket);
promise.then((rowId) => { promise.then((rowId: number) => {
console.info(`Insert is successful, rowId = ${rowId}`); console.info(`Insert is successful, rowId = ${rowId}`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Insert is failed, code is ${err.code},message is ${err.message}`); console.error(`Insert is failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -1814,16 +1843,24 @@ insert(table: string, values: ValuesBucket, conflict: ConflictResolution):Promi ...@@ -1814,16 +1843,24 @@ insert(table: string, values: ValuesBucket, conflict: ConflictResolution):Promi
**示例:** **示例:**
```js ```js
const valueBucket = { let key1 = "NAME";
"NAME": "Lisa", let key2 = "AGE";
"AGE": 18, let key3 = "SALARY";
"SALARY": 100.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Lisa";
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
let promise = store.insert("EMPLOYEE", valueBucket, relationalStore.ConflictResolution.ON_CONFLICT_REPLACE); let promise = store.insert("EMPLOYEE", valueBucket, relationalStore.ConflictResolution.ON_CONFLICT_REPLACE);
promise.then((rowId) => { promise.then((rowId: number) => {
console.info(`Insert is successful, rowId = ${rowId}`); console.info(`Insert is successful, rowId = ${rowId}`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Insert is failed, code is ${err.code},message is ${err.message}`); console.error(`Insert is failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -1856,27 +1893,43 @@ batchInsert(table: string, values: Array&lt;ValuesBucket&gt;, callback: AsyncCal ...@@ -1856,27 +1893,43 @@ batchInsert(table: string, values: Array&lt;ValuesBucket&gt;, callback: AsyncCal
**示例:** **示例:**
```js ```js
const valueBucket1 = { let key1 = "NAME";
"NAME": "Lisa", let key2 = "AGE";
"AGE": 18, let key3 = "SALARY";
"SALARY": 100.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]) let value1 = "Lisa";
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
let value5 = "Jack";
let value6 = 19;
let value7 = 101.5;
let value8 = new Uint8Array([6, 7, 8, 9, 10]);
let value9 = "Tom";
let value10 = 20;
let value11 = 102.5;
let value12 = new Uint8Array([11, 12, 13, 14, 15]);
const valueBucket1: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
const valueBucket2 = { const valueBucket2: ValuesBucket = {
"NAME": "Jack", key1: value5,
"AGE": 19, key2: value6,
"SALARY": 101.5, key3: value7,
"CODES": new Uint8Array([6, 7, 8, 9, 10]) key4: value8,
}; };
const valueBucket3 = { const valueBucket3: ValuesBucket = {
"NAME": "Tom", key1: value9,
"AGE": 20, key2: value10,
"SALARY": 102.5, key3: value11,
"CODES": new Uint8Array([11, 12, 13, 14, 15]) key4: value12,
}; };
let valueBuckets = new Array(valueBucket1, valueBucket2, valueBucket3); let valueBuckets = new Array(valueBucket1, valueBucket2, valueBucket3);
store.batchInsert("EMPLOYEE", valueBuckets, function(err, insertNum) { store.batchInsert("EMPLOYEE", valueBuckets, (err, insertNum) => {
if (err) { if (err) {
console.error(`batchInsert is failed, code is ${err.code},message is ${err.message}`); console.error(`batchInsert is failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -1918,30 +1971,46 @@ batchInsert(table: string, values: Array&lt;ValuesBucket&gt;):Promise&lt;number& ...@@ -1918,30 +1971,46 @@ batchInsert(table: string, values: Array&lt;ValuesBucket&gt;):Promise&lt;number&
**示例:** **示例:**
```js ```js
const valueBucket1 = { let key1 = "NAME";
"NAME": "Lisa", let key2 = "AGE";
"AGE": 18, let key3 = "SALARY";
"SALARY": 100.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]) let value1 = "Lisa";
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
let value5 = "Jack";
let value6 = 19;
let value7 = 101.5;
let value8 = new Uint8Array([6, 7, 8, 9, 10]);
let value9 = "Tom";
let value10 = 20;
let value11 = 102.5;
let value12 = new Uint8Array([11, 12, 13, 14, 15]);
const valueBucket1: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
const valueBucket2 = { const valueBucket2: ValuesBucket = {
"NAME": "Jack", key1: value5,
"AGE": 19, key2: value6,
"SALARY": 101.5, key3: value7,
"CODES": new Uint8Array([6, 7, 8, 9, 10]) key4: value8,
}; };
const valueBucket3 = { const valueBucket3: ValuesBucket = {
"NAME": "Tom", key1: value9,
"AGE": 20, key2: value10,
"SALARY": 102.5, key3: value11,
"CODES": new Uint8Array([11, 12, 13, 14, 15]) key4: value12,
}; };
let valueBuckets = new Array(valueBucket1, valueBucket2, valueBucket3); let valueBuckets = new Array(valueBucket1, valueBucket2, valueBucket3);
let promise = store.batchInsert("EMPLOYEE", valueBuckets); let promise = store.batchInsert("EMPLOYEE", valueBuckets);
promise.then((insertNum) => { promise.then((insertNum: number) => {
console.info(`batchInsert is successful, the number of values that were inserted = ${insertNum}`); console.info(`batchInsert is successful, the number of values that were inserted = ${insertNum}`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`batchInsert is failed, code is ${err.code},message is ${err.message}`); console.error(`batchInsert is failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -1974,11 +2043,19 @@ update(values: ValuesBucket, predicates: RdbPredicates, callback: AsyncCallback& ...@@ -1974,11 +2043,19 @@ update(values: ValuesBucket, predicates: RdbPredicates, callback: AsyncCallback&
**示例:** **示例:**
```js ```js
const valueBucket = { let key1 = "NAME";
"NAME": "Rose", let key2 = "AGE";
"AGE": 22, let key3 = "SALARY";
"SALARY": 200.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Rose";
let value2 = 22;
let value3 = 200.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
...@@ -2020,15 +2097,23 @@ update(values: ValuesBucket, predicates: RdbPredicates, conflict: ConflictResolu ...@@ -2020,15 +2097,23 @@ update(values: ValuesBucket, predicates: RdbPredicates, conflict: ConflictResolu
**示例:** **示例:**
```js ```js
const valueBucket = { let key1 = "NAME";
"NAME": "Rose", let key2 = "AGE";
"AGE": 22, let key3 = "SALARY";
"SALARY": 200.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Rose";
let value2 = 22;
let value3 = 200.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
store.update(valueBucket, predicates, relationalStore.ConflictResolution.ON_CONFLICT_REPLACE, function (err, rows) { store.update(valueBucket, predicates, relationalStore.ConflictResolution.ON_CONFLICT_REPLACE, (err, rows) => {
if (err) { if (err) {
console.error(`Updated failed, code is ${err.code},message is ${err.message}`); console.error(`Updated failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2070,18 +2155,26 @@ update(values: ValuesBucket, predicates: RdbPredicates):Promise&lt;number&gt; ...@@ -2070,18 +2155,26 @@ update(values: ValuesBucket, predicates: RdbPredicates):Promise&lt;number&gt;
**示例:** **示例:**
```js ```js
const valueBucket = { let key1 = "NAME";
"NAME": "Rose", let key2 = "AGE";
"AGE": 22, let key3 = "SALARY";
"SALARY": 200.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Rose";
let value2 = 22;
let value3 = 200.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
let promise = store.update(valueBucket, predicates); let promise = store.update(valueBucket, predicates);
promise.then(async (rows) => { promise.then(async (rows: Number) => {
console.info(`Updated row count: ${rows}`); console.info(`Updated row count: ${rows}`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Updated failed, code is ${err.code},message is ${err.message}`); console.error(`Updated failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -2120,18 +2213,26 @@ update(values: ValuesBucket, predicates: RdbPredicates, conflict: ConflictResolu ...@@ -2120,18 +2213,26 @@ update(values: ValuesBucket, predicates: RdbPredicates, conflict: ConflictResolu
**示例:** **示例:**
```js ```js
const valueBucket = { let key1 = "NAME";
"NAME": "Rose", let key2 = "AGE";
"AGE": 22, let key3 = "SALARY";
"SALARY": 200.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Rose";
let value2 = 22;
let value3 = 200.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
let promise = store.update(valueBucket, predicates, relationalStore.ConflictResolution.ON_CONFLICT_REPLACE); let promise = store.update(valueBucket, predicates, relationalStore.ConflictResolution.ON_CONFLICT_REPLACE);
promise.then(async (rows) => { promise.then(async (rows: Number) => {
console.info(`Updated row count: ${rows}`); console.info(`Updated row count: ${rows}`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Updated failed, code is ${err.code},message is ${err.message}`); console.error(`Updated failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -2170,15 +2271,23 @@ update(table: string, values: ValuesBucket, predicates: dataSharePredicates.Data ...@@ -2170,15 +2271,23 @@ update(table: string, values: ValuesBucket, predicates: dataSharePredicates.Data
```js ```js
import dataSharePredicates from '@ohos.data.dataSharePredicates' import dataSharePredicates from '@ohos.data.dataSharePredicates'
const valueBucket = { let key1 = "NAME";
"NAME": "Rose", let key2 = "AGE";
"AGE": 22, let key3 = "SALARY";
"SALARY": 200.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Rose";
let value2 = 22;
let value3 = 200.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
let predicates = new dataSharePredicates.DataSharePredicates(); let predicates = new dataSharePredicates.DataSharePredicates();
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
store.update("EMPLOYEE", valueBucket, predicates, function (err, rows) { store.update("EMPLOYEE", valueBucket, predicates, (err, rows) => {
if (err) { if (err) {
console.error(`Updated failed, code is ${err.code},message is ${err.message}`); console.error(`Updated failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2226,18 +2335,26 @@ update(table: string, values: ValuesBucket, predicates: dataSharePredicates.Data ...@@ -2226,18 +2335,26 @@ update(table: string, values: ValuesBucket, predicates: dataSharePredicates.Data
```js ```js
import dataSharePredicates from '@ohos.data.dataSharePredicates' import dataSharePredicates from '@ohos.data.dataSharePredicates'
const valueBucket = { let key1 = "NAME";
"NAME": "Rose", let key2 = "AGE";
"AGE": 22, let key3 = "SALARY";
"SALARY": 200.5, let key4 = "CODES";
"CODES": new Uint8Array([1, 2, 3, 4, 5]), let value1 = "Rose";
let value2 = 22;
let value3 = 200.5;
let value4 = new Uint8Array([1, 2, 3, 4, 5]);
const valueBucket: ValuesBucket = {
key1: value1,
key2: value2,
key3: value3,
key4: value4,
}; };
let predicates = new dataSharePredicates.DataSharePredicates(); let predicates = new dataSharePredicates.DataSharePredicates();
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
let promise = store.update("EMPLOYEE", valueBucket, predicates); let promise = store.update("EMPLOYEE", valueBucket, predicates);
promise.then(async (rows) => { promise.then(async (rows: Number) => {
console.info(`Updated row count: ${rows}`); console.info(`Updated row count: ${rows}`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Updated failed, code is ${err.code},message is ${err.message}`); console.error(`Updated failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -2271,7 +2388,7 @@ delete(predicates: RdbPredicates, callback: AsyncCallback&lt;number&gt;):void ...@@ -2271,7 +2388,7 @@ delete(predicates: RdbPredicates, callback: AsyncCallback&lt;number&gt;):void
```js ```js
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
store.delete(predicates, function (err, rows) { store.delete(predicates, (err, rows) => {
if (err) { if (err) {
console.error(`Delete failed, code is ${err.code},message is ${err.message}`); console.error(`Delete failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2315,9 +2432,9 @@ delete(predicates: RdbPredicates):Promise&lt;number&gt; ...@@ -2315,9 +2432,9 @@ delete(predicates: RdbPredicates):Promise&lt;number&gt;
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
let promise = store.delete(predicates); let promise = store.delete(predicates);
promise.then((rows) => { promise.then((rows: Number) => {
console.info(`Delete rows: ${rows}`); console.info(`Delete rows: ${rows}`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Delete failed, code is ${err.code},message is ${err.message}`); console.error(`Delete failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -2357,7 +2474,7 @@ delete(table: string, predicates: dataSharePredicates.DataSharePredicates, callb ...@@ -2357,7 +2474,7 @@ delete(table: string, predicates: dataSharePredicates.DataSharePredicates, callb
import dataSharePredicates from '@ohos.data.dataSharePredicates' import dataSharePredicates from '@ohos.data.dataSharePredicates'
let predicates = new dataSharePredicates.DataSharePredicates(); let predicates = new dataSharePredicates.DataSharePredicates();
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
store.delete("EMPLOYEE", predicates, function (err, rows) { store.delete("EMPLOYEE", predicates, (err, rows) => {
if (err) { if (err) {
console.error(`Delete failed, code is ${err.code},message is ${err.message}`); console.error(`Delete failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2407,9 +2524,9 @@ import dataSharePredicates from '@ohos.data.dataSharePredicates' ...@@ -2407,9 +2524,9 @@ import dataSharePredicates from '@ohos.data.dataSharePredicates'
let predicates = new dataSharePredicates.DataSharePredicates(); let predicates = new dataSharePredicates.DataSharePredicates();
predicates.equalTo("NAME", "Lisa"); predicates.equalTo("NAME", "Lisa");
let promise = store.delete("EMPLOYEE", predicates); let promise = store.delete("EMPLOYEE", predicates);
promise.then((rows) => { promise.then((rows: Number) => {
console.info(`Delete rows: ${rows}`); console.info(`Delete rows: ${rows}`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Delete failed, code is ${err.code},message is ${err.message}`); console.error(`Delete failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -2442,7 +2559,7 @@ query(predicates: RdbPredicates, callback: AsyncCallback&lt;ResultSet&gt;):void ...@@ -2442,7 +2559,7 @@ query(predicates: RdbPredicates, callback: AsyncCallback&lt;ResultSet&gt;):void
```js ```js
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("NAME", "Rose"); predicates.equalTo("NAME", "Rose");
store.query(predicates, function (err, resultSet) { store.query(predicates, (err, resultSet) => {
if (err) { if (err) {
console.error(`Query failed, code is ${err.code},message is ${err.message}`); console.error(`Query failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2490,7 +2607,7 @@ query(predicates: RdbPredicates, columns: Array&lt;string&gt;, callback: AsyncCa ...@@ -2490,7 +2607,7 @@ query(predicates: RdbPredicates, columns: Array&lt;string&gt;, callback: AsyncCa
```js ```js
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("NAME", "Rose"); predicates.equalTo("NAME", "Rose");
store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"], function (err, resultSet) { store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"], (err, resultSet) => {
if (err) { if (err) {
console.error(`Query failed, code is ${err.code},message is ${err.message}`); console.error(`Query failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2544,7 +2661,7 @@ query(predicates: RdbPredicates, columns?: Array&lt;string&gt;):Promise&lt;Resul ...@@ -2544,7 +2661,7 @@ query(predicates: RdbPredicates, columns?: Array&lt;string&gt;):Promise&lt;Resul
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("NAME", "Rose"); predicates.equalTo("NAME", "Rose");
let promise = store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]); let promise = store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((resultSet) => { promise.then((resultSet: relationalStore.ResultSet) => {
console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`); console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`);
// resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。 // resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。
while (resultSet.goToNextRow()) { while (resultSet.goToNextRow()) {
...@@ -2556,7 +2673,7 @@ promise.then((resultSet) => { ...@@ -2556,7 +2673,7 @@ promise.then((resultSet) => {
} }
// 释放数据集的内存 // 释放数据集的内存
resultSet.close(); resultSet.close();
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Query failed, code is ${err.code},message is ${err.message}`); console.error(`Query failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -2595,7 +2712,7 @@ query(table: string, predicates: dataSharePredicates.DataSharePredicates, callba ...@@ -2595,7 +2712,7 @@ query(table: string, predicates: dataSharePredicates.DataSharePredicates, callba
import dataSharePredicates from '@ohos.data.dataSharePredicates' import dataSharePredicates from '@ohos.data.dataSharePredicates'
let predicates = new dataSharePredicates.DataSharePredicates(); let predicates = new dataSharePredicates.DataSharePredicates();
predicates.equalTo("NAME", "Rose"); predicates.equalTo("NAME", "Rose");
store.query("EMPLOYEE", predicates, function (err, resultSet) { store.query("EMPLOYEE", predicates, (err, resultSet) => {
if (err) { if (err) {
console.error(`Query failed, code is ${err.code},message is ${err.message}`); console.error(`Query failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2649,7 +2766,7 @@ query(table: string, predicates: dataSharePredicates.DataSharePredicates, column ...@@ -2649,7 +2766,7 @@ query(table: string, predicates: dataSharePredicates.DataSharePredicates, column
import dataSharePredicates from '@ohos.data.dataSharePredicates' import dataSharePredicates from '@ohos.data.dataSharePredicates'
let predicates = new dataSharePredicates.DataSharePredicates(); let predicates = new dataSharePredicates.DataSharePredicates();
predicates.equalTo("NAME", "Rose"); predicates.equalTo("NAME", "Rose");
store.query("EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"], function (err, resultSet) { store.query("EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"], (err, resultSet) => {
if (err) { if (err) {
console.error(`Query failed, code is ${err.code},message is ${err.message}`); console.error(`Query failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2709,7 +2826,7 @@ import dataSharePredicates from '@ohos.data.dataSharePredicates' ...@@ -2709,7 +2826,7 @@ import dataSharePredicates from '@ohos.data.dataSharePredicates'
let predicates = new dataSharePredicates.DataSharePredicates(); let predicates = new dataSharePredicates.DataSharePredicates();
predicates.equalTo("NAME", "Rose"); predicates.equalTo("NAME", "Rose");
let promise = store.query("EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]); let promise = store.query("EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((resultSet) => { promise.then((resultSet: relationalStore.ResultSet) => {
console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`); console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`);
// resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。 // resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。
while (resultSet.goToNextRow()) { while (resultSet.goToNextRow()) {
...@@ -2721,7 +2838,7 @@ promise.then((resultSet) => { ...@@ -2721,7 +2838,7 @@ promise.then((resultSet) => {
} }
// 释放数据集的内存 // 释放数据集的内存
resultSet.close(); resultSet.close();
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Query failed, code is ${err.code},message is ${err.message}`); console.error(`Query failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -2760,8 +2877,8 @@ remoteQuery(device: string, table: string, predicates: RdbPredicates, columns: A ...@@ -2760,8 +2877,8 @@ remoteQuery(device: string, table: string, predicates: RdbPredicates, columns: A
```js ```js
import deviceManager from '@ohos.distributedDeviceManager'; import deviceManager from '@ohos.distributedDeviceManager';
let dmInstance = null; let dmInstance: deviceManager.DeviceManager = null;
let deviceId = null; let deviceId: string = null;
try { try {
dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify"); dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify");
...@@ -2773,12 +2890,8 @@ try { ...@@ -2773,12 +2890,8 @@ try {
let predicates = new relationalStore.RdbPredicates('EMPLOYEE'); let predicates = new relationalStore.RdbPredicates('EMPLOYEE');
predicates.greaterThan("id", 0); predicates.greaterThan("id", 0);
store.remoteQuery(deviceId, "EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"], let promise = store.remoteQuery(deviceId, "EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
function(err, resultSet) { promise.then((resultSet: relationalStore.ResultSet) => {
if (err) {
console.error(`Failed to remoteQuery, code is ${err.code},message is ${err.message}`);
return;
}
console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`); console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`);
// resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。 // resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。
while (resultSet.goToNextRow()) { while (resultSet.goToNextRow()) {
...@@ -2790,8 +2903,9 @@ store.remoteQuery(deviceId, "EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALAR ...@@ -2790,8 +2903,9 @@ store.remoteQuery(deviceId, "EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALAR
} }
// 释放数据集的内存 // 释放数据集的内存
resultSet.close(); resultSet.close();
} }).catch((err: BusinessError) => {
) console.error(`Failed to remoteQuery, code is ${err.code},message is ${err.message}`);
})
``` ```
### remoteQuery ### remoteQuery
...@@ -2833,8 +2947,8 @@ remoteQuery(device: string, table: string, predicates: RdbPredicates, columns: A ...@@ -2833,8 +2947,8 @@ remoteQuery(device: string, table: string, predicates: RdbPredicates, columns: A
```js ```js
import deviceManager from '@ohos.distributedDeviceManager'; import deviceManager from '@ohos.distributedDeviceManager';
let dmInstance = null; let dmInstance: deviceManager.DeviceManager = null;
let deviceId = null; let deviceId: string = null;
try { try {
dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify"); dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify");
...@@ -2847,7 +2961,7 @@ try { ...@@ -2847,7 +2961,7 @@ try {
let predicates = new relationalStore.RdbPredicates('EMPLOYEE'); let predicates = new relationalStore.RdbPredicates('EMPLOYEE');
predicates.greaterThan("id", 0); predicates.greaterThan("id", 0);
let promise = store.remoteQuery(deviceId, "EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]); let promise = store.remoteQuery(deviceId, "EMPLOYEE", predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((resultSet) => { promise.then((resultSet: relationalStore.ResultSet) => {
console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`); console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`);
// resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。 // resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。
while (resultSet.goToNextRow()) { while (resultSet.goToNextRow()) {
...@@ -2859,7 +2973,7 @@ promise.then((resultSet) => { ...@@ -2859,7 +2973,7 @@ promise.then((resultSet) => {
} }
// 释放数据集的内存 // 释放数据集的内存
resultSet.close(); resultSet.close();
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Failed to remoteQuery, code is ${err.code},message is ${err.message}`); console.error(`Failed to remoteQuery, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -2890,7 +3004,7 @@ querySql(sql: string, callback: AsyncCallback&lt;ResultSet&gt;):void ...@@ -2890,7 +3004,7 @@ querySql(sql: string, callback: AsyncCallback&lt;ResultSet&gt;):void
**示例:** **示例:**
```js ```js
store.querySql("SELECT * FROM EMPLOYEE CROSS JOIN BOOK WHERE BOOK.NAME = 'sanguo'", function (err, resultSet) { store.querySql("SELECT * FROM EMPLOYEE CROSS JOIN BOOK WHERE BOOK.NAME = 'sanguo'", (err, resultSet) => {
if (err) { if (err) {
console.error(`Query failed, code is ${err.code},message is ${err.message}`); console.error(`Query failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2936,7 +3050,7 @@ querySql(sql: string, bindArgs: Array&lt;ValueType&gt;, callback: AsyncCallback& ...@@ -2936,7 +3050,7 @@ querySql(sql: string, bindArgs: Array&lt;ValueType&gt;, callback: AsyncCallback&
**示例:** **示例:**
```js ```js
store.querySql("SELECT * FROM EMPLOYEE CROSS JOIN BOOK WHERE BOOK.NAME = ?", ['sanguo'], function (err, resultSet) { store.querySql("SELECT * FROM EMPLOYEE CROSS JOIN BOOK WHERE BOOK.NAME = ?", ['sanguo'], (err, resultSet) => {
if (err) { if (err) {
console.error(`Query failed, code is ${err.code},message is ${err.message}`); console.error(`Query failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -2988,7 +3102,7 @@ querySql(sql: string, bindArgs?: Array&lt;ValueType&gt;):Promise&lt;ResultSet&gt ...@@ -2988,7 +3102,7 @@ querySql(sql: string, bindArgs?: Array&lt;ValueType&gt;):Promise&lt;ResultSet&gt
```js ```js
let promise = store.querySql("SELECT * FROM EMPLOYEE CROSS JOIN BOOK WHERE BOOK.NAME = 'sanguo'"); let promise = store.querySql("SELECT * FROM EMPLOYEE CROSS JOIN BOOK WHERE BOOK.NAME = 'sanguo'");
promise.then((resultSet) => { promise.then((resultSet: relationalStore.ResultSet) => {
console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`); console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`);
// resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。 // resultSet是一个数据集合的游标,默认指向第-1个记录,有效的数据从0开始。
while (resultSet.goToNextRow()) { while (resultSet.goToNextRow()) {
...@@ -3000,7 +3114,7 @@ promise.then((resultSet) => { ...@@ -3000,7 +3114,7 @@ promise.then((resultSet) => {
} }
// 释放数据集的内存 // 释放数据集的内存
resultSet.close(); resultSet.close();
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Query failed, code is ${err.code},message is ${err.message}`); console.error(`Query failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -3033,7 +3147,7 @@ executeSql(sql: string, callback: AsyncCallback&lt;void&gt;):void ...@@ -3033,7 +3147,7 @@ executeSql(sql: string, callback: AsyncCallback&lt;void&gt;):void
```js ```js
const SQL_DELETE_TABLE = "DELETE FROM test WHERE name = 'zhangsan'" const SQL_DELETE_TABLE = "DELETE FROM test WHERE name = 'zhangsan'"
store.executeSql(SQL_DELETE_TABLE, function(err) { store.executeSql(SQL_DELETE_TABLE, (err) => {
if (err) { if (err) {
console.error(`ExecuteSql failed, code is ${err.code},message is ${err.message}`); console.error(`ExecuteSql failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3071,7 +3185,7 @@ executeSql(sql: string, bindArgs: Array&lt;ValueType&gt;, callback: AsyncCallbac ...@@ -3071,7 +3185,7 @@ executeSql(sql: string, bindArgs: Array&lt;ValueType&gt;, callback: AsyncCallbac
```js ```js
const SQL_DELETE_TABLE = "DELETE FROM test WHERE name = ?" const SQL_DELETE_TABLE = "DELETE FROM test WHERE name = ?"
store.executeSql(SQL_DELETE_TABLE, ['zhangsan'], function(err) { store.executeSql(SQL_DELETE_TABLE, ['zhangsan'], (err) => {
if (err) { if (err) {
console.error(`ExecuteSql failed, code is ${err.code},message is ${err.message}`); console.error(`ExecuteSql failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3117,7 +3231,7 @@ const SQL_DELETE_TABLE = "DELETE FROM test WHERE name = 'zhangsan'" ...@@ -3117,7 +3231,7 @@ const SQL_DELETE_TABLE = "DELETE FROM test WHERE name = 'zhangsan'"
let promise = store.executeSql(SQL_DELETE_TABLE); let promise = store.executeSql(SQL_DELETE_TABLE);
promise.then(() => { promise.then(() => {
console.info(`Delete table done.`); console.info(`Delete table done.`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`ExecuteSql failed, code is ${err.code},message is ${err.message}`); console.error(`ExecuteSql failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -3151,12 +3265,12 @@ getModifyTime(table: string, columnName: string, primaryKeys: PRIKeyType[], call ...@@ -3151,12 +3265,12 @@ getModifyTime(table: string, columnName: string, primaryKeys: PRIKeyType[], call
```js ```js
let PRIKey = [1, 4, 2, 3]; let PRIKey = [1, 4, 2, 3];
store.getModifyTime("cloud_tasks", "uuid", PRIKey, function (err, modifyTime) { store.getModifyTime("cloud_tasks", "uuid", PRIKey, (err, modifyTime: relationalStore.ModifyTime)=> {
if (err) { if (err) {
console.error(`getModifyTime failed, code is ${err.code},message is ${err.message}`); console.error(`getModifyTime failed, code is ${err.code},message is ${err.message}`);
return; return;
} }
let size = modifyTime.size(); let size = modifyTime.size;
}); });
``` ```
...@@ -3194,9 +3308,9 @@ getModifyTime(table: string, columnName: string, primaryKeys: PRIKeyType[]): Pro ...@@ -3194,9 +3308,9 @@ getModifyTime(table: string, columnName: string, primaryKeys: PRIKeyType[]): Pro
```js ```js
let PRIKey = [1, 2, 3]; let PRIKey = [1, 2, 3];
store.getModifyTime("cloud_tasks", "uuid", PRIKey).then((modifyTime) => { store.getModifyTime("cloud_tasks", "uuid", PRIKey).then((modifyTime: relationalStore.ModifyTime) => {
let size = modifyTime.size(); let size = modifyTime.size;
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`getModifyTime failed, code is ${err.code},message is ${err.message}`); console.error(`getModifyTime failed, code is ${err.code},message is ${err.message}`);
}); });
``` ```
...@@ -3223,21 +3337,29 @@ beginTransaction():void ...@@ -3223,21 +3337,29 @@ beginTransaction():void
```js ```js
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
let context = featureAbility.getContext(); let context = featureAbility.getContext();
const STORE_CONFIG = { let key1 = "name";
let key2 = "age";
let key3 = "SALARY";
let key4 = "blobType";
let value1 = "Lisi";
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3]);
const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
relationalStore.getRdbStore(context, STORE_CONFIG, async function (err, store) { relationalStore.getRdbStore(this.context, STORE_CONFIG, async (err, store) => {
if (err) { if (err) {
console.error(`GetRdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`GetRdbStore failed, code is ${err.code},message is ${err.message}`);
return; return;
} }
store.beginTransaction(); store.beginTransaction();
const valueBucket = { const valueBucket: ValuesBucket = {
"name": "lisi", key1: value1,
"age": 18, key2: value2,
"salary": 100.5, key3: value3,
"blobType": new Uint8Array([1, 2, 3]), key4: value4,
}; };
await store.insert("test", valueBucket); await store.insert("test", valueBucket);
store.commit(); store.commit();
...@@ -3257,21 +3379,29 @@ commit():void ...@@ -3257,21 +3379,29 @@ commit():void
```js ```js
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
let context = featureAbility.getContext(); let context = featureAbility.getContext();
const STORE_CONFIG = { let key1 = "name";
let key2 = "age";
let key3 = "SALARY";
let key4 = "blobType";
let value1 = "Lisi";
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3]);
const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
relationalStore.getRdbStore(context, STORE_CONFIG, async function (err, store) { relationalStore.getRdbStore(this.context, STORE_CONFIG, async (err, store) => {
if (err) { if (err) {
console.error(`GetRdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`GetRdbStore failed, code is ${err.code},message is ${err.message}`);
return; return;
} }
store.beginTransaction(); store.beginTransaction();
const valueBucket = { const valueBucket: ValuesBucket = {
"name": "lisi", key1: value1,
"age": 18, key2: value2,
"salary": 100.5, key3: value3,
"blobType": new Uint8Array([1, 2, 3]), key4: value4,
}; };
await store.insert("test", valueBucket); await store.insert("test", valueBucket);
store.commit(); store.commit();
...@@ -3291,23 +3421,30 @@ rollBack():void ...@@ -3291,23 +3421,30 @@ rollBack():void
```js ```js
import featureAbility from '@ohos.ability.featureAbility' import featureAbility from '@ohos.ability.featureAbility'
let context = featureAbility.getContext(); let context = featureAbility.getContext();
const STORE_CONFIG = { let key1 = "name";
let key2 = "age";
let key3 = "SALARY";
let key4 = "blobType";
let value1 = "Lisi";
let value2 = 18;
let value3 = 100.5;
let value4 = new Uint8Array([1, 2, 3]);
const STORE_CONFIG: relationalStore.StoreConfig = {
name: "RdbTest.db", name: "RdbTest.db",
securityLevel: relationalStore.SecurityLevel.S1 securityLevel: relationalStore.SecurityLevel.S1
}; };
relationalStore.getRdbStore(context, STORE_CONFIG, async function (err, store) { relationalStore.getRdbStore(this.context, STORE_CONFIG, async (err, store) => {
if (err) { if (err) {
console.error(`GetRdbStore failed, code is ${err.code},message is ${err.message}`); console.error(`GetRdbStore failed, code is ${err.code},message is ${err.message}`);
return; return;
} }
try { try {
store.beginTransaction() store.beginTransaction()
const valueBucket = { const valueBucket: ValuesBucket = {
"id": 1, key1: value1,
"name": "lisi", key2: value2,
"age": 18, key3: value3,
"salary": 100.5, key4: value4,
"blobType": new Uint8Array([1, 2, 3]),
}; };
await store.insert("test", valueBucket); await store.insert("test", valueBucket);
store.commit(); store.commit();
...@@ -3344,7 +3481,7 @@ backup(destName:string, callback: AsyncCallback&lt;void&gt;):void ...@@ -3344,7 +3481,7 @@ backup(destName:string, callback: AsyncCallback&lt;void&gt;):void
**示例:** **示例:**
```js ```js
store.backup("dbBackup.db", function(err) { store.backup("dbBackup.db", (err) => {
if (err) { if (err) {
console.error(`Backup failed, code is ${err.code},message is ${err.message}`); console.error(`Backup failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3387,7 +3524,7 @@ backup(destName:string): Promise&lt;void&gt; ...@@ -3387,7 +3524,7 @@ backup(destName:string): Promise&lt;void&gt;
let promiseBackup = store.backup("dbBackup.db"); let promiseBackup = store.backup("dbBackup.db");
promiseBackup.then(()=>{ promiseBackup.then(()=>{
console.info(`Backup success.`); console.info(`Backup success.`);
}).catch((err)=>{ }).catch((err: BusinessError)=>{
console.error(`Backup failed, code is ${err.code},message is ${err.message}`); console.error(`Backup failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -3418,7 +3555,7 @@ restore(srcName:string, callback: AsyncCallback&lt;void&gt;):void ...@@ -3418,7 +3555,7 @@ restore(srcName:string, callback: AsyncCallback&lt;void&gt;):void
**示例:** **示例:**
```js ```js
store.restore("dbBackup.db", function(err) { store.restore("dbBackup.db", (err) => {
if (err) { if (err) {
console.error(`Restore failed, code is ${err.code},message is ${err.message}`); console.error(`Restore failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3461,7 +3598,7 @@ restore(srcName:string): Promise&lt;void&gt; ...@@ -3461,7 +3598,7 @@ restore(srcName:string): Promise&lt;void&gt;
let promiseRestore = store.restore("dbBackup.db"); let promiseRestore = store.restore("dbBackup.db");
promiseRestore.then(()=>{ promiseRestore.then(()=>{
console.info(`Restore success.`); console.info(`Restore success.`);
}).catch((err)=>{ }).catch((err: BusinessError)=>{
console.error(`Restore failed, code is ${err.code},message is ${err.message}`); console.error(`Restore failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -3494,7 +3631,7 @@ setDistributedTables(tables: Array&lt;string&gt;, callback: AsyncCallback&lt;voi ...@@ -3494,7 +3631,7 @@ setDistributedTables(tables: Array&lt;string&gt;, callback: AsyncCallback&lt;voi
**示例:** **示例:**
```js ```js
store.setDistributedTables(["EMPLOYEE"], function (err) { store.setDistributedTables(["EMPLOYEE"], (err) => {
if (err) { if (err) {
console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`); console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3539,7 +3676,7 @@ store.setDistributedTables(["EMPLOYEE"], function (err) { ...@@ -3539,7 +3676,7 @@ store.setDistributedTables(["EMPLOYEE"], function (err) {
let promise = store.setDistributedTables(["EMPLOYEE"]); let promise = store.setDistributedTables(["EMPLOYEE"]);
promise.then(() => { promise.then(() => {
console.info(`SetDistributedTables successfully.`); console.info(`SetDistributedTables successfully.`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`); console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -3574,7 +3711,7 @@ setDistributedTables(tables: Array&lt;string&gt;, type: DistributedType, callbac ...@@ -3574,7 +3711,7 @@ setDistributedTables(tables: Array&lt;string&gt;, type: DistributedType, callbac
**示例:** **示例:**
```js ```js
store.setDistributedTables(["EMPLOYEE"], relationalStore.DistributedType.DISTRIBUTED_CLOUD, function (err) { store.setDistributedTables(["EMPLOYEE"], relationalStore.DistributedType.DISTRIBUTED_CLOUD, (err) => {
if (err) { if (err) {
console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`); console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3618,7 +3755,7 @@ setDistributedTables(tables: Array&lt;string&gt;, type: DistributedType, config: ...@@ -3618,7 +3755,7 @@ setDistributedTables(tables: Array&lt;string&gt;, type: DistributedType, config:
```js ```js
store.setDistributedTables(["EMPLOYEE"], relationalStore.DistributedType.DISTRIBUTED_CLOUD, { store.setDistributedTables(["EMPLOYEE"], relationalStore.DistributedType.DISTRIBUTED_CLOUD, {
autoSync: true autoSync: true
}, function (err) { },(err) => {
if (err) { if (err) {
console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`); console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3668,7 +3805,7 @@ let promise = store.setDistributedTables(["EMPLOYEE"], relationalStore.Distribut ...@@ -3668,7 +3805,7 @@ let promise = store.setDistributedTables(["EMPLOYEE"], relationalStore.Distribut
}); });
promise.then(() => { promise.then(() => {
console.info(`SetDistributedTables successfully.`); console.info(`SetDistributedTables successfully.`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`); console.error(`SetDistributedTables failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -3707,8 +3844,8 @@ obtainDistributedTableName(device: string, table: string, callback: AsyncCallbac ...@@ -3707,8 +3844,8 @@ obtainDistributedTableName(device: string, table: string, callback: AsyncCallbac
```js ```js
import deviceManager from '@ohos.distributedDeviceManager'; import deviceManager from '@ohos.distributedDeviceManager';
let dmInstance = null; let dmInstance: deviceManager.DeviceManager = null;
let deviceId = null; let deviceId: string = null;
try { try {
dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify"); dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify");
...@@ -3718,7 +3855,7 @@ try { ...@@ -3718,7 +3855,7 @@ try {
console.error("createDeviceManager errCode:" + err.code + ",errMessage:" + err.message); console.error("createDeviceManager errCode:" + err.code + ",errMessage:" + err.message);
} }
store.obtainDistributedTableName(deviceId, "EMPLOYEE", function (err, tableName) { store.obtainDistributedTableName(deviceId, "EMPLOYEE", (err, tableName) => {
if (err) { if (err) {
console.error(`ObtainDistributedTableName failed, code is ${err.code},message is ${err.message}`); console.error(`ObtainDistributedTableName failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3766,8 +3903,8 @@ store.obtainDistributedTableName(deviceId, "EMPLOYEE", function (err, tableName) ...@@ -3766,8 +3903,8 @@ store.obtainDistributedTableName(deviceId, "EMPLOYEE", function (err, tableName)
```js ```js
import deviceManager from '@ohos.distributedDeviceManager'; import deviceManager from '@ohos.distributedDeviceManager';
let dmInstance = null; let dmInstance: deviceManager.DeviceManager = null;
let deviceId = null; let deviceId: string = null;
try { try {
dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify"); dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify");
...@@ -3778,9 +3915,9 @@ try { ...@@ -3778,9 +3915,9 @@ try {
} }
let promise = store.obtainDistributedTableName(deviceId, "EMPLOYEE"); let promise = store.obtainDistributedTableName(deviceId, "EMPLOYEE");
promise.then((tableName) => { promise.then((tableName: string) => {
console.info(`ObtainDistributedTableName successfully, tableName= ${tableName}`); console.info(`ObtainDistributedTableName successfully, tableName= ${tableName}`);
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`ObtainDistributedTableName failed, code is ${err.code},message is ${err.message}`); console.error(`ObtainDistributedTableName failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -3815,13 +3952,13 @@ sync(mode: SyncMode, predicates: RdbPredicates, callback: AsyncCallback&lt;Array ...@@ -3815,13 +3952,13 @@ sync(mode: SyncMode, predicates: RdbPredicates, callback: AsyncCallback&lt;Array
```js ```js
import deviceManager from '@ohos.distributedDeviceManager'; import deviceManager from '@ohos.distributedDeviceManager';
let dmInstance = null; let dmInstance: deviceManager.DeviceManager = null;
let deviceIds = []; let deviceIds: Array<string> = [];
try { try {
dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify"); dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify");
let devices = dmInstance.getAvailableDeviceListSync(); let devices = dmInstance.getAvailableDeviceListSync();
for (var i = 0; i < devices.length; i++) { for (let i = 0; i < devices.length; i++) {
deviceIds[i] = devices[i].networkId; deviceIds[i] = devices[i].networkId;
} }
} catch (err) { } catch (err) {
...@@ -3830,7 +3967,7 @@ try { ...@@ -3830,7 +3967,7 @@ try {
let predicates = new relationalStore.RdbPredicates('EMPLOYEE'); let predicates = new relationalStore.RdbPredicates('EMPLOYEE');
predicates.inDevices(deviceIds); predicates.inDevices(deviceIds);
store.sync(relationalStore.SyncMode.SYNC_MODE_PUSH, predicates, function (err, result) { store.sync(relationalStore.SyncMode.SYNC_MODE_PUSH, predicates, (err, result) => {
if (err) { if (err) {
console.error(`Sync failed, code is ${err.code},message is ${err.message}`); console.error(`Sync failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3877,13 +4014,13 @@ store.sync(relationalStore.SyncMode.SYNC_MODE_PUSH, predicates, function (err, r ...@@ -3877,13 +4014,13 @@ store.sync(relationalStore.SyncMode.SYNC_MODE_PUSH, predicates, function (err, r
```js ```js
import deviceManager from '@ohos.distributedDeviceManager'; import deviceManager from '@ohos.distributedDeviceManager';
let dmInstance = null; let dmInstance: deviceManager.DeviceManager = null;
let deviceIds = []; let deviceIds: Array<string> = [];
try { try {
dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify"); dmInstance = deviceManager.createDeviceManager("com.example.appdatamgrverify");
let devices = dmInstance.getAvailableDeviceListSync(); let devices = dmInstance.getAvailableDeviceListSync();
for (var i = 0; i < devices.length; i++) { for (let i = 0; i < devices.length; i++) {
deviceIds[i] = devices[i].networkId; deviceIds[i] = devices[i].networkId;
} }
} catch (err) { } catch (err) {
...@@ -3893,12 +4030,12 @@ try { ...@@ -3893,12 +4030,12 @@ try {
let predicates = new relationalStore.RdbPredicates('EMPLOYEE'); let predicates = new relationalStore.RdbPredicates('EMPLOYEE');
predicates.inDevices(deviceIds); predicates.inDevices(deviceIds);
let promise = store.sync(relationalStore.SyncMode.SYNC_MODE_PUSH, predicates); let promise = store.sync(relationalStore.SyncMode.SYNC_MODE_PUSH, predicates);
promise.then((result) =>{ promise.then((result: Object[][]) =>{
console.info(`Sync done.`); console.info(`Sync done.`);
for (let i = 0; i < result.length; i++) { for (let i = 0; i < result.length; i++) {
console.info(`device= ${result[i][0]}, status= ${result[i][1]}`); console.info(`device= ${result[i][0]}, status= ${result[i][1]}`);
} }
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`Sync failed, code is ${err.code},message is ${err.message}`); console.error(`Sync failed, code is ${err.code},message is ${err.message}`);
}) })
``` ```
...@@ -3924,9 +4061,9 @@ cloudSync(mode: SyncMode, progress: Callback&lt;ProgressDetails&gt;, callback: A ...@@ -3924,9 +4061,9 @@ cloudSync(mode: SyncMode, progress: Callback&lt;ProgressDetails&gt;, callback: A
**示例:** **示例:**
```js ```js
store.cloudSync(relationalStore.SyncMode.SYNC_MODE_CLOUD_FIRST, function (progressDetails) { store.cloudSync(relationalStore.SyncMode.SYNC_MODE_CLOUD_FIRST, (progressDetails) => {
console.info(`Progess: ${progressDetails}`); console.info(`Progess: ${progressDetails}`);
}, function (err) { }, (err) =>{
if (err) { if (err) {
console.error(`Cloud sync failed, code is ${err.code},message is ${err.message}`); console.error(`Cloud sync failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -3961,13 +4098,11 @@ cloudSync(mode: SyncMode, progress: Callback&lt;ProgressDetails&gt;): Promise&lt ...@@ -3961,13 +4098,11 @@ cloudSync(mode: SyncMode, progress: Callback&lt;ProgressDetails&gt;): Promise&lt
**示例:** **示例:**
```js ```js
function progress(progressDetail) { store.cloudSync(relationalStore.SyncMode.SYNC_MODE_CLOUD_FIRST, (progressDetail: relationalStore.ProgressDetails) => {
console.info(`progress: ${progressDetail}`); console.info(`progress: ${progressDetail}`);
} }).then(() => {
store.cloudSync(relationalStore.SyncMode.SYNC_MODE_CLOUD_FIRST, progress).then(() => {
console.info('Cloud sync succeeded'); console.info('Cloud sync succeeded');
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`cloudSync failed, code is ${err.code},message is ${err.message}`); console.error(`cloudSync failed, code is ${err.code},message is ${err.message}`);
}); });
``` ```
...@@ -3995,9 +4130,9 @@ cloudSync(mode: SyncMode, tables: string[], progress: Callback&lt;ProgressDetail ...@@ -3995,9 +4130,9 @@ cloudSync(mode: SyncMode, tables: string[], progress: Callback&lt;ProgressDetail
```js ```js
const tables = ["table1", "table2"]; const tables = ["table1", "table2"];
store.cloudSync(relationalStore.SyncMode.SYNC_MODE_CLOUD_FIRST, tables, function (progressDetails) { store.cloudSync(relationalStore.SyncMode.SYNC_MODE_CLOUD_FIRST, tables, (progressDetail: relationalStore.ProgressDetails) => {
console.info(`Progess: ${progressDetails}`); console.info(`Progess: ${progressDetails}`);
}, function (err) { }, (err) => {
if (err) { if (err) {
console.error(`Cloud sync failed, code is ${err.code},message is ${err.message}`); console.error(`Cloud sync failed, code is ${err.code},message is ${err.message}`);
return; return;
...@@ -4034,13 +4169,12 @@ cloudSync(mode: SyncMode, tables: string[], progress: Callback&lt;ProgressDetail ...@@ -4034,13 +4169,12 @@ cloudSync(mode: SyncMode, tables: string[], progress: Callback&lt;ProgressDetail
```js ```js
const tables = ["table1", "table2"]; const tables = ["table1", "table2"];
function progress(progressDetail) {
console.info(`progress: ${progressDetail}`);
}
store.cloudSync(relationalStore.SyncMode.SYNC_MODE_CLOUD_FIRST, tables, progress).then(() => { store.cloudSync(relationalStore.SyncMode.SYNC_MODE_CLOUD_FIRST, (progressDetail: relationalStore.ProgressDetails) => {
console.info(`progress: ${progressDetail}`);
}).then(() => {
console.info('Cloud sync succeeded'); console.info('Cloud sync succeeded');
}).catch((err) => { }).catch((err: BusinessError) => {
console.error(`cloudSync failed, code is ${err.code},message is ${err.message}`); console.error(`cloudSync failed, code is ${err.code},message is ${err.message}`);
}); });
``` ```
...@@ -4064,13 +4198,14 @@ on(event: 'dataChange', type: SubscribeType, observer: Callback&lt;Array&lt;stri ...@@ -4064,13 +4198,14 @@ on(event: 'dataChange', type: SubscribeType, observer: Callback&lt;Array&lt;stri
**示例:** **示例:**
```js ```js
function storeObserver(devices) { try {
store.on('dataChange', relationalStore.SubscribeType.SUBSCRIBE_TYPE_REMOTE, (storeObserver) => {
let devices: string;
for (let i = 0; i < devices.length; i++) { for (let i = 0; i < devices.length; i++) {
console.info(`device= ${devices[i]} data changed`); console.info(`device= ${devices[i]} data changed`);
} }
} }
try { );
store.on('dataChange', relationalStore.SubscribeType.SUBSCRIBE_TYPE_REMOTE, storeObserver);
} catch (err) { } catch (err) {
console.error(`Register observer failed, code is ${err.code},message is ${err.message}`); console.error(`Register observer failed, code is ${err.code},message is ${err.message}`);
} }
...@@ -4135,11 +4270,10 @@ on(event: string, interProcess: boolean, observer: Callback\<void>): void ...@@ -4135,11 +4270,10 @@ on(event: string, interProcess: boolean, observer: Callback\<void>): void
**示例:** **示例:**
```js ```js
function storeObserver() {
console.info(`storeObserver`);
}
try { try {
store.on('storeObserver', false, storeObserver); store.on('storeObserver', false, (storeObserver) => {
console.info(`storeObserver`);
});
} catch (err) { } catch (err) {
console.error(`Register observer failed, code is ${err.code},message is ${err.message}`); console.error(`Register observer failed, code is ${err.code},message is ${err.message}`);
} }
...@@ -4164,13 +4298,14 @@ off(event:'dataChange', type: SubscribeType, observer: Callback&lt;Array&lt;stri ...@@ -4164,13 +4298,14 @@ off(event:'dataChange', type: SubscribeType, observer: Callback&lt;Array&lt;stri
**示例:** **示例:**
``` ```
function storeObserver(devices) { try {
store.off('dataChange', relationalStore.SubscribeType.SUBSCRIBE_TYPE_REMOTE, (storeObserver) => {
let devices: string;
for (let i = 0; i < devices.length; i++) { for (let i = 0; i < devices.length; i++) {
console.info(`device= ${devices[i]} data changed`); console.info(`device= ${devices[i]} data changed`);
} }
} }
try { );
store.off('dataChange', relationalStore.SubscribeType.SUBSCRIBE_TYPE_REMOTE, storeObserver);
} catch (err) { } catch (err) {
console.error(`Unregister observer failed, code is ${err.code},message is ${err.message}`); console.error(`Unregister observer failed, code is ${err.code},message is ${err.message}`);
} }
...@@ -4195,13 +4330,14 @@ off(event:'dataChange', type: SubscribeType, observer?: Callback&lt;Array&lt;str ...@@ -4195,13 +4330,14 @@ off(event:'dataChange', type: SubscribeType, observer?: Callback&lt;Array&lt;str
**示例:** **示例:**
```js ```js
function storeObserver(devices) { try {
store.off('dataChange', relationalStore.SubscribeType.SUBSCRIBE_TYPE_REMOTE, (storeObserver) => {
let devices: string;
for (let i = 0; i < devices.length; i++) { for (let i = 0; i < devices.length; i++) {
console.info(`device= ${devices[i]} data changed`); console.info(`device= ${devices[i]} data changed`);
} }
} }
try { );
store.off('dataChange', relationalStore.SubscribeType.SUBSCRIBE_TYPE_REMOTE, storeObserver);
} catch (err) { } catch (err) {
console.error(`Unregister observer failed, code is ${err.code},message is ${err.message}`); console.error(`Unregister observer failed, code is ${err.code},message is ${err.message}`);
} }
...@@ -4235,11 +4371,11 @@ off(event: string, interProcess: boolean, observer?: Callback\<void>): void ...@@ -4235,11 +4371,11 @@ off(event: string, interProcess: boolean, observer?: Callback\<void>): void
**示例:** **示例:**
```js ```js
function storeObserver() {
console.info(`storeObserver`);
}
try { try {
store.off('storeObserver', false, storeObserver); store.off('storeObserver', false, (storeObserver) => {
console.info(`storeObserver`);
}
);
} catch (err) { } catch (err) {
console.error(`Register observer failed, code is ${err.code},message is ${err.message}`); console.error(`Register observer failed, code is ${err.code},message is ${err.message}`);
} }
...@@ -4283,11 +4419,11 @@ store.emit('storeObserver'); ...@@ -4283,11 +4419,11 @@ store.emit('storeObserver');
首先需要获取resultSet对象。 首先需要获取resultSet对象。
```js ```js
let resultSet = null; let resultSet: relationalStore.ResultSet = null;
let predicates = new relationalStore.RdbPredicates("EMPLOYEE"); let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
predicates.equalTo("AGE", 18); predicates.equalTo("AGE", 18);
let promise = store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]); let promise = store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((result) => { promise.then((result: relationalStore.ResultSet) => {
resultSet = result; resultSet = result;
console.info(`resultSet columnNames: ${resultSet.columnNames}`); console.info(`resultSet columnNames: ${resultSet.columnNames}`);
console.info(`resultSet columnCount: ${resultSet.columnCount}`); console.info(`resultSet columnCount: ${resultSet.columnCount}`);
...@@ -4341,7 +4477,6 @@ getColumnIndex(columnName: string): number ...@@ -4341,7 +4477,6 @@ getColumnIndex(columnName: string): number
**示例:** **示例:**
```js ```js
resultSet.goToFirstRow();
const id = resultSet.getLong(resultSet.getColumnIndex("ID")); const id = resultSet.getLong(resultSet.getColumnIndex("ID"));
const name = resultSet.getString(resultSet.getColumnIndex("NAME")); const name = resultSet.getString(resultSet.getColumnIndex("NAME"));
const age = resultSet.getLong(resultSet.getColumnIndex("AGE")); const age = resultSet.getLong(resultSet.getColumnIndex("AGE"));
...@@ -4415,14 +4550,7 @@ goTo(offset:number): boolean ...@@ -4415,14 +4550,7 @@ goTo(offset:number): boolean
**示例:** **示例:**
```js ```js
let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
let promise= store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((resultSet) => {
resultSet.goTo(1); resultSet.goTo(1);
resultSet.close();
}).catch((err) => {
console.error(`query failed, code is ${err.code},message is ${err.message}`);
});
``` ```
### goToRow ### goToRow
...@@ -4456,14 +4584,7 @@ goToRow(position: number): boolean ...@@ -4456,14 +4584,7 @@ goToRow(position: number): boolean
**示例:** **示例:**
```js ```js
let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
let promise = store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((resultSet) => {
resultSet.goToRow(5); resultSet.goToRow(5);
resultSet.close();
}).catch((err) => {
console.error(`query failed, code is ${err.code},message is ${err.message}`);
});
``` ```
### goToFirstRow ### goToFirstRow
...@@ -4492,14 +4613,7 @@ goToFirstRow(): boolean ...@@ -4492,14 +4613,7 @@ goToFirstRow(): boolean
**示例:** **示例:**
```js ```js
let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
let promise = store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((resultSet) => {
resultSet.goToFirstRow(); resultSet.goToFirstRow();
resultSet.close();
}).catch((err) => {
console.error(`query failed, code is ${err.code},message is ${err.message}`);
});
``` ```
### goToLastRow ### goToLastRow
...@@ -4527,14 +4641,7 @@ goToLastRow(): boolean ...@@ -4527,14 +4641,7 @@ goToLastRow(): boolean
**示例:** **示例:**
```js ```js
let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
let promise = store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((resultSet) => {
resultSet.goToLastRow(); resultSet.goToLastRow();
resultSet.close();
}).catch((err) => {
console.error(`query failed, code is ${err.code},message is ${err.message}`);
});
``` ```
### goToNextRow ### goToNextRow
...@@ -4562,14 +4669,7 @@ goToNextRow(): boolean ...@@ -4562,14 +4669,7 @@ goToNextRow(): boolean
**示例:** **示例:**
```js ```js
let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
let promise = store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((resultSet) => {
resultSet.goToNextRow(); resultSet.goToNextRow();
resultSet.close();
}).catch((err) => {
console.error(`query failed, code is ${err.code},message is ${err.message}`);
});
``` ```
### goToPreviousRow ### goToPreviousRow
...@@ -4597,14 +4697,7 @@ goToPreviousRow(): boolean ...@@ -4597,14 +4697,7 @@ goToPreviousRow(): boolean
**示例:** **示例:**
```js ```js
let predicates = new relationalStore.RdbPredicates("EMPLOYEE");
let promise = store.query(predicates, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promise.then((resultSet) => {
resultSet.goToPreviousRow(); resultSet.goToPreviousRow();
resultSet.close();
}).catch((err) => {
console.error(`query failed, code is ${err.code},message is ${err.message}`);
});
``` ```
### getBlob ### getBlob
...@@ -4857,13 +4950,7 @@ close(): void ...@@ -4857,13 +4950,7 @@ close(): void
**示例:** **示例:**
```js ```js
let predicatesClose = new relationalStore.RdbPredicates("EMPLOYEE");
let promiseClose = store.query(predicatesClose, ["ID", "NAME", "AGE", "SALARY", "CODES"]);
promiseClose.then((resultSet) => {
resultSet.close(); resultSet.close();
}).catch((err) => {
console.error(`resultset close failed, code is ${err.code},message is ${err.message}`);
});
``` ```
**错误码:** **错误码:**
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册