Home
last modified time | relevance | path

Searched refs:vBucket (Results 1 - 25 of 27) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/
H A Dcloud_storage_utils.h28 static int BindInt64(int index, const VBucket &vBucket, const Field &field, sqlite3_stmt *upsertStmt);
29 static int BindBool(int index, const VBucket &vBucket, const Field &field, sqlite3_stmt *upsertStmt);
30 static int BindDouble(int index, const VBucket &vBucket, const Field &field, sqlite3_stmt *upsertStmt);
31 static int BindText(int index, const VBucket &vBucket, const Field &field, sqlite3_stmt *upsertStmt);
32 static int BindBlob(int index, const VBucket &vBucket, const Field &field, sqlite3_stmt *upsertStmt);
33 static int BindAsset(int index, const VBucket &vBucket, const Field &field, sqlite3_stmt *upsertStmt);
40 static int Int64ToVector(const VBucket &vBucket, const Field &field, CollateType collateType,
42 static int BoolToVector(const VBucket &vBucket, const Field &field, CollateType collateType,
44 static int DoubleToVector(const VBucket &vBucket, const Field &field, CollateType collateType,
46 static int TextToVector(const VBucket &vBucket, cons
139 GetValueFromVBucket(const std::string &fieldName, const VBucket &vBucket, T &outVal) GetValueFromVBucket() argument
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/common/src/
H A Ddatashare_valuebucket_convert.cpp26 VBucket vBucket; in Convert() local
30 vBucket.emplace(k, std::move(value)); in Convert()
32 res.emplace_back(std::move(vBucket)); in Convert()
42 for (auto &vBucket : vBuckets) { in Convert()
44 for (auto &[k, v] : vBucket) { in Convert()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dcloud_cursor_impl.cpp49 OhCloudExtValueBucket *vBucket = reinterpret_cast<OhCloudExtValueBucket *>(values); in CloudCursorImpl() local
50 auto data = GetData(vBucket); in CloudCursorImpl()
54 OhCloudExtValueBucketFree(vBucket); in CloudCursorImpl()
158 OhCloudExtValueBucket *vBucket = reinterpret_cast<OhCloudExtValueBucket *>(values); in GetEntry() local
159 auto data = GetData(vBucket); in GetEntry()
163 entry[DBSchemaMeta::DELETE_FIELD] = GetExtend(vBucket, OPERATION_KEY); in GetEntry()
164 entry[DBSchemaMeta::GID_FIELD] = GetExtend(vBucket, GID_KEY); in GetEntry()
165 entry[DBSchemaMeta::CREATE_FIELD] = GetExtend(vBucket, CREATE_TIME_KEY); in GetEntry()
166 entry[DBSchemaMeta::MODIFY_FIELD] = GetExtend(vBucket, MODIFY_TIME_KEY); in GetEntry()
169 OhCloudExtValueBucketFree(vBucket); in GetEntry()
270 OhCloudExtValueBucket *vBucket = reinterpret_cast<OhCloudExtValueBucket *>(data); Get() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp35 const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) in GetInfoByPrimaryKeyOrGid()
40 int errCode = GetQueryInfoSql(tableSchema.name, vBucket, pkSet, assetFields, querySql); in GetInfoByPrimaryKeyOrGid()
46 errCode = GetPrimaryKeyHashValue(vBucket, tableSchema, dataInfoWithLog.logInfo.hashKey, true); in GetInfoByPrimaryKeyOrGid()
53 errCode = GetQueryLogStatement(tableSchema, vBucket, querySql, dataInfoWithLog.logInfo.hashKey, selectStmt); in GetInfoByPrimaryKeyOrGid()
163 int SQLiteSingleVerRelationalStorageExecutor::GetPrimaryKeyHashValue(const VBucket &vBucket, in GetPrimaryKeyHashValue() argument
181 std::tie(errCode, hashValue) = CloudStorageUtils::GetHashValueWithPrimaryKeyMap(vBucket, in GetPrimaryKeyHashValue()
188 const VBucket &vBucket, const std::string &querySql, const Key &hashKey, sqlite3_stmt *&selectStmt) in GetQueryLogStatement()
198 errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in GetQueryLogStatement()
225 int SQLiteSingleVerRelationalStorageExecutor::GetQueryLogSql(const std::string &tableName, const VBucket &vBucket, in GetQueryLogSql() argument
229 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGi in GetQueryLogSql()
34 GetInfoByPrimaryKeyOrGid(const TableSchema &tableSchema, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) GetInfoByPrimaryKeyOrGid() argument
187 GetQueryLogStatement(const TableSchema &tableSchema, const VBucket &vBucket, const std::string &querySql, const Key &hashKey, sqlite3_stmt *&selectStmt) GetQueryLogStatement() argument
257 VBucket &vBucket = downloadData.data[index]; ExecutePutCloudData() local
643 InsertCloudData(VBucket &vBucket, const TableSchema &tableSchema, const TrackerTable &trackerTable, int64_t dataKey) InsertCloudData() argument
681 InsertLogRecord(const TableSchema &tableSchema, const TrackerTable &trackerTable, VBucket &vBucket) InsertLogRecord() argument
730 BindOneField(int index, const VBucket &vBucket, const Field &field, sqlite3_stmt *updateStmt) BindOneField() argument
741 BindValueToUpsertStatement(const VBucket &vBucket, const std::vector<Field> &fields, sqlite3_stmt *upsertStmt) BindValueToUpsertStatement() argument
773 BindHashKeyAndGidToInsertLogStatement(const VBucket &vBucket, const TableSchema &tableSchema, const TrackerTable &trackerTable, sqlite3_stmt *insertLogStmt) BindHashKeyAndGidToInsertLogStatement() argument
820 BindValueToInsertLogStatement(VBucket &vBucket, const TableSchema &tableSchema, const TrackerTable &trackerTable, sqlite3_stmt *insertLogStmt) BindValueToInsertLogStatement() argument
924 GetUpdateDataTableStatement(const VBucket &vBucket, const TableSchema &tableSchema, sqlite3_stmt *&updateStmt) GetUpdateDataTableStatement() argument
965 UpdateCloudData(VBucket &vBucket, const TableSchema &tableSchema) UpdateCloudData() argument
1002 UpdateLogRecord(const VBucket &vBucket, const TableSchema &tableSchema, OpType opType) UpdateLogRecord() argument
1032 BindValueToUpdateLogStatement(const VBucket &vBucket, const TableSchema &tableSchema, const std::vector<std::string> &colNames, bool allowPrimaryKeyEmpty, sqlite3_stmt *updateLogStmt) BindValueToUpdateLogStatement() argument
1053 GetDeleteStatementForCloudSync(const TableSchema &tableSchema, const std::set<std::string> &pkSet, const VBucket &vBucket, sqlite3_stmt *&deleteStmt) GetDeleteStatementForCloudSync() argument
1088 DeleteCloudData(const std::string &tableName, const VBucket &vBucket, const TableSchema &tableSchema, const TrackerTable &trackerTable) DeleteCloudData() argument
1120 OnlyUpdateLogTable(const VBucket &vBucket, const TableSchema &tableSchema, OpType opType) OnlyUpdateLogTable() argument
1183 LogicDeleteCloudData(const std::string &tableName, const VBucket &vBucket, const TableSchema &tableSchema, const TrackerTable &trackerTable) LogicDeleteCloudData() argument
1278 IsNeedUpdateAssetIdInner(sqlite3_stmt *selectStmt, const VBucket &vBucket, const Field &field, VBucket &assetInfo) IsNeedUpdateAssetIdInner() argument
1313 IsNeedUpdateAssetId(const TableSchema &tableSchema, int64_t dataKey, const VBucket &vBucket) IsNeedUpdateAssetId() argument
1549 PutVBucketByType(VBucket &vBucket, const Field &field, Type &cloudValue) PutVBucketByType() argument
[all...]
H A Dsqlite_single_ver_relational_storage_executor.h131 int GetInfoByPrimaryKeyOrGid(const TableSchema &tableSchema, const VBucket &vBucket,
137 int FillCloudAssetForDownload(const TableSchema &tableSchema, VBucket &vBucket, bool isDownloadSuccess);
288 int PutVBucketByType(VBucket &vBucket, const Field &field, Type &cloudValue);
295 int GetPrimaryKeyHashValue(const VBucket &vBucket, const TableSchema &tableSchema, std::vector<uint8_t> &hashValue,
298 int GetQueryLogStatement(const TableSchema &tableSchema, const VBucket &vBucket, const std::string &querySql,
301 int GetQueryLogSql(const std::string &tableName, const VBucket &vBucket, const std::set<std::string> &pkSet,
304 int GetQueryInfoSql(const std::string &tableName, const VBucket &vBucket, std::set<std::string> &pkSet,
307 int GetFillDownloadAssetStatement(const std::string &tableName, const VBucket &vBucket,
318 int InsertCloudData(VBucket &vBucket, const TableSchema &tableSchema, const TrackerTable &trackerTable,
321 int InsertLogRecord(const TableSchema &tableSchema, const TrackerTable &trackerTable, VBucket &vBucket);
[all...]
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp35 int SQLiteSingleVerRelationalStorageExecutor::GetQueryInfoSql(const std::string &tableName, const VBucket &vBucket, in GetQueryInfoSql() argument
39 return GetQueryLogSql(tableName, vBucket, pkSet, querySql); in GetQueryInfoSql()
42 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gid); in GetQueryInfoSql()
70 const VBucket &vBucket, const std::vector<Field> &fields, sqlite3_stmt *&statement) in GetFillDownloadAssetStatement()
86 errCode = BindOneField(i + 1, vBucket, fields[i], stmt); in GetFillDownloadAssetStatement()
97 VBucket &vBucket, bool isDownloadSuccess) in FillCloudAssetForDownload()
100 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); in FillCloudAssetForDownload()
106 errCode = CloudStorageUtils::GetAssetFieldsFromSchema(tableSchema, vBucket, assetsField); in FillCloudAssetForDownload()
111 CloudStorageUtils::ChangeAssetsOnVBucketToAsset(vBucket, assetsField); in FillCloudAssetForDownload()
114 (void)CloudStorageUtils::GetValueFromVBucket<Bytes>(HASH_KEY, vBucket, hashKe in FillCloudAssetForDownload()
69 GetFillDownloadAssetStatement(const std::string &tableName, const VBucket &vBucket, const std::vector<Field> &fields, sqlite3_stmt *&statement) GetFillDownloadAssetStatement() argument
96 FillCloudAssetForDownload(const TableSchema &tableSchema, VBucket &vBucket, bool isDownloadSuccess) FillCloudAssetForDownload() argument
255 BindUpdateVersionStatement(const VBucket &vBucket, const Bytes &hashKey, sqlite3_stmt *&stmt) BindUpdateVersionStatement() argument
289 VBucket vBucket = data.assets.at(index); InitFillUploadAssetStatement() local
708 AppendUpdateLogRecordWhereSqlCondition(const TableSchema &tableSchema, const VBucket &vBucket, std::string &sql) AppendUpdateLogRecordWhereSqlCondition() argument
1446 CleanDownloadChangedAssets( const VBucket &vBucket, const AssetOperationUtils::RecordAssetOpType &assetOpType) CleanDownloadChangedAssets() argument
1492 OnlyUpdateAssetId(const std::string &tableName, const TableSchema &tableSchema, const VBucket &vBucket, int64_t dataKey, OpType opType) OnlyUpdateAssetId() argument
1513 UpdateLocalAssetId(const VBucket &vBucket, const std::string &fieldName, Asset &asset) UpdateLocalAssetId() argument
1523 UpdateLocalAssetsId(const VBucket &vBucket, const std::string &fieldName, Assets &assets) UpdateLocalAssetsId() argument
1623 UpdateAssetId(const TableSchema &tableSchema, int64_t dataKey, const VBucket &vBucket) UpdateAssetId() argument
1700 GetUpdateField(const VBucket &vBucket, const TableSchema &tableSchema) GetUpdateField() argument
1891 BindShareValueToInsertLogStatement(const VBucket &vBucket, const TableSchema &tableSchema, sqlite3_stmt *insertLogStmt) BindShareValueToInsertLogStatement() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_storage_utils.cpp26 int CloudStorageUtils::BindInt64(int index, const VBucket &vBucket, const Field &field, in BindInt64() argument
30 int errCode = GetValueFromVBucket<int64_t>(field.colName, vBucket, val); in BindInt64()
47 int CloudStorageUtils::BindBool(int index, const VBucket &vBucket, const Field &field, in BindBool() argument
51 int errCode = GetValueFromVBucket<bool>(field.colName, vBucket, val); in BindBool()
68 int CloudStorageUtils::BindDouble(int index, const VBucket &vBucket, const Field &field, in BindDouble() argument
72 int errCode = GetValueFromVBucket<double>(field.colName, vBucket, val); in BindDouble()
89 int CloudStorageUtils::BindText(int index, const VBucket &vBucket, const Field &field, in BindText() argument
93 int errCode = GetValueFromVBucket<std::string>(field.colName, vBucket, str); in BindText()
110 int CloudStorageUtils::BindBlob(int index, const VBucket &vBucket, const Field &field, in BindBlob() argument
116 errCode = GetValueFromVBucket<Bytes>(field.colName, vBucket, va in BindBlob()
150 BindAsset(int index, const VBucket &vBucket, const Field &field, sqlite3_stmt *upsertStmt) BindAsset() argument
203 Int64ToVector(const VBucket &vBucket, const Field &field, CollateType collateType, std::vector<uint8_t> &value) Int64ToVector() argument
215 BoolToVector(const VBucket &vBucket, const Field &field, CollateType collateType, std::vector<uint8_t> &value) BoolToVector() argument
227 DoubleToVector(const VBucket &vBucket, const Field &field, CollateType collateType, std::vector<uint8_t> &value) DoubleToVector() argument
241 TextToVector(const VBucket &vBucket, const Field &field, CollateType collateType, std::vector<uint8_t> &value) TextToVector() argument
258 BlobToVector(const VBucket &vBucket, const Field &field, CollateType collateType, std::vector<uint8_t> &value) BlobToVector() argument
342 GetAssetFieldsFromSchema(const TableSchema &tableSchema, const VBucket &vBucket, std::vector<Field> &fields) GetAssetFieldsFromSchema() argument
372 ObtainAssetFromVBucket(const VBucket &vBucket, VBucket &asset) ObtainAssetFromVBucket() argument
413 ChangeAssetsOnVBucketToAsset(VBucket &vBucket, std::vector<Field> &fields) ChangeAssetsOnVBucketToAsset() argument
562 PrepareToFillAssetFromVBucket(VBucket &vBucket, std::function<int(Asset &)> fillAsset) PrepareToFillAssetFromVBucket() argument
581 FillAssetFromVBucketFinish(const AssetOperationUtils::RecordAssetOpType &assetOpType, VBucket &vBucket, VBucket &dbAssets, std::function<int(Asset &, Asset &, AssetOperationUtils::AssetOpType)> fillAsset, std::function<void(Assets &, Assets &, const std::map<std::string, AssetOperationUtils::AssetOpType> &)> fillAssets) FillAssetFromVBucketFinish() argument
636 CalculateHashKeyForOneField(const Field &field, const VBucket &vBucket, bool allowEmpty, CollateType collateType, std::vector<uint8_t> &hashValue) CalculateHashKeyForOneField() argument
728 IsVbucketContainsAllPK(const VBucket &vBucket, const std::set<std::string> &pkSet) IsVbucketContainsAllPK() argument
885 GetToBeRemoveAssets(const VBucket &vBucket, const AssetOperationUtils::RecordAssetOpType &assetOpType, std::vector<Asset> &removeAssets) GetToBeRemoveAssets() argument
990 GetHashValueWithPrimaryKeyMap(const VBucket &vBucket, const TableSchema &tableSchema, const TableInfo &localTable, const std::map<std::string, Field> &pkMap, bool allowEmpty) GetHashValueWithPrimaryKeyMap() argument
1049 TransferFieldToLower(VBucket &vBucket) TransferFieldToLower() argument
1063 GetTypeCaseInsensitive(const std::string &fieldName, const VBucket &vBucket, Type &data) GetTypeCaseInsensitive() argument
1077 BindUpdateLogStmtFromVBucket(const VBucket &vBucket, const TableSchema &tableSchema, const std::vector<std::string> &colNames, sqlite3_stmt *updateLogStmt) BindUpdateLogStmtFromVBucket() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_save_cloud_data_test.cpp272 VBucket vBucket; in GetInfoByPrimaryKeyOrGidTest() local
273 vBucket["id"] = id ; in GetInfoByPrimaryKeyOrGidTest()
276 vBucket["name"] = name; in GetInfoByPrimaryKeyOrGidTest()
277 vBucket["age"] = 10.1; // 10.1 is test age in GetInfoByPrimaryKeyOrGidTest()
280 vBucket["name"] = name; in GetInfoByPrimaryKeyOrGidTest()
281 vBucket["age"] = 10.11; // 10.11 is test age in GetInfoByPrimaryKeyOrGidTest()
283 vBucket[CloudDbConstant::GID_FIELD] = gidStr; in GetInfoByPrimaryKeyOrGidTest()
286 EXPECT_EQ(storageProxy->GetInfoByPrimaryKeyOrGid(g_tableName, vBucket, dataInfoWithLog, assetInfo), expectCode); in GetInfoByPrimaryKeyOrGidTest()
463 VBucket vBucket; in VbucketWithoutPrimaryDataTest() local
465 vBucket[CloudDbConstan in VbucketWithoutPrimaryDataTest()
540 VBucket vBucket; PrimaryKeyCollateTest() local
787 VBucket vBucket; ConstructDownloadData() local
1006 VBucket vBucket; ConstructMultiDownloadData() local
1154 VBucket vBucket; HWTEST_F() local
1189 VBucket vBucket; HWTEST_F() local
1248 VBucket vBucket; DeleteWithPkTest() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_sync_tag_assets.h34 Type &GetAssetsCaseInsensitive(const std::string &assetFieldName, VBucket &vBucket);
H A Dcloud_sync_tag_assets.cpp348 Type &GetAssetsCaseInsensitive(const std::string &assetFieldName, VBucket &vBucket) in GetAssetsCaseInsensitive() argument
350 for (auto &item : vBucket) { in GetAssetsCaseInsensitive()
355 return vBucket[assetFieldName]; in GetAssetsCaseInsensitive()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp238 VBucket vBucket; in ConstructMultiDownloadData() local
241 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()
246 vBucket["assert"] = asset; in ConstructMultiDownloadData()
255 vBucket["asserts"] = assets; in ConstructMultiDownloadData()
257 vBucket["name"] = name; in ConstructMultiDownloadData()
258 vBucket["age"] = (int64_t)i; in ConstructMultiDownloadData()
260 vBucket[CloudDbConstant::MODIFY_FIELD] = mTime; in ConstructMultiDownloadData()
261 vBucket[CloudDbConstant::CREATE_FIELD] = mTime; in ConstructMultiDownloadData()
262 downloadData.data.push_back(vBucket); in ConstructMultiDownloadData()
311 VBucket vBucket; fillCloudAssetTest() local
1000 VBucket vBucket; HWTEST_F() local
1038 VBucket vBucket; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dobject_asset_machine_test.cpp59 VBucket vBucket{ { "11", 111 } }; in SetUp()
63 .primaryKey = vBucket, in SetUp()
H A Dobject_snapshot_test.cpp54 VBucket vBucket{ { "11", 111 } }; in SetUp()
58 .primaryKey = vBucket, in SetUp()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dvirtual_cloud_db.cpp55 VBucket vBucket; in BatchInsert() local
56 extend.push_back(vBucket); in BatchInsert()
145 VBucket vBucket; in BatchInsertWithGid() local
146 extend.push_back(vBucket); in BatchInsertWithGid()
420 VBucket vBucket; in InnerUpdate() local
421 extend.push_back(vBucket); in InnerUpdate()
H A Ddistributeddb_cloud_syncer_download_assets_test.cpp175 for (VBucket vBucket : record) { in InsertLocalData()
178 ASSERT_EQ(SQLiteUtils::BindInt64ToStatement(stmt, 1, std::get<int64_t>(vBucket[COL_ID])), E_OK); // 1 is id in InsertLocalData()
179 ASSERT_EQ(SQLiteUtils::BindTextToStatement(stmt, 2, std::get<string>(vBucket[COL_NAME])), E_OK); // 2 is name in InsertLocalData()
181 sqlite3_bind_double(stmt, 3, std::get<double>(vBucket[COL_HEIGHT]))), E_OK); // 3 is height in InsertLocalData()
189 std::get<Assets>(vBucket[COL_ASSETS])); in InsertLocalData()
191 ASSERT_EQ(SQLiteUtils::BindInt64ToStatement(stmt, 6, std::get<int64_t>(vBucket[COL_AGE])), E_OK); // 6 is age in InsertLocalData()
288 for (auto &vBucket: record) { in InsertCloudDBData()
289 vBucket.insert_or_assign(CloudDbConstant::CLOUD_OWNER, std::string("cloudA")); in InsertCloudDBData()
1187 count = -1; // -1 means extend push a empty vBucket in HWTEST_F()
H A Ddistributeddb_cloud_syncer_lock_test.cpp242 for (VBucket vBucket : record) { in InsertLocalData()
245 ASSERT_EQ(SQLiteUtils::BindInt64ToStatement(stmt, 1, std::get<int64_t>(vBucket[COL_ID])), E_OK); // 1 is id in InsertLocalData()
246 ASSERT_EQ(SQLiteUtils::BindTextToStatement(stmt, 2, std::get<string>(vBucket[COL_NAME])), E_OK); // 2 is name in InsertLocalData()
254 std::get<Assets>(vBucket[COL_ASSETS])); in InsertLocalData()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_store.h62 int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog,
H A Dsqlite_cloud_kv_store.cpp239 int SqliteCloudKvStore::GetInfoByPrimaryKeyOrGid([[gnu::unused]] const std::string &tableName, const VBucket &vBucket, in GetInfoByPrimaryKeyOrGid() argument
248 std::tie(errCode, dataInfoWithLog) = SqliteCloudKvExecutorUtils::GetLogInfo(db, isMemory, vBucket, user_); in GetInfoByPrimaryKeyOrGid()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h169 int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket,
232 const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dicloud_sync_storage_interface.h128 virtual int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket,
H A Dstorage_proxy.h80 int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_multi_sub_user_test.cpp343 for (VBucket vBucket : record) { in InsertLocalData()
346 ASSERT_EQ(SQLiteUtils::BindInt64ToStatement(stmt, 1, std::get<int64_t>(vBucket[COL_ID])), E_OK); // 1 is id in InsertLocalData()
347 ASSERT_EQ(SQLiteUtils::BindTextToStatement(stmt, 2, std::get<string>(vBucket[COL_NAME])), E_OK); // 2 is name in InsertLocalData()
355 std::get<Assets>(vBucket[COL_ASSETS])); in InsertLocalData()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_proxy.cpp277 int StorageProxy::GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket, in GetInfoByPrimaryKeyOrGid() argument
289 int errCode = store_->GetInfoByPrimaryKeyOrGid(tableName, vBucket, dataInfoWithLog, assetInfo); in GetInfoByPrimaryKeyOrGid()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_manager.h217 VBucket ConvertVBucket(ObjectStore::ValuesBucket &vBucket);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp1251 int RelationalSyncAbleStorage::GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket, in GetInfoByPrimaryKeyOrGid() argument
1259 return GetInfoByPrimaryKeyOrGidInner(transactionHandle_, tableName, vBucket, dataInfoWithLog, assetInfo); in GetInfoByPrimaryKeyOrGid()
1263 const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) in GetInfoByPrimaryKeyOrGidInner()
1276 return handle->GetInfoByPrimaryKeyOrGid(tableSchema, vBucket, dataInfoWithLog, assetInfo); in GetInfoByPrimaryKeyOrGidInner()
1262 GetInfoByPrimaryKeyOrGidInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) GetInfoByPrimaryKeyOrGidInner() argument

Completed in 27 milliseconds

12