Home
last modified time | relevance | path

Searched refs:GID_FIELD (Results 1 - 25 of 32) sorted by relevance

12

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/service_impl/
H A Dcloud_db.rs18 Database, RawValueBucket, Value, CREATE_FIELD, GID_FIELD, MODIFY_FIELD,
70 extends[i].insert(GID_FIELD.to_string(), Value::String(id.to_string())); in batch_insert()
73 vb.insert(GID_FIELD.to_string(), Value::String(id.to_string())); in batch_insert()
125 match ext.get(GID_FIELD) { in batch_delete()
252 match ext.get(GID_FIELD) { in upload()
H A Dtypes.rs20 pub(crate) const GID_FIELD: &str = "#_gid";
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/
H A Dcloud_db_constant.h26 static constexpr const char *GID_FIELD = "#_gid"; member in DistributedDB::CloudDbConstant
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dschema_meta.h54 static constexpr const char *GID_FIELD = "#_gid"; member in OHOS::DistributedData::final
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dcloud_cursor_impl.cpp25 { DistributedData::SchemaMeta::GID_FIELD, "id" },
164 entry[DBSchemaMeta::GID_FIELD] = GetExtend(vBucket, GID_KEY); in GetEntry()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp241 vBucket[CloudDbConstant::GID_FIELD] = (i == 1 ? std::to_string(i) : std::to_string(count + i)); in ConstructMultiDownloadData()
244 vBucket[CloudDbConstant::GID_FIELD] = std::to_string(i); in ConstructMultiDownloadData()
312 vBucket[CloudDbConstant::GID_FIELD] = std::to_string(1); in fillCloudAssetTest()
740 bucket1.insert_or_assign(CloudDbConstant::GID_FIELD, 1L); in HWTEST_F()
767 * @tc.steps: missing field GID_FIELD in HWTEST_F()
772 bucket1.insert_or_assign(CloudDbConstant::GID_FIELD, std::string("1")); in HWTEST_F()
781 bucket2.insert_or_assign(CloudDbConstant::GID_FIELD, std::string("2")); in HWTEST_F()
1001 vBucket[CloudDbConstant::GID_FIELD] = std::to_string(i); in HWTEST_F()
1039 vBucket[CloudDbConstant::GID_FIELD] = std::to_string(i); in HWTEST_F()
1218 bucket1.insert_or_assign(CloudDbConstant::GID_FIELD, st in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_save_cloud_data_test.cpp283 vBucket[CloudDbConstant::GID_FIELD] = gidStr; in GetInfoByPrimaryKeyOrGidTest()
465 vBucket[CloudDbConstant::GID_FIELD] = gid; in VbucketWithoutPrimaryDataTest()
546 vBucket[CloudDbConstant::GID_FIELD] = gid; in PrimaryKeyCollateTest()
815 vBucket[CloudDbConstant::GID_FIELD] = gid; in ConstructDownloadData()
1033 vBucket[CloudDbConstant::GID_FIELD] = gid; in ConstructMultiDownloadData()
1156 vBucket[CloudDbConstant::GID_FIELD] = gid; in HWTEST_F()
1191 vBucket[CloudDbConstant::GID_FIELD] = gid; in HWTEST_F()
1256 vBucket[CloudDbConstant::GID_FIELD] = gid; in DeleteWithPkTest()
H A Ddistributeddb_cloud_assets_operation_sync_test.cpp277 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in UpdateCloudTableRecord()
1074 extend[std::string(CloudDbConstant::GID_FIELD)] = std::string(""); in HWTEST_F()
1136 extend[std::string(CloudDbConstant::GID_FIELD)] = ""; in HWTEST_F()
H A Ddistributeddb_cloud_reference_sync_test.cpp329 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in UpdateCloudSharedTableRecord()
331 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(++i)); in UpdateCloudSharedTableRecord()
344 data.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(j)); in DeleteCloudSharedTableRecordByGid()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp589 logInfo.insert_or_assign(CloudDbConstant::GID_FIELD, cloudGid); in GetCloudLog()
595 if (logInfo.count(CloudDbConstant::GID_FIELD) != 0) { in GetCloudLog()
596 cloudGid = std::get<std::string>(logInfo[CloudDbConstant::GID_FIELD]); in GetCloudLog()
1870 updateColName.push_back(CloudDbConstant::GID_FIELD); in GetUpdateLogRecordStatement()
1887 updateColName.push_back(CloudDbConstant::GID_FIELD); in GetUpdateLogRecordStatement()
1897 updateColName.push_back(CloudDbConstant::GID_FIELD); in GetUpdateLogRecordStatement()
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp198 errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in GetQueryLogStatement()
229 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in GetQueryLogSql()
688 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); in InsertLogRecord()
789 errCode = CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in BindHashKeyAndGidToInsertLogStatement()
928 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); in GetUpdateDataTableStatement()
1057 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); in GetDeleteStatementForCloudSync()
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp42 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gid); in GetQueryInfoSql()
100 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in FillCloudAssetForDownload()
293 (void)CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in InitFillUploadAssetStatement()
712 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); in AppendUpdateLogRecordWhereSqlCondition()
943 auto gidEntry = cloudDataResult.insData.extend[i].find(CloudDbConstant::GID_FIELD); in BindStmtWithCloudGid()
962 if (CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::GID_FIELD, in BindStmtWithCloudGid()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_db_sync_utils_test.cpp134 log.insert_or_assign(CloudDbConstant::GID_FIELD, to_string(i)); in UpdateCloudTableRecord()
147 data.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in DeleteCloudTableRecordByGid()
H A Ddistributeddb_cloud_syncer_lock_test.cpp229 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i + gidStart)); in GenerateDataRecords()
295 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(beginGid + i)); in DeleteCloudDBData()
424 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(0)); in UpdateCloudAssets()
H A Ddistributeddb_cloud_syncer_download_test.cpp95 data.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in GetRetCloudData()
137 data.insert_or_assign(CloudDbConstant::GID_FIELD, (int64_t)i); in GetInvalidTypeCloudData()
171 data.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(i)); in GetInvalidFieldCloudData()
H A Dcloud_syncer_test.h202 std::pair<std::string, std::string>(CloudDbConstant::GID_FIELD, "0"), in initFullCloudSyncData()
H A Dvirtual_cloud_db.cpp28 const char *g_gidField = CloudDbConstant::GID_FIELD;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_executor_utils.cpp163 logInfo.insert_or_assign(CloudDbConstant::GID_FIELD, cloudGid); in GetCloudLog()
169 if (logInfo.count(CloudDbConstant::GID_FIELD) != 0) { in GetCloudLog()
170 cloudGid = std::get<std::string>(logInfo[CloudDbConstant::GID_FIELD]); in GetCloudLog()
272 errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, cloudData, gid); in GetLogInfo()
879 errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, data.extend[i], dataItem.gid); in FillCloudGid()
H A Dquery_sync_object.cpp257 objNode.fieldName = CloudDbConstant::GID_FIELD; in SetCloudGid()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_sync_utils.cpp72 if (key != CloudDbConstant::GID_FIELD && in RemoveDataExceptExtendInfo()
188 cloudLogInfo.cloudGid = std::get<std::string>(datum[CloudDbConstant::GID_FIELD]); in GetCloudLogInfo()
H A Dcloud_db_proxy.cpp605 if (extend.count(CloudDbConstant::GID_FIELD) == 0) { in IsRecordActionFail()
614 auto gid = std::get_if<std::string>(&extend.at(CloudDbConstant::GID_FIELD)); in IsRecordActionFail()
H A Dcloud_syncer_extend.cpp446 normalAssets[CloudDbConstant::GID_FIELD] = gid; in CommitDownloadAssets()
447 failedAssets[CloudDbConstant::GID_FIELD] = gid; in CommitDownloadAssets()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_storage_utils.cpp1084 if (colName == CloudDbConstant::GID_FIELD) { in BindUpdateLogStmtFromVBucket()
1210 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, data, gidStr); in BindStepConsistentFlagStmt()
1290 bool isInsert = (!isDelete) && (log.find(CloudDbConstant::GID_FIELD) == log.end()); in IdentifyCloudTypeInner()
1362 GetStringFromCloudData(CloudDbConstant::GID_FIELD, data, dataItem.gid); in GetDataItemFromCloudData()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_set_cloud_schema_test.cpp319 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(beginGid + i)); in InsertCloudTableRecord()
412 log.insert_or_assign(CloudDbConstant::GID_FIELD, std::to_string(beginGid + i)); in DeleteCloudTableRecord()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp1841 recordCopy[CloudDbConstant::GID_FIELD] = dataInfoWithLog.logInfo.cloudGid; in UpsertDataInTransaction()
1914 (void)CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, record, cloudGid); in UpdateRecordFlagAfterUpload()

Completed in 43 milliseconds

12