| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| D | sqlite_single_relational_storage_engine.h | 56 … SQLiteSingleVerRelationalStorageExecutor *handle, std::set<std::string> &clearWaterMarkTables,
69 int ReleaseExecutor(SQLiteSingleVerRelationalStorageExecutor *&handle);
76 int CreateDistributedTable(SQLiteSingleVerRelationalStorageExecutor *&handle, bool isUpgraded,
82 …int CreateDistributedSharedTable(SQLiteSingleVerRelationalStorageExecutor *&handle, const std::str…
88 SQLiteSingleVerRelationalStorageExecutor *&handle);
99 int UpgradeSharedTableInner(SQLiteSingleVerRelationalStorageExecutor *&handle,
104 int DoDeleteSharedTable(SQLiteSingleVerRelationalStorageExecutor *&handle,
107 int DoUpdateSharedTable(SQLiteSingleVerRelationalStorageExecutor *&handle,
111 int DoAlterSharedTableName(SQLiteSingleVerRelationalStorageExecutor *&handle,
114 int DoCreateSharedTable(SQLiteSingleVerRelationalStorageExecutor *&handle,
[all …]
|
| D | sqlite_single_ver_relational_storage_extend_executor.cpp | 34 int SQLiteSingleVerRelationalStorageExecutor::GetQueryInfoSql(const std::string &tableName, const V… in GetQueryInfoSql()
68 int SQLiteSingleVerRelationalStorageExecutor::GetFillDownloadAssetStatement(const std::string &tabl… in GetFillDownloadAssetStatement()
95 int SQLiteSingleVerRelationalStorageExecutor::FillCloudAssetForDownload(const TableSchema &tableSch… in FillCloudAssetForDownload()
140 int SQLiteSingleVerRelationalStorageExecutor::FillCloudAssetForUpload(OpType opType, const TableSch… in FillCloudAssetForUpload()
190 int SQLiteSingleVerRelationalStorageExecutor::FillCloudVersionForUpload(const CloudSyncData &data) in FillCloudVersionForUpload()
229 int SQLiteSingleVerRelationalStorageExecutor::BindUpdateVersionStatement(const VBucket &vBucket, co… in BindUpdateVersionStatement()
269 int SQLiteSingleVerRelationalStorageExecutor::InitFillUploadAssetStatement(OpType opType, in InitFillUploadAssetStatement()
305 bool SQLiteSingleVerRelationalStorageExecutor::IsGetCloudDataContinue(uint32_t curNum, uint32_t cur… in IsGetCloudDataContinue()
323 int SQLiteSingleVerRelationalStorageExecutor::AnalysisTrackerTable(const TrackerTable &trackerTable, in AnalysisTrackerTable()
329 int SQLiteSingleVerRelationalStorageExecutor::CreateTrackerTable(const TrackerTable &trackerTable, … in CreateTrackerTable()
[all …]
|
| D | sqlite_single_ver_relational_storage_executor_extend.cpp | 34 int SQLiteSingleVerRelationalStorageExecutor::GetInfoByPrimaryKeyOrGid(const TableSchema &tableSche… in GetInfoByPrimaryKeyOrGid()
89 void SQLiteSingleVerRelationalStorageExecutor::GetLogInfoByStatement(sqlite3_stmt *statement, LogIn… in GetLogInfoByStatement()
105 int SQLiteSingleVerRelationalStorageExecutor::GetInfoByStatement(sqlite3_stmt *statement, in GetInfoByStatement()
143 std::string SQLiteSingleVerRelationalStorageExecutor::GetInsertSqlForCloudSync(const TableSchema &t… in GetInsertSqlForCloudSync()
159 int SQLiteSingleVerRelationalStorageExecutor::GetPrimaryKeyHashValue(const VBucket &vBucket, in GetPrimaryKeyHashValue()
183 int SQLiteSingleVerRelationalStorageExecutor::GetQueryLogStatement(const TableSchema &tableSchema, in GetQueryLogStatement()
221 int SQLiteSingleVerRelationalStorageExecutor::GetQueryLogSql(const std::string &tableName, const VB… in GetQueryLogSql()
246 int SQLiteSingleVerRelationalStorageExecutor::ExecutePutCloudData(const std::string &tableName, in ExecutePutCloudData()
289 int SQLiteSingleVerRelationalStorageExecutor::DoCleanInner(ClearMode mode, in DoCleanInner()
325 int SQLiteSingleVerRelationalStorageExecutor::DoCleanLogs(const std::vector<std::string> &tableName… in DoCleanLogs()
[all …]
|
| D | sqlite_single_ver_relational_storage_executor.cpp | 66 SQLiteSingleVerRelationalStorageExecutor::SQLiteSingleVerRelationalStorageExecutor(sqlite3 *dbHandl… in SQLiteSingleVerRelationalStorageExecutor() function in DistributedDB::SQLiteSingleVerRelationalStorageExecutor
152 int SQLiteSingleVerRelationalStorageExecutor::GeneLogInfoForExistedData(sqlite3 *db, const std::str… in GeneLogInfoForExistedData()
180 int SQLiteSingleVerRelationalStorageExecutor::CreateDistributedTable(DistributedTableMode mode, boo… in CreateDistributedTable()
239 int SQLiteSingleVerRelationalStorageExecutor::UpgradeDistributedTable(const std::string &tableName, in UpgradeDistributedTable()
446 int SQLiteSingleVerRelationalStorageExecutor::AlterAuxTableForUpgrade(const TableInfo &oldTableInfo, in AlterAuxTableForUpgrade()
474 int SQLiteSingleVerRelationalStorageExecutor::StartTransaction(TransactType type) in StartTransaction()
487 int SQLiteSingleVerRelationalStorageExecutor::Commit() in Commit()
496 int SQLiteSingleVerRelationalStorageExecutor::Rollback() in Rollback()
508 void SQLiteSingleVerRelationalStorageExecutor::SetTableInfo(const TableInfo &tableInfo) in SetTableInfo()
663 int SQLiteSingleVerRelationalStorageExecutor::GetKvData(const Key &key, Value &value) const in GetKvData()
[all …]
|
| D | sqlite_single_relational_storage_engine.cpp | 38 return new (std::nothrow) SQLiteSingleVerRelationalStorageExecutor(dbHandle, isWrite, mode); in NewSQLiteStorageExecutor()
124 int SQLiteSingleRelationalStorageEngine::ReleaseExecutor(SQLiteSingleVerRelationalStorageExecutor *… in ReleaseExecutor()
152 int SaveSchemaToMetaTable(SQLiteSingleVerRelationalStorageExecutor *handle, const RelationalSchemaO… in SaveSchemaToMetaTable()
164 int SaveTrackerSchemaToMetaTable(SQLiteSingleVerRelationalStorageExecutor *handle, in SaveTrackerSchemaToMetaTable()
178 int SaveSyncTableTypeAndDropFlagToMeta(SQLiteSingleVerRelationalStorageExecutor *handle, const std:… in SaveSyncTableTypeAndDropFlagToMeta()
236 …leRelationalStorageEngine::CreateDistributedSharedTable(SQLiteSingleVerRelationalStorageExecutor *… in CreateDistributedSharedTable()
266 …auto *handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>(FindExecutor(true, OperateP… in CreateDistributedTable()
303 …teSingleRelationalStorageEngine::CreateDistributedTable(SQLiteSingleVerRelationalStorageExecutor *… in CreateDistributedTable()
339 …auto *handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>(FindExecutor(true, OperateP… in UpgradeDistributedTable()
380 …auto handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>(FindExecutor(true, OperatePe… in CleanDistributedDeviceTable()
[all …]
|
| D | sqlite_relational_store_connection.h | 72 SQLiteSingleVerRelationalStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
73 void ReleaseExecutor(SQLiteSingleVerRelationalStorageExecutor *&executor) const;
81 SQLiteSingleVerRelationalStorageExecutor *writeHandle_ = nullptr;
|
| D | sqlite_relational_store.h | 46 SQLiteSingleVerRelationalStorageExecutor *GetHandle(bool isWrite, int &errCode) const;
47 void ReleaseHandle(SQLiteSingleVerRelationalStorageExecutor *&handle) const;
135 int GetHandleAndStartTransaction(SQLiteSingleVerRelationalStorageExecutor *&handle) const;
|
| D | sqlite_single_ver_relational_storage_executor.h | 37 class SQLiteSingleVerRelationalStorageExecutor : public SQLiteStorageExecutor {
47 …SQLiteSingleVerRelationalStorageExecutor(sqlite3 *dbHandle, bool writable, DistributedTableMode mo…
48 ~SQLiteSingleVerRelationalStorageExecutor() override = default;
51 DISABLE_COPY_ASSIGN_MOVE(SQLiteSingleVerRelationalStorageExecutor);
|
| D | sqlite_relational_store_connection.cpp | 70 SQLiteSingleVerRelationalStorageExecutor *SQLiteRelationalStoreConnection::GetExecutor(bool isWrite… in GetExecutor()
82 void SQLiteRelationalStoreConnection::ReleaseExecutor(SQLiteSingleVerRelationalStorageExecutor *&ex… in ReleaseExecutor()
|
| D | sqlite_relational_store.cpp | 329 SQLiteSingleVerRelationalStorageExecutor *SQLiteRelationalStore::GetHandle(bool isWrite, int &errCo… in GetHandle()
336 …return static_cast<SQLiteSingleVerRelationalStorageExecutor *>(sqliteStorageEngine_->FindExecutor(… in GetHandle()
339 void SQLiteRelationalStore::ReleaseHandle(SQLiteSingleVerRelationalStorageExecutor *&handle) const in ReleaseHandle()
528 SQLiteSingleVerRelationalStorageExecutor *handle = nullptr; in RemoveDeviceData()
832 int SQLiteRelationalStore::GetHandleAndStartTransaction(SQLiteSingleVerRelationalStorageExecutor *&… in GetHandleAndStartTransaction()
872 SQLiteSingleVerRelationalStorageExecutor *handle = nullptr; in RemoveDeviceDataInner()
1291 SQLiteSingleVerRelationalStorageExecutor *handle = nullptr; in SetReference()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| D | relational_sync_able_storage.h | 213 …int GetInfoByPrimaryKeyOrGidInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::str…
216 …int PutCloudSyncDataInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &tab…
222 int FillCloudLogAndAssetInner(SQLiteSingleVerRelationalStorageExecutor *handle, OpType opType,
225 …int UpdateRecordFlagAfterUpload(SQLiteSingleVerRelationalStorageExecutor *handle, const std::strin…
232 SQLiteSingleVerRelationalStorageExecutor *GetHandle(bool isWrite, int &errCode,
234 SQLiteSingleVerRelationalStorageExecutor *GetHandleExpectTransaction(bool isWrite, int &errCode,
236 void ReleaseHandle(SQLiteSingleVerRelationalStorageExecutor *&handle) const;
258 …int UpsertDataInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &tableName,
261 …int UpsertDataInTransaction(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &t…
266 int GetCompensatedSyncQueryInner(SQLiteSingleVerRelationalStorageExecutor *handle,
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| D | relational_sync_able_storage.cpp | 133 SQLiteSingleVerRelationalStorageExecutor *RelationalSyncAbleStorage::GetHandle(bool isWrite, int &e… in GetHandle()
140 auto handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>( in GetHandle()
148 SQLiteSingleVerRelationalStorageExecutor *RelationalSyncAbleStorage::GetHandleExpectTransaction(boo… in GetHandleExpectTransaction()
158 auto handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>( in GetHandleExpectTransaction()
167 void RelationalSyncAbleStorage::ReleaseHandle(SQLiteSingleVerRelationalStorageExecutor *&handle) co… in ReleaseHandle()
227 SQLiteSingleVerRelationalStorageExecutor *handle = nullptr; in PutMetaData()
234 handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>(reusedHandle_); in PutMetaData()
404 …auto handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>(storageEngine_->FindExecutor… in GetSyncDataForQuerySync()
1014 auto *handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>( in StartTransaction()
1184 …elationalSyncAbleStorage::GetInfoByPrimaryKeyOrGidInner(SQLiteSingleVerRelationalStorageExecutor *… in GetInfoByPrimaryKeyOrGidInner()
[all …]
|