| /ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/common/src/ |
| H A D | datashare_valuebucket_convert.cpp | 26 VBucket vBucket; in Convert() local
42 for (auto &vBucket : vBuckets) { in Convert() local
|
| /ohos5.0/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()
163 int SQLiteSingleVerRelationalStorageExecutor::GetPrimaryKeyHashValue(const VBucket &vBucket, in GetPrimaryKeyHashValue()
257 VBucket &vBucket = downloadData.data[index]; in ExecutePutCloudData() local
681 const TrackerTable &trackerTable, VBucket &vBucket) in InsertLogRecord()
740 int SQLiteSingleVerRelationalStorageExecutor::BindValueToUpsertStatement(const VBucket &vBucket, in BindValueToUpsertStatement()
819 int SQLiteSingleVerRelationalStorageExecutor::BindValueToInsertLogStatement(VBucket &vBucket, in BindValueToInsertLogStatement()
923 int SQLiteSingleVerRelationalStorageExecutor::GetUpdateDataTableStatement(const VBucket &vBucket, in GetUpdateDataTableStatement()
1053 const std::set<std::string> &pkSet, const VBucket &vBucket, sqlite3_stmt *&deleteStmt) in GetDeleteStatementForCloudSync()
1119 int SQLiteSingleVerRelationalStorageExecutor::OnlyUpdateLogTable(const VBucket &vBucket, in OnlyUpdateLogTable()
1251 const VBucket &vBucket, const Field &field, VBucket &assetInfo) in IsNeedUpdateAssetIdInner()
[all …]
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 35 …VerRelationalStorageExecutor::GetQueryInfoSql(const std::string &tableName, const VBucket &vBucket, in GetQueryInfoSql()
70 const VBucket &vBucket, const std::vector<Field> &fields, sqlite3_stmt *&statement) in GetFillDownloadAssetStatement()
97 VBucket &vBucket, bool isDownloadSuccess) in FillCloudAssetForDownload()
255 int SQLiteSingleVerRelationalStorageExecutor::BindUpdateVersionStatement(const VBucket &vBucket, co… in BindUpdateVersionStatement()
289 VBucket vBucket = data.assets.at(index); in InitFillUploadAssetStatement() local
715 const VBucket &vBucket, std::string &sql) in AppendUpdateLogRecordWhereSqlCondition()
1435 const VBucket &vBucket, const AssetOperationUtils::RecordAssetOpType &assetOpType) in CleanDownloadChangedAssets()
1481 const TableSchema &tableSchema, const VBucket &vBucket, int64_t dataKey, OpType opType) in OnlyUpdateAssetId()
1701 const VBucket &vBucket) in UpdateAssetId()
1777 std::vector<Field> SQLiteSingleVerRelationalStorageExecutor::GetUpdateField(const VBucket &vBucket, in GetUpdateField()
[all …]
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 1841 …const VBucket &vBucket, OpType opType, std::vector<std::string> &updateColName, sqlite3_stmt *&upd… in GetUpdateLogRecordStatement()
|
| /ohos5.0/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()
47 int CloudStorageUtils::BindBool(int index, const VBucket &vBucket, const Field &field, in BindBool()
68 int CloudStorageUtils::BindDouble(int index, const VBucket &vBucket, const Field &field, in BindDouble()
89 int CloudStorageUtils::BindText(int index, const VBucket &vBucket, const Field &field, in BindText()
110 int CloudStorageUtils::BindBlob(int index, const VBucket &vBucket, const Field &field, in BindBlob()
215 int CloudStorageUtils::BoolToVector(const VBucket &vBucket, const Field &field, CollateType collate… in BoolToVector()
372 void CloudStorageUtils::ObtainAssetFromVBucket(const VBucket &vBucket, VBucket &asset) in ObtainAssetFromVBucket()
413 void CloudStorageUtils::ChangeAssetsOnVBucketToAsset(VBucket &vBucket, std::vector<Field> &fields) in ChangeAssetsOnVBucketToAsset()
584 VBucket &vBucket, VBucket &dbAssets, in FillAssetFromVBucketFinish()
887 void CloudStorageUtils::GetToBeRemoveAssets(const VBucket &vBucket, in GetToBeRemoveAssets()
[all …]
|
| /ohos5.0/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); in Get() local
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_storage_utils.h | 139 static int GetValueFromVBucket(const std::string &fieldName, const VBucket &vBucket, T &outVal) in GetValueFromVBucket()
|
| /ohos5.0/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; in PrimaryKeyCollateTest() local
787 VBucket vBucket; in ConstructDownloadData() local
1006 VBucket vBucket; in ConstructMultiDownloadData() local
1154 VBucket vBucket; variable
1189 VBucket vBucket; variable
1248 VBucket vBucket; in DeleteWithPkTest() local
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | object_asset_machine_test.cpp | 59 VBucket vBucket{ { "11", 111 } }; in SetUp() local
|
| H A D | object_snapshot_test.cpp | 52 VBucket vBucket{ { "11", 111 } }; in SetUp() local
|
| /ohos5.0/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
423 VBucket vBucket; in InnerUpdate() local
|
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 242 for (VBucket vBucket : record) { in InsertLocalData() local
|
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 174 for (VBucket vBucket : record) { in InsertLocalData() local
287 for (auto &vBucket: record) { in InsertCloudDBData() local
|
| /ohos5.0/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; in fillCloudAssetTest() local
990 VBucket vBucket; variable
1028 VBucket vBucket; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_tag_assets.cpp | 352 Type &GetAssetsCaseInsensitive(const std::string &assetFieldName, VBucket &vBucket) in GetAssetsCaseInsensitive()
|
| /ohos5.0/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() local
|
| /ohos5.0/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()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1242 …onalSyncAbleStorage::GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket, in GetInfoByPrimaryKeyOrGid()
1254 …const std::string &tableName, const VBucket &vBucket, DataInfoWithLog &dataInfoWithLog, VBucket &a… in GetInfoByPrimaryKeyOrGidInner()
|