/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
H A D | rd_single_ver_storage_executor.h | 53 int GetKvData(SingleVerDataType type, const Key &key, Value &value, Timestamp ×tamp) const; 61 virtual int PutKvData(SingleVerDataType type, const Key &key, const Value &value, 129 int ResetForSavingData(SingleVerDataType type); 140 int PrepareForSavingCacheData(SingleVerDataType type); 142 int ResetForSavingCacheData(SingleVerDataType type); 199 int SaveKvData(SingleVerDataType type, const Key &key, const Value &value);
|
H A D | rd_single_ver_storage_executor.cpp | 270 int RdSingleVerStorageExecutor::GetKvData(SingleVerDataType type, const Key &key, Value &value, in GetKvData() 376 int RdSingleVerStorageExecutor::SaveKvData(SingleVerDataType type, const Key &key, const Value &val… in SaveKvData() 442 int RdSingleVerStorageExecutor::PutKvData(SingleVerDataType type, const Key &key, const Value &valu… in PutKvData() 549 int RdSingleVerStorageExecutor::ResetForSavingData(SingleVerDataType type) in ResetForSavingData() 575 int RdSingleVerStorageExecutor::PrepareForSavingCacheData(SingleVerDataType type) in PrepareForSavingCacheData() 580 int RdSingleVerStorageExecutor::ResetForSavingCacheData(SingleVerDataType type) in ResetForSavingCacheData() 742 int errCode = GetKvData(SingleVerDataType::SYNC_TYPE, key, value, recordTimestamp); in GetSyncDataPreByKey() 782 return SaveKvData(SingleVerDataType::SYNC_TYPE, entry.key, entry.value); in SaveSyncDataToDatabase()
|
H A D | rd_single_ver_natural_store_connection.cpp | 53 int RdSingleVerNaturalStoreConnection::CheckOption(const IOption &option, SingleVerDataType &type) in CheckOption() 56 type = SingleVerDataType::SYNC_TYPE; in CheckOption() 71 SingleVerDataType type; in GetEntriesInner() 266 SingleVerDataType dataType; in Get()
|
H A D | rd_utils.h | 42 int GetCollNameFromType(SingleVerDataType type, std::string &collName);
|
H A D | rd_utils.cpp | 105 int GetCollNameFromType(SingleVerDataType type, std::string &collName) in GetCollNameFromType() 108 case SingleVerDataType::SYNC_TYPE: in GetCollNameFromType()
|
H A D | rd_single_ver_natural_store_connection.h | 118 static int CheckOption(const IOption &option, SingleVerDataType &type);
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_single_ver_storage_executor.h | 37 …virtual int GetKvData(SingleVerDataType type, const Key &key, Value &value, Timestamp ×tamp) … 43 virtual int PutKvData(SingleVerDataType type, const Key &key, const Value &value, 46 virtual int GetEntries(bool isGetValue, SingleVerDataType type, const Key &keyPrefix, 120 int PrepareForSavingData(SingleVerDataType type); 122 int ResetForSavingData(SingleVerDataType type); 135 int PrepareForSavingCacheData(SingleVerDataType type); 136 int ResetForSavingCacheData(SingleVerDataType type); 194 …virtual int SaveKvData(SingleVerDataType type, const Key &key, const Value &value, Timestamp times… 258 SingleVerDataType type);
|
H A D | sqlite_single_ver_storage_executor.cpp | 111 if (type == SingleVerDataType::LOCAL_TYPE_SQLITE) { in GetKvData() 113 } else if (type == SingleVerDataType::SYNC_TYPE) { in GetKvData() 115 } else if (type == SingleVerDataType::META_TYPE) { in GetKvData() 147 if (type == SingleVerDataType::LOCAL_TYPE_SQLITE) { in GetKvData() 149 } else if (type == SingleVerDataType::SYNC_TYPE) { in GetKvData() 159 Timestamp timestamp, SingleVerDataType type) in BindPutKvData() 173 if (type == SingleVerDataType::LOCAL_TYPE_SQLITE) { in BindPutKvData() 253 if (type == SingleVerDataType::LOCAL_TYPE_SQLITE) { in SaveKvData() 282 if (type != SingleVerDataType::LOCAL_TYPE_SQLITE && type != SingleVerDataType::META_TYPE) { in PutKvData() 314 if ((type != SingleVerDataType::LOCAL_TYPE_SQLITE) && (type != SingleVerDataType::SYNC_TYPE)) { in GetEntries() [all …]
|
H A D | sqlite_single_ver_storage_executor_cache.cpp | 29 int SQLiteSingleVerStorageExecutor::PrepareForSavingCacheData(SingleVerDataType type) in PrepareForSavingCacheData() 32 if (type == SingleVerDataType::LOCAL_TYPE_SQLITE) { in PrepareForSavingCacheData() 39 } else if (type == SingleVerDataType::SYNC_TYPE) { in PrepareForSavingCacheData() 54 int SQLiteSingleVerStorageExecutor::ResetForSavingCacheData(SingleVerDataType type) in ResetForSavingCacheData() 57 if (type == SingleVerDataType::LOCAL_TYPE_SQLITE) { in ResetForSavingCacheData() 61 } else if (type == SingleVerDataType::SYNC_TYPE) { in ResetForSavingCacheData() 663 return ResetForSavingCacheData(SingleVerDataType::SYNC_TYPE); in SaveSyncDataItemInCacheMode()
|
H A D | sqlite_single_ver_natural_store_connection.cpp | 86 SingleVerDataType dataType; in Get() 88 dataType = SingleVerDataType::LOCAL_TYPE_SQLITE; in Get() 90 dataType = SingleVerDataType::SYNC_TYPE; in Get() 1011 …errCode = writeHandle_->PutKvData(SingleVerDataType::LOCAL_TYPE_SQLITE, dataItem.key, dataItem.val… in SaveLocalItem() 1037 int errCode = writeHandle_->PrepareForSavingData(SingleVerDataType::SYNC_TYPE); in SaveEntryNormally() 1058 int errCode = writeHandle_->PrepareForSavingCacheData(SingleVerDataType::SYNC_TYPE); in SaveEntryInCacheMode() 1642 …errCode = writeHandle_->PutKvData(SingleVerDataType::LOCAL_TYPE_SQLITE, syncRecord.key, syncRecord… in UnpublishOper() 1799 SingleVerDataType type; in GetEntriesInner() 1801 type = SingleVerDataType::LOCAL_TYPE_SQLITE; in GetEntriesInner() 1803 type = SingleVerDataType::SYNC_TYPE; in GetEntriesInner()
|
H A D | sqlite_single_ver_natural_store.cpp | 546 errCode = handle->GetKvData(SingleVerDataType::META_TYPE, key, value, timestamp); in GetMetaData() 565 …errCode = handle->PutKvData(SingleVerDataType::META_TYPE, key, value, 0, nullptr); // meta doesn't… in PutMetaData() 1265 errCode = handle->PrepareForSavingData(SingleVerDataType::SYNC_TYPE); in SaveSyncItems() 1281 innerCode = handle->ResetForSavingData(SingleVerDataType::SYNC_TYPE); in SaveSyncItems() 1681 errCode = handle->GetKvData(SingleVerDataType::META_TYPE, key, value, timestamp); in GetSchema() 1792 errCode = handle->PrepareForSavingCacheData(SingleVerDataType::SYNC_TYPE); in SaveSyncItemsInCacheMode() 1808 innerCode = handle->ResetForSavingCacheData(SingleVerDataType::SYNC_TYPE); in SaveSyncItemsInCacheMode()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_sqlite_single_ver_natural_executor_test.cpp | 135 int type = static_cast<int>(SingleVerDataType::SYNC_TYPE); 136 …EXPECT_EQ(g_nullHandle->GetKvData(SingleVerDataType(type + 1), key, value, timestamp), -E_INVALID_… 142 … EXPECT_EQ(g_nullHandle->GetKvData(SingleVerDataType(type), key, value, timestamp), -E_INVALID_DB); 148 EXPECT_EQ(g_handle->GetKvData(SingleVerDataType(type), key, value, timestamp), -E_INVALID_ARGS); 171 …EXPECT_EQ(g_nullHandle->PutKvData(SingleVerDataType::META_TYPE, KEY_1, value, 0, nullptr), -E_INVA… 178 …EXPECT_EQ(g_handle->PutKvData(SingleVerDataType::META_TYPE, key, value, 0, nullptr), -E_INVALID_AR… 195 …EXPECT_EQ(g_nullHandle->GetEntries(false, SingleVerDataType::META_TYPE, KEY_1, entries), -E_INVALI… 491 …EXPECT_EQ(g_nullHandle->PrepareForSavingData(SingleVerDataType::LOCAL_TYPE_SQLITE), -E_INVALID_DB); 497 EXPECT_EQ(g_handle->PrepareForSavingData(SingleVerDataType::SYNC_TYPE), E_OK); 889 …EXPECT_EQ(g_handle->PrepareForSavingCacheData(SingleVerDataType::LOCAL_TYPE_SQLITE), SQL_STATE_ERR… [all …]
|
H A D | distributeddb_storage_rd_single_ver_natural_executor_test.cpp | 129 int type = static_cast<int>(SingleVerDataType::SYNC_TYPE); 130 …EXPECT_EQ(g_nullHandle->GetKvData(SingleVerDataType(type + 1), key, value, timestamp), -E_INVALID_… 136 EXPECT_EQ(g_handle->GetKvData(SingleVerDataType(type), key, value, timestamp), -E_INVALID_ARGS); 142 …EXPECT_EQ(g_nullHandle->GetKvData(SingleVerDataType(type), KEY_1, value, timestamp), -E_INVALID_DB… 159 …EXPECT_EQ(g_nullHandle->PutKvData(SingleVerDataType::SYNC_TYPE, KEY_1, value, 0, nullptr), -E_NOT_… 165 …EXPECT_EQ(g_nullHandle->PutKvData(SingleVerDataType::META_TYPE, KEY_1, value, 0, nullptr), -E_NOT_… 476 …EXPECT_EQ(g_handle->PrepareForSavingCacheData(SingleVerDataType::LOCAL_TYPE_SQLITE), -E_NOT_SUPPOR… 481 …EXPECT_EQ(g_handle->ResetForSavingCacheData(SingleVerDataType::LOCAL_TYPE_SQLITE), -E_NOT_SUPPORT);
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | storage_executor.h | 33 enum class SingleVerDataType { enum
|