KVUtil建议增加过滤的Entry的方法

async queryEntries(prefix:string, check:(entry:distributedKVStore.Entry) => boolean): Promise<distributedKVStore.Entry[]>{
    if (this.store == null) { this.open() }
    const entries: distributedKVStore.Entry[] = []

const query = new distributedKVStore.Query();
    query.prefixKey(prefix)

this.store.getResultSet(query)
      .then((result: distributedKVStore.KVStoreResultSet) => {
        result.moveToFirst()
        do {
          let entry = result.getEntry()
          if(check(entry)){ entries.push(entry) }
        }while(!result.moveToNext())
      })
      .catch((err: BusinessError) => {
        hilog.error(domainId, logTag, `Failed to get resultset.code is ${err.code},message is ${err.message}`);
      });

return entries
  }

async queryEntriesByKeys(prefix:string, keys:string[]): Promise<distributedKVStore.Entry[]>{
    const entries: distributedKVStore.Entry[] = []
    this.queryEntries(prefix, (entry:distributedKVStore.Entry) => {
      for (let i = 0; i < keys.length; i++) {
        if(keys[i] === entry.key){ return true }
      }
      return false
    })

return entries
  }

桃花镇童长老/harmony-utils

内容风险标识

评论 (0)

桃花镇童长老/harmony-utils .gitee-modal { width: 500px !important; }

内容风险标识