| /foundation/distributeddatamgr/data_share/frameworks/native/common/src/ |
| H A D | datashare_valuebucket_convert.cpp | 26 VBucket vBucket;
in Convert() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_storage_utils.h | 139 GetValueFromVBucket(const std::string &fieldName, const VBucket &vBucket, T &outVal) GetValueFromVBucket() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_tag_assets.cpp | 348 Type &GetAssetsCaseInsensitive(const std::string &assetFieldName, VBucket &vBucket) in GetAssetsCaseInsensitive() argument
|
| /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
158 OhCloudExtValueBucket *vBucket = reinterpret_cast<OhCloudExtValueBucket *>(values); in GetEntry() local
270 OhCloudExtValueBucket *vBucket = reinterpret_cast<OhCloudExtValueBucket *>(data); Get() local
[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
463 VBucket vBucket; in VbucketWithoutPrimaryDataTest() local
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/test/unittest/common/syncer/cloud/ |
| H A D | virtual_cloud_db.cpp | 55 VBucket vBucket; in BatchInsert() local
145 VBucket vBucket; in BatchInsertWithGid() local
420 VBucket vBucket; in InnerUpdate() local
|
| /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
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 239 int SqliteCloudKvStore::GetInfoByPrimaryKeyOrGid([[gnu::unused]] const std::string &tableName, const VBucket &vBucket, in GetInfoByPrimaryKeyOrGid() argument
|
| /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
311 VBucket vBucket; fillCloudAssetTest() local
1000 VBucket vBucket; HWTEST_F() local
1038 VBucket vBucket; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 1864 GetUpdateLogRecordStatement(const TableSchema &tableSchema, const VBucket &vBucket, OpType opType, std::vector<std::string> &updateColName, sqlite3_stmt *&updateLogStmt) GetUpdateLogRecordStatement() argument
|
| 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
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...] |
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 163 int SQLiteSingleVerRelationalStorageExecutor::GetPrimaryKeyHashValue(const VBucket &vBucket, in GetPrimaryKeyHashValue() argument
225 int SQLiteSingleVerRelationalStorageExecutor::GetQueryLogSql(const std::string &tableName, const VBucket &vBucket, in GetQueryLogSql() argument
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...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_delegate_test.cpp | 3390 VBucket vBucket; in HWTEST_F() local
|
| /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
47 int CloudStorageUtils::BindBool(int index, const VBucket &vBucket, const Field &field, in BindBool() argument
68 int CloudStorageUtils::BindDouble(int index, const VBucket &vBucket, const Field &field, in BindDouble() argument
89 int CloudStorageUtils::BindText(int index, const VBucket &vBucket, const Field &field, in BindText() argument
110 int CloudStorageUtils::BindBlob(int index, const VBucket &vBucket, const Field &field, in BindBlob() argument
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/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
1262 GetInfoByPrimaryKeyOrGidInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &assetInfo) GetInfoByPrimaryKeyOrGidInner() argument
|