/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
H A D | rd_single_ver_natural_store_connection.h | 40 int Get(const IOption &option, const Key &key, Value &value) const override; 43 int Clear(const IOption &option) override; 46 …int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const ove… 48 …int GetEntries(const IOption &option, const Query &query, std::vector<Entry> &entries) const overr… 50 int GetCount(const IOption &option, const Query &query, int &count) const override; 97 int GetKeys(const IOption &option, const Key &keyPrefix, std::vector<Key> &keys) const override; 112 int GetEntriesInner(bool isGetValue, const IOption &option, 115 int GetEntriesInner(const IOption &option, const Query &query, 118 static int CheckOption(const IOption &option, SingleVerDataType &type); 128 int PutBatchInner(const IOption &option, const std::vector<Entry> &entries) override; [all …]
|
H A D | rd_single_ver_natural_store_connection.cpp | 43 int RdSingleVerNaturalStoreConnection::GetEntries(const IOption &option, const Key &keyPrefix, in GetEntries() 46 if (option.dataType != IOption::SYNC_DATA) { in GetEntries() 55 if (option.dataType == IOption::SYNC_DATA) { in CheckOption() 64 int RdSingleVerNaturalStoreConnection::GetEntriesInner(bool isGetValue, const IOption &option, in GetEntriesInner() 152 int RdSingleVerNaturalStoreConnection::GetResultSet(const IOption &option, in GetResultSet() 313 int RdSingleVerNaturalStoreConnection::Clear(const IOption &option) in Clear() 353 int RdSingleVerNaturalStoreConnection::GetEntries(const IOption &option, const Query &query, in GetEntries() 356 if (option.dataType != IOption::SYNC_DATA) { in GetEntries() 521 int RdSingleVerNaturalStoreConnection::GetKeys(const IOption &option, const Key &keyPrefix, in GetKeys() 558 if (option.dataType != IOption::SYNC_DATA) { in PutBatchInner() [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
H A D | ikvdb_connection.h | 50 virtual int Get(const IOption &option, const Key &key, Value &value) const = 0; 53 virtual int Put(const IOption &option, const Key &key, const Value &value) = 0; 56 virtual int Delete(const IOption &option, const Key &key) = 0; 59 virtual int Clear(const IOption &option) = 0; 62 …virtual int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) c… 64 …virtual int GetEntries(const IOption &option, const Query &query, std::vector<Entry> &entries) con… 66 virtual int GetCount(const IOption &option, const Query &query, int &count) const = 0; 69 virtual int PutBatch(const IOption &option, const std::vector<Entry> &entries) = 0; 72 virtual int DeleteBatch(const IOption &option, const std::vector<Key> &keys) = 0; 123 …virtual int GetResultSet(const IOption &option, const Query &query, IKvDBResultSet *&resultSet) co… [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | single_ver_natural_store_connection.h | 27 int Put(const IOption &option, const Key &key, const Value &value) override; 29 int PutBatch(const IOption &option, const std::vector<Entry> &entries) override; 33 int Get(const IOption &option, const Key &key, Value &value) const override; 36 int Delete(const IOption &option, const Key &key) override; 39 int DeleteBatch(const IOption &option, const std::vector<Key> &keys) override; 45 virtual int PutBatchInner(const IOption &option, const std::vector<Entry> &entries) = 0; 49 virtual int DeleteBatchInner(const IOption &option, const std::vector<Key> &keys) = 0;
|
H A D | single_ver_natural_store_connection.cpp | 31 int SingleVerNaturalStoreConnection::Put(const IOption &option, const Key &key, const Value &value) in Put() 40 int SingleVerNaturalStoreConnection::PutBatch(const IOption &option, const std::vector<Entry> &entr… in PutBatch() 43 if (option.dataType != IOption::SYNC_DATA) { in PutBatch() 96 int SingleVerNaturalStoreConnection::Get(const IOption &option, const Key &key, Value &value) const in Get() 101 int SingleVerNaturalStoreConnection::Delete(const IOption &option, const Key &key) in Delete() 109 int SingleVerNaturalStoreConnection::DeleteBatch(const IOption &option, const std::vector<Key> &key… in DeleteBatch() 112 if (option.dataType != IOption::SYNC_DATA) { in DeleteBatch()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_single_ver_natural_store_testcase.cpp | 55 IOption option; in GetSyncData001() 96 IOption option; in GetSyncData002() 133 IOption option; in GetSyncData003() 173 IOption option; in GetSyncData004() 237 IOption option; in GetSyncData005() 278 IOption option; in GetSyncData006() 310 IOption option; in PutSyncData001() 405 IOption option; in PutSyncData002() 489 IOption option; in PutSyncData003() 628 IOption option; in GetCurrentMaxTimestamp001() [all …]
|
H A D | distributeddb_storage_rd_single_ver_natural_store_testcase.cpp | 40 IOption option; in SyncDatabaseOperate001() 41 option.dataType = IOption::SYNC_DATA; in SyncDatabaseOperate001() 55 IOption option; in SyncDatabaseOperate003() 56 option.dataType = IOption::SYNC_DATA; in SyncDatabaseOperate003() 70 IOption option; in SyncDatabaseOperate005() 71 option.dataType = IOption::SYNC_DATA; in SyncDatabaseOperate005() 85 IOption option; in SyncDatabaseOperate006() 86 option.dataType = IOption::SYNC_DATA; in SyncDatabaseOperate006() 132 option.dataType = IOption::LOCAL_DATA; in SyncDatabaseOperate006() 149 RdSingleVerNaturalStoreConnection *&connection, IOption option) in DataBaseCommonPutOperate() [all …]
|
H A D | distributeddb_storage_transaction_data_test.cpp | 180 IOption option; in PutAndCommitEntry() 218 IOption option; in ValueEqualByKey() 306 IOption option; 348 IOption option; 366 IOption option; 388 IOption option; 418 IOption option; 447 IOption option; 478 IOption option; 502 IOption option; [all …]
|
H A D | distributeddb_storage_rd_single_ver_natural_store_testcase.h | 65 DistributedDB::RdSingleVerNaturalStoreConnection *&connection, DistributedDB::IOption option); 68 DistributedDB::RdSingleVerNaturalStoreConnection *&connection, DistributedDB::IOption option); 71 DistributedDB::RdSingleVerNaturalStoreConnection *&connection, DistributedDB::IOption option);
|
H A D | distributeddb_storage_sqlite_single_ver_natural_executor_test.cpp | 530 IOption option; 545 option.dataType = IOption::LOCAL_DATA; 570 IOption option = {IOption::LOCAL_DATA}; 575 option.dataType = IOption::SYNC_DATA; 601 IOption option = {IOption::SYNC_DATA}; 629 option.dataType = IOption::SYNC_DATA; 648 IOption option; 649 option.dataType = IOption::SYNC_DATA; 693 IOption option; 694 option.dataType = IOption::SYNC_DATA; [all …]
|
H A D | distributeddb_storage_register_conflict_test.cpp | 274 IOption option; in SyncPutConflictData() 275 option.dataType = IOption::SYNC_DATA; in SyncPutConflictData() 308 IOption option; in SyncDeleteConflictData() 309 option.dataType = IOption::SYNC_DATA; in SyncDeleteConflictData() 332 IOption option; in SyncPutFromDiffDevConflictData() 333 option.dataType = IOption::SYNC_DATA; in SyncPutFromDiffDevConflictData() 353 IOption option; in SyncDeleteFromDiffDevConflictData() 354 option.dataType = IOption::SYNC_DATA; in SyncDeleteFromDiffDevConflictData() 755 IOption option; 756 option.dataType = IOption::SYNC_DATA; [all …]
|
H A D | distributeddb_storage_data_connection_test.cpp | 141 IOption option; 179 IOption option; 205 IOption option; 245 IOption option; 287 IOption option;
|
H A D | distributeddb_storage_query_sync_test.cpp | 168 IOption option; in SetUp() 169 option.dataType = IOption::SYNC_DATA; in SetUp() 205 IOption option; 285 IOption option{ IOption::SYNC_DATA }; 354 IOption option{ IOption::SYNC_DATA }; 421 IOption option{ IOption::SYNC_DATA }; 493 IOption option{ IOption::SYNC_DATA }; 550 IOption option{ IOption::SYNC_DATA }; 632 IOption option; 721 IOption option; [all …]
|
H A D | distributeddb_storage_rd_single_ver_natural_executor_test.cpp | 275 IOption option; 276 option.dataType = IOption::SYNC_DATA + 1; 290 option.dataType = IOption::LOCAL_DATA; 315 IOption option = {IOption::SYNC_DATA}; 320 option.dataType = IOption::SYNC_DATA; 323 option.dataType = IOption::SYNC_DATA + 1;
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/ |
H A D | sqlite_local_kvdb_connection.h | 40 int Get(const IOption &option, const Key &key, Value &value) const override; 43 int Put(const IOption &option, const Key &key, const Value &value) override; 46 int Delete(const IOption &option, const Key &key) override; 49 int Clear(const IOption &option) override; 52 …int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const ove… 55 int PutBatch(const IOption &option, const std::vector<Entry> &entries) override; 58 int DeleteBatch(const IOption &option, const std::vector<Key> &keys) override;
|
H A D | sqlite_local_kvdb_connection.cpp | 38 int SQLiteLocalKvDBConnection::Get(const IOption &option, const Key &key, Value &value) const in Get() 63 int SQLiteLocalKvDBConnection::Put(const IOption &option, const Key &key, const Value &value) in Put() 96 int SQLiteLocalKvDBConnection::Delete(const IOption &option, const Key &key) in Delete() 129 int SQLiteLocalKvDBConnection::Clear(const IOption &option) in Clear() 159 int SQLiteLocalKvDBConnection::GetEntries(const IOption &option, const Key &keyPrefix, in GetEntries() 184 int SQLiteLocalKvDBConnection::PutBatch(const IOption &option, const std::vector<Entry> &entries) in PutBatch() 226 int SQLiteLocalKvDBConnection::DeleteBatch(const IOption &option, const std::vector<Key> &keys) in DeleteBatch()
|
H A D | sqlite_local_kvdb_snapshot.cpp | 35 IOption option; in Get() 44 IOption option; in GetEntries()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_single_ver_natural_store_connection.h | 37 int Get(const IOption &option, const Key &key, Value &value) const override; 40 int Clear(const IOption &option) override; 43 …int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const ove… 45 …int GetEntries(const IOption &option, const Query &query, std::vector<Entry> &entries) const overr… 47 int GetCount(const IOption &option, const Query &query, int &count) const override; 50 int PutBatch(const IOption &option, const std::vector<Entry> &entries) override; 53 int DeleteBatch(const IOption &option, const std::vector<Key> &keys) override; 103 int GetKeys(const IOption &option, const Key &keyPrefix, std::vector<Key> &keys) const override; 129 int PutBatchInner(const IOption &option, const std::vector<Entry> &entries) override; 130 int DeleteBatchInner(const IOption &option, const std::vector<Key> &keys) override; [all …]
|
H A D | sqlite_single_ver_natural_store_connection.cpp | 87 if (option.dataType == IOption::LOCAL_DATA) { in Get() 89 } else if (option.dataType == IOption::SYNC_DATA) { in Get() 127 int SQLiteSingleVerNaturalStoreConnection::Clear(const IOption &option) in Clear() 141 if (option.dataType != IOption::SYNC_DATA) { in GetEntries() 190 if (option.dataType != IOption::SYNC_DATA) { in GetCount() 239 if (option.dataType == IOption::LOCAL_DATA) { in PutBatch() 252 if (option.dataType == IOption::LOCAL_DATA) { in DeleteBatch() 829 if (option.dataType == IOption::SYNC_DATA) { in PutBatchInner() 877 if (option.dataType == IOption::SYNC_DATA) { in DeleteBatchInner() 1800 if (option.dataType == IOption::LOCAL_DATA) { in GetEntriesInner() [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
H A D | multi_ver_natural_store_connection.h | 46 int Get(const IOption &option, const Key &key, Value &value) const override; 49 int Put(const IOption &option, const Key &key, const Value &value) override; 52 int Delete(const IOption &option, const Key &key) override; 55 int Clear(const IOption &option) override; 58 …int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const ove… 61 int PutBatch(const IOption &option, const std::vector<Entry> &entries) override; 67 int DeleteBatch(const IOption &option, const std::vector<Key> &keys) override;
|
H A D | multi_ver_natural_store_connection.cpp | 41 int MultiVerNaturalStoreConnection::Get(const IOption &option, const Key &key, Value &value) const in Get() 70 int MultiVerNaturalStoreConnection::Put(const IOption &option, const Key &key, const Value &value) in Put() 102 int MultiVerNaturalStoreConnection::Delete(const IOption &option, const Key &key) in Delete() 132 int MultiVerNaturalStoreConnection::Clear(const IOption &option) in Clear() 158 int MultiVerNaturalStoreConnection::GetEntries(const IOption &option, in GetEntries() 179 int MultiVerNaturalStoreConnection::PutBatch(const IOption &option, const std::vector<Entry> &entri… in PutBatch() 217 int MultiVerNaturalStoreConnection::DeleteBatch(const IOption &option, const std::vector<Key> &keys) in DeleteBatch()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
H A D | kv_store_nb_delegate_impl.cpp | 86 IOption option; in Get() 93 IOption option; in GetEntries() 105 IOption option; in GetEntries() 127 IOption option; in GetEntries() 153 IOption option; in GetEntries() 180 IOption option; in GetCount() 217 IOption option; in Put() 247 IOption option; in DeleteBatch() 260 IOption option; in Delete() 267 IOption option; in GetLocal() [all …]
|
H A D | kv_store_delegate_impl.cpp | 58 IOption option; in Put() 75 IOption option; in PutBatch() 92 IOption option; in Delete() 109 IOption option; in DeleteBatch() 126 IOption option; in Clear()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
H A D | generic_kvdb_connection.h | 60 …int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const ove… 62 …int GetEntries(const IOption &option, const Query &query, std::vector<Entry> &entries) const overr… 64 …int GetResultSet(const IOption &option, const Key &keyPrefix, IKvDBResultSet *&resultSet) const ov… 66 …int GetResultSet(const IOption &option, const Query &query, IKvDBResultSet *&resultSet) const over… 68 int GetCount(const IOption &option, const Query &query, int &count) const override; 78 int GetKeys(const IOption &option, const Key &keyPrefix, std::vector<Key> &keys) const override;
|
H A D | generic_kvdb_connection.cpp | 227 int GenericKvDBConnection::GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entr… in GetEntries() 235 int GenericKvDBConnection::GetEntries(const IOption &option, const Query &query, std::vector<Entry>… in GetEntries() 243 int GenericKvDBConnection::GetResultSet(const IOption &option, const Key &keyPrefix, IKvDBResultSet… in GetResultSet() 251 int GenericKvDBConnection::GetResultSet(const IOption &option, const Query &query, IKvDBResultSet *… in GetResultSet() 259 int GenericKvDBConnection::GetCount(const IOption &option, const Query &query, int &count) const in GetCount() 354 int GenericKvDBConnection::GetKeys(const IOption &option, const Key &keyPrefix, std::vector<Key> &k… in GetKeys()
|