Home
last modified time | relevance | path

Searched refs:pkSet (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp38 std::set<std::string> pkSet = CloudStorageUtils::GetCloudPrimaryKey(tableSchema); in GetInfoByPrimaryKeyOrGid() local
45 if (!pkSet.empty()) { in GetInfoByPrimaryKeyOrGid()
226 const std::set<std::string> &pkSet, std::string &querySql) in GetQueryLogSql() argument
235 if (pkSet.empty() && cloudGid.empty()) { in GetQueryLogSql()
884 if (!pkSet.empty() && queryByPk) { in GetWhereConditionForDataTable()
889 for (const auto &pk : pkSet) { in GetWhereConditionForDataTable()
901 if (pkSet.empty() && gidStr.empty()) { in GetUpdateSqlForCloudSync()
910 sql += GetWhereConditionForDataTable(gidStr, pkSet, tableSchema.name); in GetUpdateSqlForCloudSync()
952 if (!pkSet.empty()) { in GetUpdateDataTableStatement()
1066 bool queryByPk = CloudStorageUtils::IsVbucketContainsAllPK(vBucket, pkSet); in GetDeleteStatementForCloudSync()
[all …]
H A Dsqlite_single_ver_relational_storage_executor.h301 …eryLogSql(const std::string &tableName, const VBucket &vBucket, const std::set<std::string> &pkSet,
304 …GetQueryInfoSql(const std::string &tableName, const VBucket &vBucket, std::set<std::string> &pkSet,
338 …string GetWhereConditionForDataTable(const std::string &gidStr, const std::set<std::string> &pkSet,
342 const std::string &gidStr, const std::set<std::string> &pkSet, std::string &updateSql);
358 … GetDeleteStatementForCloudSync(const TableSchema &tableSchema, const std::set<std::string> &pkSet,
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp36 std::set<std::string> &pkSet, std::vector<Field> &assetFields, std::string &querySql) in GetQueryInfoSql() argument
38 if (assetFields.empty() && pkSet.empty()) { in GetQueryInfoSql()
39 return GetQueryLogSql(tableName, vBucket, pkSet, querySql); in GetQueryInfoSql()
48 if (pkSet.empty() && gid.empty()) { in GetQueryInfoSql()
57 for (const auto &pk : pkSet) { in GetQueryInfoSql()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dquery_object.cpp525 std::set<std::string> pkSet; in CheckPrimaryKey() local
529 pkSet.insert(pk); in CheckPrimaryKey()
538 if (pkSet.find(field) == pkSet.end()) { in CheckPrimaryKey()
548 if (queryPkSet.size() != pkSet.size()) { in CheckPrimaryKey()
549 … LOGE("[Query] pk count is different! query %zu schema %zu", queryPkSet.size(), pkSet.size()); in CheckPrimaryKey()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_storage_utils.cpp289 std::set<std::string> pkSet; in GetCloudPrimaryKey() local
292 pkSet.insert(field.colName); in GetCloudPrimaryKey()
295 return pkSet; in GetCloudPrimaryKey()
730 …oudStorageUtils::IsVbucketContainsAllPK(const VBucket &vBucket, const std::set<std::string> &pkSet) in IsVbucketContainsAllPK() argument
732 if (pkSet.empty()) { in IsVbucketContainsAllPK()
735 for (const auto &pk : pkSet) { in IsVbucketContainsAllPK()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/
H A Dcloud_storage_utils.h95 static bool IsVbucketContainsAllPK(const VBucket &vBucket, const std::set<std::string> &pkSet);