HarmonyOS 鸿蒙Next数据持久化之关系型数据库

HarmonyOS 鸿蒙Next数据持久化之关系型数据库

指南：

• https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/data-persistence-by-rdb-store
• 关系型数据库备份: https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/data-backup-and-restore# 关系型数据库备份
• 关系型数据库异常重建: https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/data-backup-and-restore# 关系型数据库异常重建
• 关系型数据库数据恢复: https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/data-backup-and-restore# 关系型数据库数据恢复

封装工具：

class dBUtils {
  private rdbStore: relationalStore.RdbStore | null = null

  /**
   * 初始化数据库
   * @param context  上下文对象
   * @param tableName 创建的表格名字
   */
  initDB(context: Context, tableName: string) {
    // (1) 初始化数据库配置
    const STORE_CONFIG: relationalStore.StoreConfig = {
      name: 'xxx.db', // 数据库文件名
      securityLevel: relationalStore.SecurityLevel.S1, // 数据库安全级别
    }
    // (2) 定义sql语句
    const SQL_CREATE_TABLE = `CREATE TABLE IF NOT EXISTS ${tableName} (
      ID INTEGER PRIMARY KEY AUTOINCREMENT,
      NAME TEXT NOT NULL,
      BIG_LOGO TEXT,
      CODE TEXT,
      PRICE REAL,
      COUNT INTEGER,
      CHECKED INTEGER)`
    // (3) 初始化数据库(getRdbStore异步)
    relationalStore.getRdbStore(context, STORE_CONFIG, (err, store) => {
      if (err) {
        console.log(`获取RdbStore失败，Code:${err.code},message:${err.message}`)
        return
      } else {
        console.log(`获取RdbStore成功`);
        this.rdbStore = store
        // 有了数据库，就可以创建表格
        store.executeSql(SQL_CREATE_TABLE, (error) => {
          if (!error) {
            console.log(`${tableName}创建成功`);
          } else {
            console.log('创建失败')
            return
          }
        })
      }
    })
  }

  /**
   * 添加数据到数据库
   * @param tableName
   * @value 要添加的数据
   */
  insertDataDB(tableName: string, value: relationalStore.ValuesBucket) {
    if (this.rdbStore !== null) {
      this.rdbStore.insert(tableName, value, (err: BusinessError, rowId: number) => {
        if (err) {
          console.log(`往${tableName}中添加数据失败,${err.name}---${err.code}---${err.message}`)
          return
        }

        console.log(`往${tableName}中添加数据成功，rowId:${rowId}`)
      })
    }
  }

  /**
   *
   * @param column  投影列['ID','NAME']
   * @param tableName
   */
  async queryDataDB(column: Array<string>, tableName: string, id?: number) {
    // 获取要操作的对象
    let predicates = new relationalStore.RdbPredicates(tableName)
    // 筛选条件
    if (id) {
      predicates.equalTo('ID', id)
    }
    // 查询到的所有对象
    let carts: CartModel[] = []
    // 查询数据得到一个结果集，需要想办法将结果集转化为CartModel
    const resultSet = await (this.rdbStore as relationalStore.RdbStore).query(predicates, column)
    // goToNextRow判断结果集是否往下指向下一个数据
    // ORM:对象和数据库进行数据转换
    while (resultSet.goToNextRow()) {
      // getColumnIndex找到数据库中指定某一行的列明
      // getString 指定列的值获取到
      let id = resultSet.getLong(resultSet.getColumnIndex('ID'))
      let name = resultSet.getString(resultSet.getColumnIndex('NAME'))
      let big_log = resultSet.getString(resultSet.getColumnIndex('BIG_LOG'))
      let code = resultSet.getString(resultSet.getColumnIndex('CODE'))
      let price = resultSet.getDouble(resultSet.getColumnIndex('PRICE'))
      let count = resultSet.getLong(resultSet.getColumnIndex('COUNT'))
      let checked = resultSet.getLong(resultSet.getColumnIndex('CHECKED'))

      const temp: CartModel = new CartModel()
      temp.id = id
      temp.name = name
      temp.big_logo = big_log
      temp.code = code
      temp.price = price
      temp.count = count
      temp.checked = checked

      carts.push(temp)
    }

    resultSet.close()

    return carts
  }

  /**
   *删除指定的数据，购物车移出
   * @param tableName
   * @param id
   */
  deleteById(tableName: string, id: number) {
    // 获取要操作的对象
    let predicates = new relationalStore.RdbPredicates(tableName)
    // 筛选条件
    predicates.equalTo('ID', id)
    if (this.rdbStore !== null) {
      this.rdbStore.delete(predicates, (err: BusinessError, rows: number) => {
        if (err) {
          console.log(`Failed to delete data . Code:${err.code},message:${err.message}`)
          return
        } else {
          console.log(`Delete rows:${rows}`)
        }
      })
    }
  }

  /**
   *
   * @param tableName  表名
   * @param id   修改商品编号
   * @param value  修改字段
   * return rows  影响行
   */
  updateById(tableName: string, id: number, value: relationalStore.ValuesBucket) {
    // 获取要操作的对象
    let predicates = new relationalStore.RdbPredicates(tableName)
    // 筛选条件
    predicates.equalTo('ID', id)
    if (this.rdbStore !== null) {
      this.rdbStore.update(value, predicates, (err: BusinessError, rows: number) => {
        if (err) {
          console.log(`Failed to delete data . Code:${err.code},message:${err.message}`)
          return
        } else {
          console.log(`Delete rows:${rows}`)
        }
      })
    }
  }
}

const dBUtils = new dBUtils()

export { dBUtils }

Abiltuty中

onWindowStageCreate(windowStage: window.WindowStage): void {
    // 加载在数据库
    cartDBUtils.initDB(this.context,'tableName')
}

页面中使用

//  insert
addCart=()=>{
    // 构造一个数据结构
    const valueBucket:relationalStore.ValuesBucket={
      NAME:this.detail.name,
      BIG_LOGO:this.detail.big_logo,
      CODE:this.detail.id,
      PRICE:Number(this.detail.price),
      COUNT:1,
      CHECKED:0
    }
    // 调用数据库，保存数据
    dBUtils.insertDataDB('tableName',valueBucket)
}

//query

fetchDBData=async ()=>{
  const res= await dBUtils.queryDataDB(
    ['ID','NAME','BIG_LOGO','PRICE','COUNT','CHECKED'],
    'tableName'
  )
  this.carts=res
}


aboutToAppear(): void {
  this.fetchDBData()
}

// update
const updateColumn:relationalStore.ValuesBucket={
  COUNT:(this.item.goods_count as number)
}
dBUtils.updateById('tableName',Number(this.item.id),updateColumn)