| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_engine.h | 79 int ReleaseExecutor(SQLiteSingleVerStorageExecutor *&handle);
80 int ReleaseHandleTransiently(SQLiteSingleVerStorageExecutor *&handle, uint64_t idleTime,
84 int MigrateLocalData(SQLiteSingleVerStorageExecutor *handle) const;
85 int MigrateSyncDataByVersion(SQLiteSingleVerStorageExecutor *&handle,
87 int MigrateSyncData(SQLiteSingleVerStorageExecutor *&handle, bool &isNeedTriggerSync);
88 int FinishMigrateData(SQLiteSingleVerStorageExecutor *&handle, EngineState stateBeforeMigrate);
89 int InitExecuteMigrate(SQLiteSingleVerStorageExecutor *handle, EngineState preMigrateState);
90 …void EndMigrate(SQLiteSingleVerStorageExecutor *&handle, EngineState stateBeforeMigrate, int errCo…
93 …int EraseDeviceWaterMark(SQLiteSingleVerStorageExecutor *&handle, const std::vector<DataItem> &dat…
95 int GetRemoveDataDevices(SQLiteSingleVerStorageExecutor *handle, const DataItem &item,
[all …]
|
| H A D | sqlite_single_ver_storage_executor.cpp | 70 SQLiteSingleVerStorageExecutor::SQLiteSingleVerStorageExecutor(sqlite3 *dbHandle, bool writable, bo… in SQLiteSingleVerStorageExecutor() function in DistributedDB::SQLiteSingleVerStorageExecutor
84 SQLiteSingleVerStorageExecutor::SQLiteSingleVerStorageExecutor(sqlite3 *dbHandle, bool writable, bo… in SQLiteSingleVerStorageExecutor() function in DistributedDB::SQLiteSingleVerStorageExecutor
99 SQLiteSingleVerStorageExecutor::~SQLiteSingleVerStorageExecutor() in ~SQLiteSingleVerStorageExecutor()
1004 void SQLiteSingleVerStorageExecutor::CloseResultSet() in CloseResultSet()
1036 int SQLiteSingleVerStorageExecutor::Commit() in Commit()
1049 int SQLiteSingleVerStorageExecutor::Rollback() in Rollback()
1547 int SQLiteSingleVerStorageExecutor::Reset() in Reset()
2061 void SQLiteSingleVerStorageExecutor::FinalizeAllStatements() in FinalizeAllStatements()
2098 int SQLiteSingleVerStorageExecutor::CheckIntegrity() const in CheckIntegrity()
2107 int SQLiteSingleVerStorageExecutor::ForceCheckPoint() const in ForceCheckPoint()
[all …]
|
| H A D | sqlite_single_ver_storage_executor_cache.cpp | 29 int SQLiteSingleVerStorageExecutor::PrepareForSavingCacheData(SingleVerDataType type) in PrepareForSavingCacheData()
54 int SQLiteSingleVerStorageExecutor::ResetForSavingCacheData(SingleVerDataType type) in ResetForSavingCacheData()
70 int SQLiteSingleVerStorageExecutor::ResetForMigrateCacheData() in ResetForMigrateCacheData()
126 int SQLiteSingleVerStorageExecutor::GetMinVersionCacheData( in GetMinVersionCacheData()
460 int SQLiteSingleVerStorageExecutor::VacuumLocalData() const in VacuumLocalData()
481 int SQLiteSingleVerStorageExecutor::MigrateLocalData() in MigrateLocalData()
545 int SQLiteSingleVerStorageExecutor::BindPrimaryKeySyncDataInCacheMode( in BindPrimaryKeySyncDataInCacheMode()
560 int SQLiteSingleVerStorageExecutor::BindTimestampSyncDataInCacheMode( in BindTimestampSyncDataInCacheMode()
808 int SQLiteSingleVerStorageExecutor::InitMigrateTimestampOffset() in InitMigrateTimestampOffset()
885 int SQLiteSingleVerStorageExecutor::InitMigrateData() in InitMigrateData()
[all …]
|
| H A D | sqlite_single_ver_storage_executor_extend.cpp | 39 int SQLiteSingleVerStorageExecutor::CloudExcuteRemoveOrUpdate(const std::string &sql, const std::st… in CloudExcuteRemoveOrUpdate()
84 int SQLiteSingleVerStorageExecutor::CloudCheckDataExist(const std::string &sql, const std::string &… in CloudCheckDataExist()
135 int SQLiteSingleVerStorageExecutor::RemoveDeviceDataInner(ClearMode mode) in RemoveDeviceDataInner()
159 int SQLiteSingleVerStorageExecutor::RemoveDeviceDataInner(const std::string &deviceName, ClearMode … in RemoveDeviceDataInner()
183 int SQLiteSingleVerStorageExecutor::RemoveDeviceDataWithUserInner(const std::string &user, ClearMod… in RemoveDeviceDataWithUserInner()
210 int SQLiteSingleVerStorageExecutor::RemoveDeviceDataWithUserInner(const std::string &deviceName, in RemoveDeviceDataWithUserInner()
236 int SQLiteSingleVerStorageExecutor::RemoveDeviceData(const std::string &deviceName, ClearMode mode) in RemoveDeviceData()
250 int SQLiteSingleVerStorageExecutor::RemoveDeviceData(const std::string &deviceName, const std::stri… in RemoveDeviceData()
273 int SQLiteSingleVerStorageExecutor::GetEntries(const std::string &device, std::vector<Entry> &entri… in GetEntries()
306 int SQLiteSingleVerStorageExecutor::RemoveCloudUploadFlag(const std::vector<uint8_t> &hashKey) in RemoveCloudUploadFlag()
[all …]
|
| H A D | sqlite_single_ver_storage_executor_subscribe.cpp | 26 int SQLiteSingleVerStorageExecutor::CheckQueryObjectLegal(QueryObject &queryObj) const in CheckQueryObjectLegal()
45 int SQLiteSingleVerStorageExecutor::CheckMissQueryDataItem(sqlite3_stmt *stmt, const std::string &d… in CheckMissQueryDataItem()
74 int SQLiteSingleVerStorageExecutor::CheckMissQueryDataItems(sqlite3_stmt *&stmt, const SqliteQueryH… in CheckMissQueryDataItems()
96 int SQLiteSingleVerStorageExecutor::CheckDataWithQuery(QueryObject query, std::vector<DataItem> &da… in CheckDataWithQuery()
149 int SQLiteSingleVerStorageExecutor::AddSubscribeTrigger(QueryObject &query, const std::string &subs… in AddSubscribeTrigger()
189 int SQLiteSingleVerStorageExecutor::RemoveSubscribeTrigger(const std::vector<std::string> &subscrib… in RemoveSubscribeTrigger()
209 int SQLiteSingleVerStorageExecutor::RemoveTrigger(const std::vector<std::string> &triggers) in RemoveTrigger()
222 int SQLiteSingleVerStorageExecutor::RemoveSubscribeTriggerWaterMark(const std::vector<std::string> … in RemoveSubscribeTriggerWaterMark()
250 int SQLiteSingleVerStorageExecutor::GetTriggers(const std::string &namePreFix, std::vector<std::str… in GetTriggers()
|
| H A D | sqlite_single_ver_storage_engine.cpp | 45 int SQLiteSingleVerStorageEngine::MigrateLocalData(SQLiteSingleVerStorageExecutor *handle) const in MigrateLocalData()
76 int SQLiteSingleVerStorageEngine::GetRemoveDataDevices(SQLiteSingleVerStorageExecutor *handle, cons… in GetRemoveDataDevices()
99 int SQLiteSingleVerStorageEngine::EraseDeviceWaterMark(SQLiteSingleVerStorageExecutor *&handle, in EraseDeviceWaterMark()
127 …handle = static_cast<SQLiteSingleVerStorageExecutor *>(FindExecutor(true, OperatePerm::NORMAL_PERM, in EraseDeviceWaterMark()
138 int SQLiteSingleVerStorageEngine::MigrateSyncDataByVersion(SQLiteSingleVerStorageExecutor *&handle, in MigrateSyncDataByVersion()
204 …handle = static_cast<SQLiteSingleVerStorageExecutor *>(FindExecutor(true, OperatePerm::NORMAL_PERM… in ReleaseHandleTransiently()
289 int SQLiteSingleVerStorageEngine::AttachMainDbAndCacheDb(SQLiteSingleVerStorageExecutor *handle, in AttachMainDbAndCacheDb()
352 int SQLiteSingleVerStorageEngine::ReleaseExecutor(SQLiteSingleVerStorageExecutor *&handle) in ReleaseExecutor()
368 int SQLiteSingleVerStorageEngine::FinishMigrateData(SQLiteSingleVerStorageExecutor *&handle, in FinishMigrateData()
426 int SQLiteSingleVerStorageEngine::InitExecuteMigrate(SQLiteSingleVerStorageExecutor *handle, in InitExecuteMigrate()
[all …]
|
| H A D | kv_storage_handle.h | 26 virtual std::pair<int, SQLiteSingleVerStorageExecutor*> GetStorageExecutor(bool isWrite) = 0;
28 virtual void RecycleStorageExecutor(SQLiteSingleVerStorageExecutor *executor) = 0;
|
| H A D | sqlite_single_ver_natural_store_extend.cpp | 340 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in CheckAndInitQueryCondition()
406 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in AddSubscribe()
464 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in RemoveDeviceDataInner()
513 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in RemoveDeviceDataInner()
542 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in RemoveDeviceDataInner()
590 std::pair<int, SQLiteSingleVerStorageExecutor*> SQLiteSingleVerNaturalStore::GetStorageExecutor(boo… in GetStorageExecutor()
593 SQLiteSingleVerStorageExecutor *handle = GetHandle(isWrite, errCode); in GetStorageExecutor()
597 void SQLiteSingleVerNaturalStore::RecycleStorageExecutor(SQLiteSingleVerStorageExecutor *executor) in RecycleStorageExecutor()
|
| H A D | sqlite_single_ver_natural_store.h | 116 SQLiteSingleVerStorageExecutor *GetHandle(bool isWrite, int &errCode,
119 void ReleaseHandle(SQLiteSingleVerStorageExecutor *&handle) const;
205 std::pair<int, SQLiteSingleVerStorageExecutor*> GetStorageExecutor(bool isWrite) override;
207 void RecycleStorageExecutor(SQLiteSingleVerStorageExecutor *executor) override;
291 int SaveSyncItemsInCacheMode(SQLiteSingleVerStorageExecutor *handle, const QueryObject &query,
|
| H A D | sqlite_single_ver_result_set.h | 33 class SQLiteSingleVerStorageExecutor; variable
112 SQLiteSingleVerStorageExecutor *handle_ = nullptr;
|
| H A D | sqlite_single_ver_natural_store.cpp | 560 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in PutMetaData()
609 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in GetAllMetaKeys()
668 SQLiteSingleVerStorageExecutor *handle = GetHandle(false, errCode); in GetSyncData()
736 SQLiteSingleVerStorageExecutor *handle = GetHandle(false, errCode); in GetSyncDataForQuerySync()
830 SQLiteSingleVerStorageExecutor *handle = GetHandle(false, errCode); in GetSyncDataNext()
924 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in GetExistsDeviceList()
982 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in RemoveDeviceDataInCacheMode()
1000 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in RemoveDeviceDataNormally()
1085 return static_cast<SQLiteSingleVerStorageExecutor *>(handle); in GetHandle()
1250 SQLiteSingleVerStorageExecutor *handle = GetHandle(true, errCode); in SaveSyncItems()
[all …]
|
| H A D | sqlite_single_ver_natural_store_connection.h | 183 SQLiteSingleVerStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
185 void ReleaseExecutor(SQLiteSingleVerStorageExecutor *&executor) const;
216 bool CheckLogOverLimit(SQLiteSingleVerStorageExecutor *executor) const;
240 SQLiteSingleVerStorageExecutor *writeHandle_; // only existed while in transaction.
|
| H A D | sqlite_single_ver_storage_executor.h | 27 class SQLiteSingleVerStorageExecutor : public SQLiteStorageExecutor {
29 SQLiteSingleVerStorageExecutor(sqlite3 *dbHandle, bool writable, bool isMemDb);
30 …SQLiteSingleVerStorageExecutor(sqlite3 *dbHandle, bool writable, bool isMemDb, ExecutorState execu…
31 ~SQLiteSingleVerStorageExecutor() override;
34 DISABLE_COPY_ASSIGN_MOVE(SQLiteSingleVerStorageExecutor);
|
| H A D | sqlite_single_ver_natural_store_connection.cpp | 114 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in Get()
176 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetEntries()
225 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetCount()
687 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in CheckIntegrity()
717 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in ForceCheckPoint()
793 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetDeviceIdentifier()
1230 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in StartTransactionInCacheMode()
1253 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in StartTransactionNormally()
1825 SQLiteSingleVerStorageExecutor *handle = GetExecutor(false, errCode); in GetEntriesInner()
1854 SQLiteSingleVerStorageExecutor *handle = GetExecutor(true, errCode); in UpdateKey()
[all …]
|
| H A D | sqlite_single_ver_forward_cursor.h | 55 mutable SQLiteSingleVerStorageExecutor *handle_;
|
| H A D | sqlite_cloud_kv_store.cpp | 114 SQLiteSingleVerStorageExecutor *handle; in Commit()
132 SQLiteSingleVerStorageExecutor *handle; in Rollback()
458 SQLiteSingleVerStorageExecutor *handle = nullptr; in GetLocalCloudVersion()
|
| H A D | sqlite_cloud_kv_store.h | 122 SQLiteSingleVerStorageExecutor *transactionHandle_;
|
| /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 | 39 SQLiteSingleVerStorageExecutor *g_handle = nullptr;
40 SQLiteSingleVerStorageExecutor *g_nullHandle = nullptr;
93 g_handle = static_cast<SQLiteSingleVerStorageExecutor *>( in SetUp()
98 g_nullHandle = new (nothrow) SQLiteSingleVerStorageExecutor(nullptr, false, false); in SetUp()
441 auto executor = std::make_unique<SQLiteSingleVerStorageExecutor>(
927 auto executor = std::make_unique<SQLiteSingleVerStorageExecutor>(
940 auto executor2 = std::make_unique<SQLiteSingleVerStorageExecutor>(
1073 auto executor = std::make_unique<SQLiteSingleVerStorageExecutor>(db, false, false);
1198 SQLiteSingleVerStorageExecutor obj(nullptr, true, true, ExecutorState::CACHEDB);
|
| H A D | distributeddb_storage_query_sync_test.cpp | 436 …auto oneBlockSize = SQLiteSingleVerStorageExecutor::GetDataItemSerialSize(item, Parcel::GetAppende…
|