Home
last modified time | relevance | path

Searched refs:SQLiteSingleVerRelationalStorageExecutor (Results 1 – 12 of 12) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_relational_storage_engine.h56 … SQLiteSingleVerRelationalStorageExecutor *handle, std::set<std::string> &clearWaterMarkTables,
69 … void ReleaseExecutor(SQLiteSingleVerRelationalStorageExecutor *&handle, bool isExternal = false);
76 int CreateDistributedTable(SQLiteSingleVerRelationalStorageExecutor *&handle, bool isUpgraded,
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,
118 int UpdateKvData(SQLiteSingleVerRelationalStorageExecutor *&handle,
[all …]
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp286 int SQLiteSingleVerRelationalStorageExecutor::InitFillUploadAssetStatement(OpType opType, in InitFillUploadAssetStatement()
443 int SQLiteSingleVerRelationalStorageExecutor::GetClearWaterMarkTables( in GetClearWaterMarkTables()
552 int SQLiteSingleVerRelationalStorageExecutor::ClearAllTempSyncTrigger() in ClearAllTempSyncTrigger()
667 int SQLiteSingleVerRelationalStorageExecutor::UpdateSharedTable( in UpdateSharedTable()
912 PairStringVector SQLiteSingleVerRelationalStorageExecutor::SplitReferenceByField( in SplitReferenceByField()
1050 int64_t SQLiteSingleVerRelationalStorageExecutor::GetLocalDataKey(size_t index, in GetLocalDataKey()
1434 int SQLiteSingleVerRelationalStorageExecutor::CleanDownloadChangedAssets( in CleanDownloadChangedAssets()
1737 void SQLiteSingleVerRelationalStorageExecutor::SetPutDataMode(PutDataMode mode) in SetPutDataMode()
1747 int64_t SQLiteSingleVerRelationalStorageExecutor::GetDataFlag() in GetDataFlag()
1761 std::string SQLiteSingleVerRelationalStorageExecutor::GetUpdateDataFlagSql() in GetUpdateDataFlagSql()
[all …]
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp110 int SQLiteSingleVerRelationalStorageExecutor::GetInfoByStatement(sqlite3_stmt *statement, in GetInfoByStatement()
163 int SQLiteSingleVerRelationalStorageExecutor::GetPrimaryKeyHashValue(const VBucket &vBucket, in GetPrimaryKeyHashValue()
294 int SQLiteSingleVerRelationalStorageExecutor::DoCleanInner(ClearMode mode, in DoCleanInner()
384 int SQLiteSingleVerRelationalStorageExecutor::GetCursor(const std::string &tableName) in GetCursor()
485 int SQLiteSingleVerRelationalStorageExecutor::GetAssetOnTable(const std::string &tableName, in GetAssetOnTable()
571 int SQLiteSingleVerRelationalStorageExecutor::GetCloudAssets(const std::string &tableName, in GetCloudAssets()
593 int SQLiteSingleVerRelationalStorageExecutor::SetCursorIncFlag(bool flag) in SetCursorIncFlag()
610 int SQLiteSingleVerRelationalStorageExecutor::PutCloudSyncData(const std::string &tableName, in PutCloudSyncData()
1119 int SQLiteSingleVerRelationalStorageExecutor::OnlyUpdateLogTable(const VBucket &vBucket, in OnlyUpdateLogTable()
1144 void SQLiteSingleVerRelationalStorageExecutor::SetLogicDelete(bool isLogicDelete) in SetLogicDelete()
[all …]
H A Dsqlite_single_ver_relational_storage_executor.cpp80 SQLiteSingleVerRelationalStorageExecutor::SQLiteSingleVerRelationalStorageExecutor(sqlite3 *dbHandl… in SQLiteSingleVerRelationalStorageExecutor() function in DistributedDB::SQLiteSingleVerRelationalStorageExecutor
531 int SQLiteSingleVerRelationalStorageExecutor::StartTransaction(TransactType type) in StartTransaction()
544 int SQLiteSingleVerRelationalStorageExecutor::Commit() in Commit()
553 int SQLiteSingleVerRelationalStorageExecutor::Rollback() in Rollback()
565 void SQLiteSingleVerRelationalStorageExecutor::SetTableInfo(const TableInfo &tableInfo) in SetTableInfo()
911 int SQLiteSingleVerRelationalStorageExecutor::DeleteSyncLog(const DataItem &dataItem, in DeleteSyncLog()
942 int SQLiteSingleVerRelationalStorageExecutor::ProcessMissQueryData(const DataItem &item, in ProcessMissQueryData()
1218 int SQLiteSingleVerRelationalStorageExecutor::CheckDBModeForRelational() in CheckDBModeForRelational()
1501 int SQLiteSingleVerRelationalStorageExecutor::SetLogTriggerStatus(bool status) in SetLogTriggerStatus()
1586 int SQLiteSingleVerRelationalStorageExecutor::CheckEncryptedOrCorrupted() const in CheckEncryptedOrCorrupted()
[all …]
H A Dsqlite_single_relational_storage_engine.cpp39 return new (std::nothrow) SQLiteSingleVerRelationalStorageExecutor(dbHandle, isWrite, mode); in NewSQLiteStorageExecutor()
125 void SQLiteSingleRelationalStorageEngine::ReleaseExecutor(SQLiteSingleVerRelationalStorageExecutor … in ReleaseExecutor()
153 int SaveSchemaToMetaTable(SQLiteSingleVerRelationalStorageExecutor *handle, const RelationalSchemaO… in SaveSchemaToMetaTable()
165 int SaveTrackerSchemaToMetaTable(SQLiteSingleVerRelationalStorageExecutor *handle, in SaveTrackerSchemaToMetaTable()
513 auto *handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>(FindExecutor(true, in CheckAndCacheTrackerSchema()
602 …auto *handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>(FindExecutor(!condition.rea… in ExecuteSql()
647 SQLiteSingleVerRelationalStorageExecutor *handle, std::set<std::string> &clearWaterMarkTables, in SetReference()
776 …QLiteSingleRelationalStorageEngine::DoDeleteSharedTable(SQLiteSingleVerRelationalStorageExecutor *… in DoDeleteSharedTable()
908 int SQLiteSingleRelationalStorageEngine::UpdateKvData(SQLiteSingleVerRelationalStorageExecutor *&ha… in UpdateKvData()
994 RelationalSchemaObject &trackerSchemaObj, SQLiteSingleVerRelationalStorageExecutor *&handle) in CleanTrackerDeviceTable()
[all …]
H A Dsqlite_relational_store_connection.h76 SQLiteSingleVerRelationalStorageExecutor *GetExecutor(bool isWrite, int &errCode) const;
77 void ReleaseExecutor(SQLiteSingleVerRelationalStorageExecutor *&executor) const;
85 SQLiteSingleVerRelationalStorageExecutor *writeHandle_ = nullptr;
H A Dsqlite_relational_store.h46 SQLiteSingleVerRelationalStorageExecutor *GetHandle(bool isWrite, int &errCode) const;
47 void ReleaseHandle(SQLiteSingleVerRelationalStorageExecutor *&handle) const;
139 int GetHandleAndStartTransaction(SQLiteSingleVerRelationalStorageExecutor *&handle) const;
159 …int CleanWaterMark(SQLiteSingleVerRelationalStorageExecutor *&handle, std::set<std::string> &clear…
H A Dsqlite_relational_store.cpp345 SQLiteSingleVerRelationalStorageExecutor *SQLiteRelationalStore::GetHandle(bool isWrite, int &errCo… in GetHandle()
352 return static_cast<SQLiteSingleVerRelationalStorageExecutor *>( in GetHandle()
355 void SQLiteRelationalStore::ReleaseHandle(SQLiteSingleVerRelationalStorageExecutor *&handle) const in ReleaseHandle()
544 SQLiteSingleVerRelationalStorageExecutor *handle = nullptr; in RemoveDeviceData()
845 int SQLiteRelationalStore::GetHandleAndStartTransaction(SQLiteSingleVerRelationalStorageExecutor *&… in GetHandleAndStartTransaction()
885 SQLiteSingleVerRelationalStorageExecutor *handle = nullptr; in RemoveDeviceDataInner()
1308 int SQLiteRelationalStore::CleanWaterMark(SQLiteSingleVerRelationalStorageExecutor *&handle, in CleanWaterMark()
1340 SQLiteSingleVerRelationalStorageExecutor *handle = nullptr; in SetReference()
H A Dsqlite_single_ver_relational_storage_executor.h38 class SQLiteSingleVerRelationalStorageExecutor : public SQLiteStorageExecutor {
54 …SQLiteSingleVerRelationalStorageExecutor(sqlite3 *dbHandle, bool writable, DistributedTableMode mo…
55 ~SQLiteSingleVerRelationalStorageExecutor() override = default;
58 DISABLE_COPY_ASSIGN_MOVE(SQLiteSingleVerRelationalStorageExecutor);
H A Dsqlite_relational_store_connection.cpp70 SQLiteSingleVerRelationalStorageExecutor *SQLiteRelationalStoreConnection::GetExecutor(bool isWrite… in GetExecutor()
82 void SQLiteRelationalStoreConnection::ReleaseExecutor(SQLiteSingleVerRelationalStorageExecutor *&ex… in ReleaseExecutor()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h236 …int PutCloudSyncDataInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &tab…
242 int FillCloudLogAndAssetInner(SQLiteSingleVerRelationalStorageExecutor *handle, OpType opType,
245 …int UpdateRecordFlagAfterUpload(SQLiteSingleVerRelationalStorageExecutor *handle, const std::strin…
252 SQLiteSingleVerRelationalStorageExecutor *GetHandle(bool isWrite, int &errCode,
254 SQLiteSingleVerRelationalStorageExecutor *GetHandleExpectTransaction(bool isWrite, int &errCode,
256 void ReleaseHandle(SQLiteSingleVerRelationalStorageExecutor *&handle) const;
278 …int UpsertDataInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &tableName,
281 …int UpsertDataInTransaction(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &t…
286 int GetCompensatedSyncQueryInner(SQLiteSingleVerRelationalStorageExecutor *handle,
289 …int CreateTempSyncTriggerInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string…
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp135 auto handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>( in GetHandle()
153 auto handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>( in GetHandleExpectTransaction()
162 void RelationalSyncAbleStorage::ReleaseHandle(SQLiteSingleVerRelationalStorageExecutor *&handle) co… in ReleaseHandle()
228 SQLiteSingleVerRelationalStorageExecutor *handle = nullptr; in PutMetaData()
235 handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>(reusedHandle_); in PutMetaData()
1024 auto *handle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>( in StartTransaction()
1399 auto writeHandle = static_cast<SQLiteSingleVerRelationalStorageExecutor *>( in FillCloudLogAndAsset()
1765 handle->SetPutDataMode(SQLiteSingleVerRelationalStorageExecutor::PutDataMode::USER); in UpsertData()
1768 handle->SetPutDataMode(SQLiteSingleVerRelationalStorageExecutor::PutDataMode::SYNC); in UpsertData()
1769 handle->SetMarkFlagOption(SQLiteSingleVerRelationalStorageExecutor::MarkFlagOption::DEFAULT); in UpsertData()
[all …]