OpenHarmony-v5.1.0-Release/s

/*
 * Copyright (c) 2023 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

import data_rdb from '@ohos.data.relationalStore'
import common from '@ohos.app.ability.common'
import Contact from '../model/Contact'
import Logger from '../model/Logger'
import { STORE_CONFIG, TABLE_NAME, TYPE_INSERT, TYPE_UPDATE, TYPE_DELETE } from '../model/RdbConst'
import { ValuesBucket } from '@ohos.data.ValuesBucket';

const TAG = 'RdbModel'

export default class RdbModel {
  private rdbStore: data_rdb.RdbStore | undefined = undefined
  private tableName: string = ''
  private sqlCreateTable: string = ''
  private columns: Array<string> = []
  private distributedTable: string = ''
  private dataChangeCallback: Function | null = null
  private dataChangeDetailCallback: Function | null = null
  private isCreateDbDone: boolean = false
  private context: common.UIAbilityContext

  constructor(tableName: string, sqlCreateTable: string, columns: Array<string>, context: common.UIAbilityContext) {
    this.tableName = tableName
    this.sqlCreateTable = sqlCreateTable
    this.columns = columns
    this.context = context

    this.getRdbStore()
  }

  // 初始化数据库
  async getRdbStore() {
    Logger.info(TAG, 'getRdbStore begin')
    if (this.isCreateDbDone) {
      Logger.info(TAG, 'getRdbStore isCreateDbDone')
      return
    }
    try {
      // 获取数据库存储对象
      this.rdbStore = await data_rdb.getRdbStore(this.context, STORE_CONFIG);
    } catch (err) {
      console.info(`getRdbStore err ${JSON.stringify(err)}`);
    }
    Logger.info(TAG, 'getRdbStore end')
    try {
      // 执行sql语句，联系人个各个属性设定
      if (this.rdbStore != undefined) {
        await this.rdbStore.executeSql(this.sqlCreateTable)
        console.info(`create tabe start ` + this.sqlCreateTable);
        // 设置分布式表，表明为contact
        await this.rdbStore.setDistributedTables([this.tableName])
      }
    } catch (e) {
      Logger.error(TAG, 'getRdbStore:' + JSON.stringify(e))
    }
    // 分布式数据库创建为完成
    this.isCreateDbDone = true
    Logger.info(TAG, 'create table done')
  }

  async insertData(contact: Contact) {
    let value1 = contact.name;
    let value2 = contact.gender;
    let value3 = contact.phone;
    let value4 = contact.remark;
    let value5 = contact.age;

    const valueBucket: ValuesBucket = {
      'name': value1,
      'gender': value2,
      'phone': value3,
      'remark': value4,
      'age': value5,
    }
    if (this.rdbStore != undefined) {
      let ret = await this.rdbStore.insert(this.tableName, valueBucket, data_rdb.ConflictResolution.ON_CONFLICT_REPLACE)
      Logger.info(TAG, `insert done:${ret}`)
    }
  }

  async updateData(contact: Contact) {
    let value1 = contact.name;
    let value2 = contact.gender;
    let value3 = contact.phone;
    let value4 = contact.remark;
    let value5 = contact.age;

    const valueBucket: ValuesBucket = {
      'name': value1,
      'gender': value2,
      'phone': value3,
      'remark': value4,
      'age': value5,
    }
    let predicates = new data_rdb.RdbPredicates(this.tableName)
    Logger.info(TAG, `updateData id=${contact.id}`)
    predicates.equalTo('id', contact.id)
    if (this.rdbStore != undefined) {
      let ret = await this.rdbStore.update(valueBucket, predicates)
      Logger.info(TAG, `updated row count: ${ret}`)
    }
  }

  async deleteContacts(contacts: Array<Contact>) {
    let predicates = new data_rdb.RdbPredicates(this.tableName)
    contacts.forEach((contact) => {
      predicates.or()
        .equalTo('id', contact.id)
    })
    if (this.rdbStore != undefined) {
      let rows = await this.rdbStore.delete(predicates)
      Logger.info(TAG, `delete rows: ${rows}`)
    }
  }

  async query(predicates: data_rdb.RdbPredicates): Promise<Array<Contact>> {
    Logger.info(TAG, 'query start')
    Logger.info(TAG, 'predicates is ' + JSON.stringify(predicates))
    Logger.info(TAG, 'columns ' + JSON.stringify(this.columns))

    if (this.rdbStore != undefined) {
      // 默认查询所有列
      let resultSet: data_rdb.ResultSet = await this.rdbStore.query(predicates, this.columns);
      Logger.info(TAG, 'result is ' + JSON.stringify(resultSet.rowCount))
      // 处理查询到的结果数组
      return this.getListFromResultSet(resultSet)
    }
    return []
  }

  async syncData(predicates: data_rdb.RdbPredicates) {
    Logger.info(TAG, 'syncData')
    if (this.rdbStore != undefined) {
      let result = await this.rdbStore.sync(data_rdb.SyncMode.SYNC_MODE_PUSH, predicates)
      for (let i = 0; i < result.length; i++) {
        Logger.info(TAG, `device=${result[i][0]}, status = ${result[i][1]}`)
      }
    }
  }

  async onDataChange(device: string, callback: Function) {
    Logger.info(TAG, `onDataChange enter，device=` + device + ` ,tableName = ` + this.tableName)
    try {
      if (this.rdbStore != undefined) {
        this.distributedTable = await this.rdbStore.obtainDistributedTableName(device, this.tableName)
        Logger.info(TAG, `obtainDistributedTableName,distributedTable=` + this.distributedTable)
      }
    } catch (err) {
      Logger.error(TAG, `ObtainDistributedTableName failed, code is ${err.code},message is ${err.message}`)
    }
    this.dataChangeCallback = callback
    await this.pullData()
    if (this.rdbStore != undefined) {
      this.rdbStore.on('dataChange', data_rdb.SubscribeType.SUBSCRIBE_TYPE_REMOTE, async (devices) => {
        Logger.info(TAG, `on dataChange, callback`)
        await this.pullData()
      })
    }
  }

  async onDataChangeDetail(device: string, callback: Function) {
    Logger.info(TAG, `onDataChangeDetail enter，device=` + device + ` ,tableName = ` + this.tableName);
    try {
      if (this.rdbStore != undefined) {
        this.distributedTable = await this.rdbStore.obtainDistributedTableName(device, this.tableName);
        Logger.info(TAG, `obtainDistributedTableName,distributedTable=` + this.distributedTable);
      }
    } catch (err) {
      Logger.error(TAG, `ObtainDistributedTableName failed, code is ${err.code},message is ${err.message}`);
    }
    this.dataChangeDetailCallback = callback;
    if (this.rdbStore != undefined) {
      this.rdbStore.on('dataChange', data_rdb.SubscribeType.SUBSCRIBE_TYPE_LOCAL_DETAILS, async (changeInfo: Array<data_rdb.ChangeInfo>) => {
        Logger.info(TAG, `on dataChange SUBSCRIBE_TYPE_REMOTE, callback`);
        Logger.info(TAG, `on dataChange SUBSCRIBE_TYPE_REMOTE =` + JSON.stringify(changeInfo));
        await this.pullDataDetail(changeInfo);
      })
    }
  }

  async pullData() {
    Logger.info(TAG, `start pullData`)
    if (this.rdbStore != undefined) {
      await this.rdbStore.executeSql('delete from ' + this.tableName)
      let predicates = new data_rdb.RdbPredicates(this.distributedTable)
      let resultSet = await this.rdbStore.query(predicates, this.columns)
      let result = this.getListFromResultSet(resultSet)
      Logger.info(TAG, `on dataChange,result.length=${result.length}`)
      for (let i = 0; i < result.length; i++) {
        Logger.info(TAG, `on dataChange,insert${result[i].name}`)
        let predicate = new data_rdb.RdbPredicates(this.tableName)
        predicate.equalTo('name', result[i].name)
        let exit = await this.rdbStore.query(predicate, this.columns)
        exit.goToFirstRow()
        if (exit.rowCount === 0) {
          await this.insertData(result[i])
        } else {
          result[i].id = exit.getDouble(resultSet.getColumnIndex('id'))
          await this.updateData(result[i])
        }
      }
      if (this.dataChangeCallback != null) {
        this.dataChangeCallback(result)
      }
    }
  }

  async pullDataDetail(changeInfo: Array<data_rdb.ChangeInfo>) {
    Logger.info(TAG, `start pullDataDetail`);
    if (this.rdbStore != undefined) {
      if (changeInfo.length > 0) {
        let result: Contact[] = [];
        for (let i = 0; i < changeInfo.length; i++) {
          let table: string = changeInfo[i].table;
          if (table !== TABLE_NAME) {
            return;
          }
          let inserted: Array<string> | Array<number> = changeInfo[i].inserted;
          let updated: Array<string> | Array<number> = changeInfo[i].updated;
          let deleted: Array<string> | Array<number> = changeInfo[i].deleted;
          if (inserted.length > 0) {
            let insertData: Contact[] = await this.getDetailByType(inserted, TYPE_INSERT);
            insertData.forEach(element => {
              result.push(element);
            });
          }
          if (updated.length > 0) {
            let updateData: Contact[] = await this.getDetailByType(updated, TYPE_UPDATE);
            updateData.forEach(element => {
              result.push(element);
            });
          }
          if (deleted.length > 0) {
            for (let index = 0; index < deleted.length; index++) {
              result.push(new Contact(deleted[index] as number, '', 0, '', 0, '', TYPE_DELETE));
            }
          }
        }
        Logger.info(TAG, `result:` + JSON.stringify(result));
        if (this.dataChangeDetailCallback !== null) {
          this.dataChangeDetailCallback(result);
        }
      }
    }
  }

  async getDetailByType(id: Array<string> | Array<number>, type: string): Promise<Array<Contact>> {
    let predicates = new data_rdb.RdbPredicates(TABLE_NAME);
    predicates.in('id', id);
    let aData = await this.query(predicates);
    Logger.info(TAG, `type:${type}`);
    Logger.info(TAG, `aData:` + JSON.stringify(aData));
    if (aData.length > 0) {
      for (let i = 0; i < aData.length; i++) {
        aData[i].type = type;
      }
    }
    return aData;
  }

  offDataChange() {
    if (this.rdbStore != undefined) {
      this.rdbStore.off('dataChange', data_rdb.SubscribeType.SUBSCRIBE_TYPE_REMOTE, (devices) => {
        for (let i = 0; i < devices.length; i++) {
          Logger.info(TAG, `device=${devices[i]} off data changed`)
        }
      })
    }
  }

  offDataChangeDetail() {
    if (this.rdbStore != undefined) {
      this.rdbStore.off('dataChange', data_rdb.SubscribeType.SUBSCRIBE_TYPE_LOCAL_DETAILS, (devices) => {
        for (let i = 0; i < devices.length; i++) {
          Logger.info(TAG, `device=${devices[i]} off data changed`)
        }
      })
    }
  }

  // 处理数据格式
  getListFromResultSet(resultSet: data_rdb.ResultSet): Contact[] {
    // 声明结果变量
    let contacts: Contact[] = []
    // 进入结果集的第一行
    resultSet.goToFirstRow()
    // 如果没有结束就继续遍历
    while (!resultSet.isEnded) {
      // 读取各个属性，初始化临时变量contact
      let contact: Contact = new Contact(resultSet.getDouble(resultSet.getColumnIndex('id'))
        , resultSet.getString(resultSet.getColumnIndex('name'))
        , resultSet.getDouble(resultSet.getColumnIndex('gender'))
        , resultSet.getString(resultSet.getColumnIndex('phone'))
        , resultSet.getLong(resultSet.getColumnIndex('age'))
        , resultSet.getString(resultSet.getColumnIndex('remark')))
      if (!contacts.includes(contact)) {
        // 如果数据集合中没有这条数据就添加进去
        contacts.push(contact)
      }
      // 进入下一行
      resultSet.goToNextRow()
    }
    // 数据整合完毕就释放资源
    resultSet.close()
    Logger.info(TAG, 'contacts number is ' + contacts.length)
    // 返回整合的联系人数据
    return contacts
  }
}