HarmonyOS鸿蒙Next中如何在taskpool开启的线程内进行关系型数据库的批量插入操作

context需要传入到线程中。TaskPool和Worker的底层模型为Actor模型，基于Actor模型的内存隔离特性，执行多线程任务和取得结果需要通过跨线程序列化传输。目前支持传输的数据对象可以分为普通对象、可转移对象、可共享对象、Native绑定对象、Sendable对象五种。

EntryAbility.ets

import { AbilityConstant, UIAbility, Want } from '@kit.AbilityKit';
import { hilog } from '@kit.PerformanceAnalysisKit';
import { window } from '@kit.ArkUI';
import Dbutil from '../common/DbUtil';

const TABLE_NAME: string = "EMPLOYEE"
const CREATE_TABLE_SQL: string = `
 CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (
   ID INTEGER PRIMARY KEY AUTOINCREMENT,
   NAME TEXT NOT NULL,
   AGE INTEGER NOT NULL,
   SALARY DOUBLE NOT NULL
 )
`

export default class EntryAbility extends UIAbility {
  async onCreate(want: Want, launchParam: AbilityConstant.LaunchParam): Promise<void> {
    hilog.info(0x0000, 'testTag', '%{public}s', 'Ability onCreate');
    await Dbutil.initDB(this.context)
    Dbutil.createTable(CREATE_TABLE_SQL)
  }

  onDestroy(): void {
    hilog.info(0x0000, 'testTag', '%{public}s', 'Ability onDestroy');
  }

  onWindowStageCreate(windowStage: window.WindowStage): void {
    // Main window is created, set main page for this ability
    hilog.info(0x0000, 'testTag', '%{public}s', 'Ability onWindowStageCreate');

    windowStage.loadContent('pages/Index5', (err) => {
      if (err.code) {
        hilog.error(0x0000, 'testTag', 'Failed to load the content. Cause: %{public}s', JSON.stringify(err) ?? '');
        return;
      }
      hilog.info(0x0000, 'testTag', 'Succeeded in loading the content.');
    });
  }

  onWindowStageDestroy(): void {
    // Main window is destroyed, release UI related resources
    hilog.info(0x0000, 'testTag', '%{public}s', 'Ability onWindowStageDestroy');
  }

  onForeground(): void {
    // Ability has brought to foreground
    hilog.info(0x0000, 'testTag', '%{public}s', 'Ability onForeground');
  }

  onBackground(): void {
    // Ability has back to background
    hilog.info(0x0000, 'testTag', '%{public}s', 'Ability onBackground');
  }
}

DbUtil.ets

import relationalStore from '@ohos.data.relationalStore'
import { ColumnInfo, ColumnType } from '../common/ColumnInfo'
import { BusinessError } from '@kit.BasicServicesKit'
import { ValuesBucket, ValueType } from '@kit.ArkData'

const DB_FILENAME: string = 'testMySql.db'

class DbUtil {
  rdbStore: relationalStore.RdbStore | undefined = undefined

  initDB(context: Context): Promise<void> {
    let config: relationalStore.StoreConfig = {
      name: DB_FILENAME,
      securityLevel: relationalStore.SecurityLevel.S1
    }
    return new Promise((resolve, reject) => {
      relationalStore.getRdbStore(context, config)
        .then(rdbStore => {
          this.rdbStore = rdbStore
          console.debug('rdbStore 初始化完成！')
          resolve()
        })
        .catch(err => {
          console.error('rdbStore 初始化异常', JSON.stringify(err))
          reject(err)
        })
    })
  }

  isInited() {
    return !!this.rdbStore
  }

  createTable(sql: string): Promise<void> {
    return new Promise((resolve, reject) => {
      if (this.rdbStore){
        this.rdbStore.executeSql(sql)
          .then(() => {
            console.debug('创建成功', sql)
            resolve()
          })
          .catch(err => {
            console.error('创建失败,' + err.message, JSON.stringify(err))
          })
      }
    })
  }

  async insertTest(tableName: string, value: ValuesBucket): Promise<number> {
    return await new Promise((resolve, reject) => {
      console.debug('insertTest1111')
      if (!this.rdbStore) return
      console.debug('insertTest2222')
      this.rdbStore.insert(tableName, value, (err, id) => {
        if (err) {
          console.error('新增失败！', JSON.stringify(err))
          reject(err)
        } else {
          console.debug('新增成功！新增id：', id.toString())
          resolve(id)
        }
      })
    })
  }

  queryForListPrint(tableName: string){
    let predicates = new relationalStore.RdbPredicates(tableName);
    predicates.equalTo("NAME", "Rose");
    if(this.rdbStore != undefined) {
      (this.rdbStore as relationalStore.RdbStore).query(predicates, ["ID", "NAME", "AGE", "SALARY"]).then(resultSet => {
        console.info(`ResultSet column names: ${resultSet.columnNames}, column count: ${resultSet.columnCount}`);
        // resultSet是一个数据集合的游标，默认指向第-1个记录，有效的数据从0开始。
        while (resultSet.goToNextRow()) {
          const id = resultSet.getLong(resultSet.getColumnIndex("ID"));
          const name = resultSet.getString(resultSet.getColumnIndex("NAME"));
          const age = resultSet.getLong(resultSet.getColumnIndex("AGE"));
          const salary = resultSet.getDouble(resultSet.getColumnIndex("SALARY"));
          console.info(`id=${id}, name=${name}, age=${age}, salary=${salary}`);
        }
        // 释放数据集的内存
        resultSet.close();
      }).catch(err => {
        console.error(`Query failed, code is ${err.code},message is ${err.message}`);
      })
    }
  }
}

const dbUtil: DbUtil = new DbUtil()

export default dbUtil as DbUtil