[Android] 【Codelabs挑战赛示例讲解2】核酸检测结果认证查询系统-数据导入与查询

dependencies {
  //agc-core的依赖
  implementation 'com.huawei.agconnect:agconnect-core:1.6.0.300'
  implementation 'androidx.appcompat:appcompat:1.3.0'
  implementation 'com.google.android.material:material:1.3.0'
  implementation 'androidx.constraintlayout:constraintlayout:2.0.4'
  testImplementation 'junit:junit:4.+'
  androidTestImplementation 'androidx.test.ext:junit:1.1.3'
  androidTestImplementation 'androidx.test.espresso:espresso-core:3.4.0'
  //云数据库sdk
  implementation 'com.huawei.agconnect:agconnect-cloud-database:1.4.9.300'
  compile 'com.github.huangyanbin:SmartTable:2.0'
}

//初始化数据库
AGConnectCloudDB mCloudDB;
//初始化数据库配置
CloudDBZoneConfig mConfig;
//初始化存储区
CloudDBZone mCloudDBZone;
//初始化表格
private SmartTable table;
//云端数据对象List
private static List<personInfo> personInfoList = new ArrayList<>();

private void initView() {
  //初始化云数据库
  AGConnectCloudDB.initialize(getApplicationContext());
  AGConnectInstance instance = AGConnectInstance.buildInstance(new AGConnectOptionsBuilder().setRoutePolicy(AGCRoutePolicy.CHINA).build(getApplicationContext()));
  mCloudDB = AGConnectCloudDB.getInstance(instance, AGConnectAuth.getInstance(instance));
  Log.i(TAG,"The cloudDB is" + mCloudDB);
  try {
    mCloudDB.createObjectType(model.ObjectTypeInfoHelper.getObjectTypeInfo());
    mConfig = new CloudDBZoneConfig("personInfoZone",
    CloudDBZoneConfig.CloudDBZoneSyncProperty.CLOUDDBZONE_CLOUD_CACHE,
    CloudDBZoneConfig.CloudDBZoneAccessProperty.CLOUDDBZONE_PUBLIC);
    mConfig.setPersistenceEnabled(true);
    Task<CloudDBZone> openDBZoneTask = mCloudDB.openCloudDBZone2(mConfig, true);
    openDBZoneTask.addOnSuccessListener(new OnSuccessListener<CloudDBZone>() {
      @Override
      public void onSuccess(CloudDBZone cloudDBZone) {
        Log.i("open clouddbzone", "open cloudDBZone success");
        mCloudDBZone = cloudDBZone;
        //开始绑定数据
        bindData();
        // Add subscription after opening cloudDBZone success
        //addSubscription();
      }
    }).addOnFailureListener(new OnFailureListener() {
      @Override
      public void onFailure(Exception e) {
        Log.w("open clouddbzone", "open cloudDBZone failed for " + e.getMessage());
      }
    });
  } catch (AGConnectCloudDBException e) {
    Toast.makeText(DatabaseActivity.this, "initialize CloudDB failed" + e, Toast.LENGTH_LONG).show();
  }
}

private void bindData() {
  CloudDBZoneQuery<personInfo> query = CloudDBZoneQuery.where(personInfo.class);
  queryPersonInfo(query);
}

private List<personInfo> queryPersonInfo(CloudDBZoneQuery<personInfo> query) {
  if (mCloudDBZone == null) {
    Log.w(TAG, "CloudDBZone is null, try re-open it");
    return null;
  }
  Task<CloudDBZoneSnapshot<personInfo>> queryTask = mCloudDBZone.executeQuery(query,
    CloudDBZoneQuery.CloudDBZoneQueryPolicy.POLICY_QUERY_FROM_CLOUD_ONLY);
  //List<personInfo> tmpInfoList = new ArrayList<>();
  queryTask.addOnSuccessListener(new OnSuccessListener<CloudDBZoneSnapshot<personInfo>>() {
    @Override
    public void onSuccess(CloudDBZoneSnapshot<personInfo> snapshot) {
      try {
        personInfoList = processQueryResult(snapshot);
      } catch (AGConnectCloudDBException e) {
        Log.e(TAG, "onfailed: "+e.getErrMsg() );
      }
      Log.i(TAG, "onSuccess: query result success");
    }
  }).addOnFailureListener(new OnFailureListener() {
    @Override
    public void onFailure(Exception e) {
      mUiCallBack.updateUiOnError("Query failed");
      Log.i(TAG, "onSuccess: query result failed");
    }
  });
  return personInfoList;
}

private List<personInfo> processQueryResult(CloudDBZoneSnapshot<personInfo> snapshot) throws AGConnectCloudDBException {
  CloudDBZoneObjectList<personInfo> bookInfoCursor = snapshot.getSnapshotObjects();
  List<personInfo> bookInfoList = new ArrayList<>();
  List<PersonInfo> list = new ArrayList<>();
  table = findViewById(R.id.table);
  try {
    while (bookInfoCursor.hasNext()) {
      personInfo info = bookInfoCursor.next();
      bookInfoList.add(info);
      list.add(new PersonInfo(info.getId(),info.getName(),info.getAge(),info.getHasInoculate()==true?"是":"否",info.getCardNo()));
      //list.add(new PersonInfo(1,"xuhao",34,true,"12321"));
    }
  } catch (AGConnectCloudDBException e) {
    Log.w(TAG, "processQueryResult: " + e.getMessage());
  } finally {
    snapshot.release();
    mCloudDB.closeCloudDBZone(mCloudDBZone);
  }
  table.setData(list);
  table.getConfig().setContentStyle(new FontStyle(50, Color.BLUE));
  mUiCallBack.onAddOrQuery(bookInfoList);
  return bookInfoList;
}

findViewById(R.id.login_out).setOnClickListener(new View.OnClickListener() {
  @Override
  public void onClick(View view) {
    AGConnectAuth.getInstance().signOut();
    Intent intent = new Intent();
    intent.setClass(DatabaseActivity.this, LoginActivity.class);
    startActivity(intent);
    Log.i(TAG, "onClick: log out successfully");
  }
});