/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
H A D | cloud_storage_utils.h | 28 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 D | datashare_valuebucket_convert.cpp | 26 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 D | cloud_cursor_impl.cpp | 49 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 D | sqlite_single_ver_relational_storage_executor_extend.cpp | 35 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 D | sqlite_single_ver_relational_storage_executor.h | 131 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 D | sqlite_single_ver_relational_storage_extend_executor.cpp | 35 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 D | cloud_storage_utils.cpp | 26 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 D | distributeddb_cloud_save_cloud_data_test.cpp | 272 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 D | cloud_sync_tag_assets.h | 34 Type &GetAssetsCaseInsensitive(const std::string &assetFieldName, VBucket &vBucket);
|
H A D | cloud_sync_tag_assets.cpp | 348 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 D | distributeddb_relational_cloud_syncable_storage_test.cpp | 238 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 D | object_asset_machine_test.cpp | 59 VBucket vBucket{ { "11", 111 } }; in SetUp() 63 .primaryKey = vBucket, in SetUp()
|
H A D | object_snapshot_test.cpp | 54 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 D | virtual_cloud_db.cpp | 55 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 D | distributeddb_cloud_syncer_download_assets_test.cpp | 175 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 D | distributeddb_cloud_syncer_lock_test.cpp | 242 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 D | sqlite_cloud_kv_store.h | 62 int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog,
|
H A D | sqlite_cloud_kv_store.cpp | 239 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 D | relational_sync_able_storage.h | 169 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 D | icloud_sync_storage_interface.h | 128 virtual int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket,
|
H A D | storage_proxy.h | 80 int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket,
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | distributeddb_single_ver_multi_sub_user_test.cpp | 343 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 D | storage_proxy.cpp | 277 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 D | object_manager.h | 217 VBucket ConvertVBucket(ObjectStore::ValuesBucket &vBucket);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
H A D | relational_sync_able_storage.cpp | 1251 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
|