Home
last modified time | relevance | path

Searched refs:pkColNames (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_sync_utils.cpp24 int CloudSyncUtils::GetCloudPkVals(const VBucket &datum, const std::vector<std::string> &pkColNames… in GetCloudPkVals() argument
31 for (const auto &pkColName : pkColNames) { in GetCloudPkVals()
63 bool CloudSyncUtils::IsSinglePrimaryKey(const std::vector<std::string> &pkColNames) in IsSinglePrimaryKey() argument
65 return pkColNames.size() == 1 && pkColNames[0] != CloudDbConstant::ROW_ID_FIELD_NAME; in IsSinglePrimaryKey()
68 …udSyncUtils::RemoveDataExceptExtendInfo(VBucket &datum, const std::vector<std::string> &pkColNames) in RemoveDataExceptExtendInfo() argument
79 (std::find(pkColNames.begin(), pkColNames.end(), key) == pkColNames.end())) { in RemoveDataExceptExtendInfo()
H A Dcloud_sync_utils.h35 …static int GetCloudPkVals(const VBucket &datum, const std::vector<std::string> &pkColNames, int64_…
42 …static void RemoveDataExceptExtendInfo(VBucket &datum, const std::vector<std::string> &pkColNames);
H A Dicloud_syncer.h69 std::vector<std::string> pkColNames; member
H A Dcloud_syncer.cpp790 param.downloadData.data[idx], param.pkColNames, dataInfo.localInfo.logInfo.dataKey, pkVals); in HandleTagAssets()
820 int ret = PreHandleData(param.downloadData.data[idx], param.pkColNames); in SaveDatum()
1014 param.changedData.field = param.pkColNames; in SaveDataInTransaction()
1041 int ret = DownloadAssets(param.info, param.pkColNames, param.dupHashKeySet, changedAssets); in DoDownloadAssets()
1387 int CloudSyncer::PreHandleData(VBucket &datum, const std::vector<std::string> &pkColNames) in PreHandleData() argument
1414 CloudSyncUtils::RemoveDataExceptExtendInfo(datum, pkColNames); in PreHandleData()
2030 …ret = storageProxy_->GetPrimaryColNamesWithAssetsFields(param.tableName, param.pkColNames, assetFi… in GetSyncParamForDownload()
2039 param.isSinglePrimaryKey = CloudSyncUtils::IsSinglePrimaryKey(param.pkColNames); in GetSyncParamForDownload()
H A Dcloud_syncer.h198 int PreHandleData(VBucket &datum, const std::vector<std::string> &pkColNames);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_db_proxy_test.cpp888 const std::vector<std::string> pkColNames; variable
890 ret = utilsObj.GetCloudPkVals(record, pkColNames, 0, cloudPkVals);
H A Ddistributeddb_cloud_asset_compare_test.cpp1040 param.pkColNames.push_back(pkField);