Searched refs:GetRelationTableName (Results 1 – 8 of 8) sorted by relevance
61 hashTableName = DBCommon::TransferHashString(query_.GetRelationTableName()); in CopyTargetData()86 auto it = relationalSyncStrategy_.find(querySyncObject.GetRelationTableName()); in GetSchemaSyncStatus()
77 std::string hashTableName = DBCommon::TransferHashString(table.GetRelationTableName()); in GenerateEachSyncTask()109 …resMap_[syncId][item.first][param.syncQuery.GetRelationTableName()] = static_cast<int>(item.second… in DoOnSubSyncComplete()206 if (param.syncQuery.GetRelationTableName().empty()) { in QuerySyncPreCheck()
53 std::string GetRelationTableName() const;
388 std::string QuerySyncObject::GetRelationTableName() const in GetRelationTableName() function in DistributedDB::QuerySyncObject
242 int errCode = store_->GetCloudTableSchema(querySyncObject.GetRelationTableName(), tableSchema); in GetCloudData()270 int errCode = store_->GetCloudTableSchema(querySyncObject.GetRelationTableName(), tableSchema); in GetCloudGid()
1190 std::string tableName = item.GetRelationTableName(); in CheckQueryValid()1220 std::string tableName = item.GetRelationTableName(); in CheckObjectValid()1263 info.table.push_back(item.GetRelationTableName()); in FillSyncInfo()
1295 auto strategy = localStrategy.find(singleVerContext->GetQuery().GetRelationTableName()); in HandleRelationAckSchemaParam()
477 taskInfo.table.push_back(query.GetRelationTableName()); in GenerateCompensatedSync()