harmony 鸿蒙Batch Database Operations
Batch Database Operations
Using TaskPool for Frequent Database Operations
When dealing with scenarios that require frequent database operations, the time-consuming nature of reading from and writing to the database can lead to UI thread blockages. To mitigate this, you are advised to offload these operations to background threads.
By leveraging the TaskPool capabilities provided by ArkTS, database operations can be efficiently moved to background threads. The implementation involves the following steps:
Create multiple tasks to support various database operations such as creation, insertion, querying, and clearing.
The UI main thread calls these tasks to perform database operations such as adding, deleting, modifying, and querying data.
// Index.ets
import { relationalStore, ValuesBucket } from '@kit.ArkData';
import { taskpool } from '@kit.ArkTS';
@Concurrent
async function create(context: Context) {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
let store: relationalStore.RdbStore = await relationalStore.getRdbStore(context, CONFIG);
console.info(`Create Store.db successfully!`);
// Create a table.
const CREATE_TABLE_SQL = "CREATE TABLE IF NOT EXISTS test (" +
"id INTEGER PRIMARY KEY AUTOINCREMENT, " +
"name TEXT NOT NULL, " +
"age INTEGER, " +
"salary REAL, " +
"blobType BLOB)";
await store.executeSql(CREATE_TABLE_SQL);
console.info(`Create table test successfully!`);
}
@Concurrent
async function insert(context: Context, valueBucketArray: Array<relationalStore.ValuesBucket>) {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
let store: relationalStore.RdbStore = await relationalStore.getRdbStore(context, CONFIG);
console.info(`Create Store.db successfully!`);
// Insert data.
await store.batchInsert("test", valueBucketArray as Object as Array<relationalStore.ValuesBucket>);
}
@Concurrent
async function query(context: Context): Promise<Array<relationalStore.ValuesBucket>> {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
let store: relationalStore.RdbStore = await relationalStore.getRdbStore(context, CONFIG);
console.info(`Create Store.db successfully!`);
// Obtain the result set.
let predicates: relationalStore.RdbPredicates = new relationalStore.RdbPredicates("test");
let resultSet = await store.query(predicates); // Query all data.
console.info(`Query data successfully! row count:${resultSet.rowCount}`);
let index = 0;
let result = new Array<relationalStore.ValuesBucket>(resultSet.rowCount)
resultSet.goToFirstRow()
do {
result[index++] = resultSet.getRow()
} while (resultSet.goToNextRow());
resultSet.close();
return result
}
@Concurrent
async function clear(context: Context) {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
await relationalStore.deleteRdbStore(context, CONFIG);
console.info(`Delete Store.db successfully!`);
}
@Entry
@Component
struct Index {
@State message: string = 'Hello World';
build() {
RelativeContainer() {
Text(this.message)
.id('HelloWorld')
.fontSize(50)
.fontWeight(FontWeight.Bold)
.alignRules({
center: { anchor: '__container__', align: VerticalAlign.Center },
middle: { anchor: '__container__', align: HorizontalAlign.Center }
})
.onClick(async () => {
let context = getContext(this);
// Prepare data.
const count = 5
let valueBucketArray = new Array<relationalStore.ValuesBucket>(count);
for (let i = 0; i < count; i++) {
let v : relationalStore.ValuesBucket = {
id: i,
name: "zhangsan" + i,
age: 20,
salary: 5000 + 50 * i
};
valueBucketArray[i] = v;
}
await taskpool.execute(create, context)
await taskpool.execute(insert, context, valueBucketArray)
let index = 0
let ret = await taskpool.execute(query, context) as Array<relationalStore.ValuesBucket>
for (let v of ret) {
console.info(`Row[${index}].id = ${v.id}`)
console.info(`Row[${index}].name = ${v.name}`)
console.info(`Row[${index}].age = ${v.age}`)
console.info(`Row[${index}].salary = ${v.salary}`)
index++
}
await taskpool.execute(clear, context)
})
}
.height('100%')
.width('100%')
}
}
Using Sendable for Large-Scale Database Operations
When handling large volumes of database data, cross-thread data transfer may still block the UI main thread due to its time-consuming nature. To address this, you are advised to use Sendable to encapsulate database data, thereby reducing cross-thread overhead.
- Define the data format in the database. Sendable can be used to minimize cross-thread latency.
// SharedValuesBucket.ets
export interface IValueBucket {
id: number
name: string
age: number
salary: number
}
@Sendable
export class SharedValuesBucket implements IValueBucket {
id: number = 0
name: string = ""
age: number = 0
salary: number = 0
constructor(v: IValueBucket) {
this.id = v.id;
this.name = v.name;
this.age = v.age;
this.salary = v.salary
}
}
- Initiate from the UI main thread and perform Create, Read, Update, Delete (CRUD) operations in the background thread.
// Index.ets
import { relationalStore, ValuesBucket } from '@kit.ArkData';
import { collections, taskpool } from '@kit.ArkTS';
import { IValueBucket, SharedValuesBucket } from './SharedValuesBucket';
@Concurrent
async function create(context: Context) {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
let store: relationalStore.RdbStore = await relationalStore.getRdbStore(context, CONFIG);
console.info(`Create Store.db successfully!`);
// Create a table.
const CREATE_TABLE_SQL = "CREATE TABLE IF NOT EXISTS test (" +
"id INTEGER PRIMARY KEY AUTOINCREMENT, " +
"name TEXT NOT NULL, " +
"age INTEGER, " +
"salary REAL, " +
"blobType BLOB)";
await store.executeSql(CREATE_TABLE_SQL);
console.info(`Create table test successfully!`);
}
@Concurrent
async function insert(context: Context, valueBucketArray: collections.Array<SharedValuesBucket|undefined>) {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
let store: relationalStore.RdbStore = await relationalStore.getRdbStore(context, CONFIG);
console.info(`Create Store.db successfully!`);
// Insert data.
await store.batchInsert("test", valueBucketArray as Object as Array<ValuesBucket>);
}
@Concurrent
async function query(context: Context): Promise<collections.Array<SharedValuesBucket|undefined>> {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
let store: relationalStore.RdbStore = await relationalStore.getRdbStore(context, CONFIG);
console.info(`Create Store.db successfully!`);
// Obtain the result set.
let predicates: relationalStore.RdbPredicates = new relationalStore.RdbPredicates("test");
let resultSet = await store.query(predicates); // Query all data.
console.info(`Query data successfully! row count:${resultSet.rowCount}`);
let index = 0;
let result = collections.Array.create<SharedValuesBucket|undefined>(resultSet.rowCount, undefined)
resultSet.goToFirstRow()
do {
let v: IValueBucket = {
id: resultSet.getLong(resultSet.getColumnIndex("id")),
name: resultSet.getString(resultSet.getColumnIndex("name")),
age: resultSet.getLong(resultSet.getColumnIndex("age")),
salary: resultSet.getLong(resultSet.getColumnIndex("salary"))
};
result[index++] = new SharedValuesBucket(v)
} while (resultSet.goToNextRow());
resultSet.close();
return result
}
@Concurrent
async function clear(context: Context) {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
await relationalStore.deleteRdbStore(context, CONFIG);
console.info(`Delete Store.db successfully!`);
}
@Entry
@Component
struct Index {
@State message: string = 'Hello World';
build() {
RelativeContainer() {
Text(this.message)
.id('HelloWorld')
.fontSize(50)
.fontWeight(FontWeight.Bold)
.alignRules({
center: { anchor: '__container__', align: VerticalAlign.Center },
middle: { anchor: '__container__', align: HorizontalAlign.Center }
})
.onClick(async () => {
let context = getContext(this);
// Prepare data.
const count = 5
let valueBucketArray = collections.Array.create<SharedValuesBucket|undefined>(count, undefined);
for (let i = 0; i < count; i++) {
let v: IValueBucket = {
id: i,
name: "zhangsan" + i,
age: 20,
salary: 5000 + 50 * i
};
valueBucketArray[i] = new SharedValuesBucket(v);
}
await taskpool.execute(create, context)
await taskpool.execute(insert, context, valueBucketArray)
let index = 0
let ret: collections.Array<SharedValuesBucket> =
await taskpool.execute(query, context) as collections.Array<SharedValuesBucket>
for (let v of ret.values()) {
console.info(`Row[${index}].id = ${v.id}`)
console.info(`Row[${index}].name = ${v.name}`)
console.info(`Row[${index}].age = ${v.age}`)
console.info(`Row[${index}].salary = ${v.salary}`)
index++
}
await taskpool.execute(clear, context)
})
}
.height('100%')
.width('100%')
}
}
Using Sendable for Large-Scale Database Operations with Complex Class Instances
The properties of regular class instances can contain Sendable class instances.
For complex regular class instances, you can first wrap the relevant database data fields in Sendable class instances and then let the regular class instances hold these Sendable class instances. This can help lower the cost of cross-thread operations.
- Define the data format in the database. Sendable can be used to minimize cross-thread latency.
// SharedValuesBucket.ets
export interface IValueBucket {
id: number;
name: string;
age: number;
salary: number;
}
@Sendable
export class SharedValuesBucket implements IValueBucket {
id: number = 0;
name: string = "";
age: number = 0;
salary: number = 0;
constructor(v: IValueBucket) {
this.id = v.id;
this.name = v.name;
this.age = v.age;
this.salary = v.salary;
}
}
- Define a regular class instance to hold the Sendable class instance.
// Material.ets
import { SharedValuesBucket } from './SharedValuesBucket';
import { collections } from '@kit.ArkTS';
export class Material {
seq: number = 0;
materialName: string = "";
//... Other properties are omitted.
buckets: collections.Array<SharedValuesBucket|undefined>;
constructor(seq: number, materialName: string, buckets: collections.Array<SharedValuesBucket|undefined>) {
this.seq = seq;
this.materialName = materialName;
this.buckets = buckets;
}
getBuckets() : collections.Array<SharedValuesBucket|undefined>{
return this.buckets;
}
setBuckets(buckets: collections.Array<SharedValuesBucket|undefined>) {
this.buckets = buckets;
}
}
- Initiate from the UI main thread and perform Create, Read, Update, Delete (CRUD) operations in the background thread.
// Index.ets
import { relationalStore, ValuesBucket } from '@kit.ArkData';
import { collections, taskpool } from '@kit.ArkTS';
import { IValueBucket, SharedValuesBucket } from './SharedValuesBucket';
import { Material } from './Material';
@Concurrent
async function create(context: Context) {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
let store: relationalStore.RdbStore = await relationalStore.getRdbStore(context, CONFIG);
console.info(`Create Store.db successfully!`);
// Create a table.
const CREATE_TABLE_SQL = "CREATE TABLE IF NOT EXISTS test (" +
"id INTEGER PRIMARY KEY AUTOINCREMENT, " +
"name TEXT NOT NULL, " +
"age INTEGER, " +
"salary REAL, " +
"blobType BLOB)";
await store.executeSql(CREATE_TABLE_SQL);
console.info(`Create table test successfully!`);
}
@Concurrent
async function insert(context: Context, valueBucketArray: collections.Array<SharedValuesBucket|undefined>) {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
let store: relationalStore.RdbStore = await relationalStore.getRdbStore(context, CONFIG);
console.info(`Create Store.db successfully!`);
// Insert data.
await store.batchInsert("test", valueBucketArray as Object as Array<ValuesBucket>);
}
@Concurrent
async function query(context: Context): Promise<collections.Array<SharedValuesBucket|undefined>> {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
let store: relationalStore.RdbStore = await relationalStore.getRdbStore(context, CONFIG);
console.info(`Create Store.db successfully!`);
// Obtain the result set.
let predicates: relationalStore.RdbPredicates = new relationalStore.RdbPredicates("test");
let resultSet = await store.query(predicates); // Query all data.
console.info(`Query data successfully! row count:${resultSet.rowCount}`);
let index = 0;
let result = collections.Array.create<SharedValuesBucket|undefined>(resultSet.rowCount, undefined)
resultSet.goToFirstRow()
do {
let v: IValueBucket = {
id: resultSet.getLong(resultSet.getColumnIndex("id")),
name: resultSet.getString(resultSet.getColumnIndex("name")),
age: resultSet.getLong(resultSet.getColumnIndex("age")),
salary: resultSet.getLong(resultSet.getColumnIndex("salary"))
};
result[index++] = new SharedValuesBucket(v)
} while (resultSet.goToNextRow());
resultSet.close();
return result
}
@Concurrent
async function clear(context: Context) {
const CONFIG: relationalStore.StoreConfig = {
name: "Store.db",
securityLevel: relationalStore.SecurityLevel.S1,
};
// The default database file path is context.databaseDir + rdb + StoreConfig.name.
await relationalStore.deleteRdbStore(context, CONFIG);
console.info(`Delete Store.db successfully!`);
}
function initMaterial() : Material {
// Prepare data.
const count = 5
let valueBucketArray = collections.Array.create<SharedValuesBucket|undefined>(count, undefined);
for (let i = 0; i < count; i++) {
let v: IValueBucket = {
id: i,
name: "zhangsan" + i,
age: 20,
salary: 5000 + 50 * i
};
valueBucketArray[i] = new SharedValuesBucket(v);
}
let material = new Material(1, "test", valueBucketArray);
return material;
}
@Entry
@Component
struct Index {
@State message: string = 'Hello World';
build() {
RelativeContainer() {
Text(this.message)
.id('HelloWorld')
.fontSize(50)
.fontWeight(FontWeight.Bold)
.alignRules({
center: { anchor: '__container__', align: VerticalAlign.Center },
middle: { anchor: '__container__', align: HorizontalAlign.Center }
})
.onClick(async () => {
let context = getContext(this);
let material = initMaterial();
await taskpool.execute(create, context);
await taskpool.execute(insert, context, material.getBuckets());
let index = 0;
let ret: collections.Array<SharedValuesBucket> =
await taskpool.execute(query, context) as collections.Array<SharedValuesBucket>;
material.setBuckets(ret);
for (let v of ret.values()) {
console.info(`Row[${index}].id = ${v.id}`);
console.info(`Row[${index}].name = ${v.name}`);
console.info(`Row[${index}].age = ${v.age}`);
console.info(`Row[${index}].salary = ${v.salary}`);
index++;
}
await taskpool.execute(clear, context);
})
}
.height('100%')
.width('100%')
}
}
你可能感兴趣的鸿蒙文章
harmony 鸿蒙Configuring arkOptions in build-profile.json5
harmony 鸿蒙Ark Bytecode File Format
harmony 鸿蒙Naming Conventions for Ark Bytecode Functions
harmony 鸿蒙Ark Bytecode Fundamentals
harmony 鸿蒙Overview of Ark Bytecode
0
赞
- 所属分类： 后端技术
- 本文标签：
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
8、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦