| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_continue_token.cpp | 34 int SQLiteSingleVerRelationalContinueToken::GetStatement(sqlite3 *db, sqlite3_stmt *&queryStmt, sql… in GetStatement() argument
39 return GetDeletedDataStmt(db, queryStmt); in GetStatement()
42 int errCode = GetQuerySyncStatement(db, queryStmt); in GetStatement()
53 SQLiteUtils::ResetStatement(queryStmt, true, errCode); in GetStatement()
177 sqlite3_stmt *&queryStmt, bool &isFirstTime) in GetCloudStatement() argument
180 queryStmt = queryStmt_; in GetCloudStatement()
193 queryStmt = queryStmt_; in GetCloudStatement()
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 790 if (queryStmt == nullptr) { in GetLogInfoPre()
808 errCode = GetLogData(queryStmt, logInfoGet); in GetLogInfoPre()
958 SQLiteUtils::ResetStatement(queryStmt, false, errCode); in GetSyncDataPre()
963 sqlite3_stmt *queryStmt, bool &isDefeated) in CheckDataConflictDefeated() argument
1150 return StepNext(isMemDb_, queryStmt, queryTime); in GetQueryDataAndStepNext()
1169 sqlite3_stmt *queryStmt = nullptr; in GetSyncDataByQuery() local
1213 SQLiteUtils::ResetStatement(queryStmt, true, errCode); in GetSyncDataByQuery()
1609 sqlite3_stmt *queryStmt = nullptr; in GetSyncCloudGid() local
1622 errCode = SQLiteUtils::StepNext(queryStmt, isMemDb_); in GetSyncCloudGid()
1627 GetCloudGid(queryStmt, cloudGid); in GetSyncCloudGid()
[all …]
|
| H A D | sqlite_single_ver_relational_continue_token.h | 35 …int GetStatement(sqlite3 *db, sqlite3_stmt *&queryStmt, sqlite3_stmt *&fullStmt, bool &isGettingDe…
43 …int GetCloudStatement(sqlite3 *db, CloudSyncData &cloudDataResult, sqlite3_stmt *&queryStmt, bool …
|
| H A D | sqlite_single_ver_relational_storage_executor.h | 254 int GetSyncDataPre(const DataItem &dataItem, sqlite3_stmt *queryStmt, DataItem &itemGet);
256 int CheckDataConflictDefeated(const DataItem &item, sqlite3_stmt *queryStmt, bool &isDefeated);
265 int GetLogInfoPre(sqlite3_stmt *queryStmt, const DataItem &dataItem, LogInfo &logInfoGet);
267 …int SaveSyncLog(sqlite3_stmt *statement, sqlite3_stmt *queryStmt, const DataItem &dataItem, int64_…
275 …taAndStepNext(bool isFirstTime, bool isGettingDeletedData, sqlite3_stmt *queryStmt, DataItem &item,
|
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 1495 sqlite3_stmt *queryStmt = nullptr; in GetSyncCloudData() local
1497 int errCode = token.GetCloudStatement(dbHandle_, cloudDataResult, queryStmt, isStepNext); in GetSyncCloudData()
1506 errCode = SQLiteUtils::StepNext(queryStmt, isMemDb_); in GetSyncCloudData()
1513 … errCode = GetCloudDataForSync(uploadRecorder, queryStmt, cloudDataResult, ++stepNum, totalSize); in GetSyncCloudData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 31 if (queryStmt != nullptr) { in ResetStatements()
32 SQLiteUtils::ResetStatement(queryStmt, isNeedFinalize, errCode); in ResetStatements()
208 …yncDataInserter::GetSaveLogStatement(sqlite3 *db, sqlite3_stmt *&logStmt, sqlite3_stmt *&queryStmt) in GetSaveLogStatement() argument
226 errCode = SQLiteUtils::GetStatement(db, selectSql, queryStmt); in GetSaveLogStatement()
236 int errCode = GetSaveLogStatement(db, stmt.saveLogStmt, stmt.queryStmt); in PrepareStatement()
|
| H A D | relational_sync_data_inserter.h | 29 sqlite3_stmt *queryStmt = nullptr; member
74 int GetSaveLogStatement(sqlite3 *db, sqlite3_stmt *&logStmt, sqlite3_stmt *&queryStmt);
|
| H A D | relational_sync_able_storage.cpp | 421 …[token](sqlite3 *db, sqlite3_stmt *&queryStmt, sqlite3_stmt *&fullStmt, bool &isGettingDeletedData… in GetSyncDataForQuerySync() argument
422 return token->GetStatement(db, queryStmt, fullStmt, isGettingDeletedData); in GetSyncDataForQuerySync()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_executor.cpp | 628 …sqlite3_stmt *queryStmt = nullptr; // statement for get modified data which is matched query in th… in GetSyncDataWithQuery() local
629 int errCode = GetQueryDataStatement(dbHandle_, query, timeRange, queryStmt); in GetSyncDataWithQuery()
636 errCode = GetSyncDataItems(dataItems, queryStmt, appendLength, dataSizeInfo); in GetSyncDataWithQuery()
644 errCode = GetSyncDataWithQuery(fullStmt, queryStmt, appendLength, dataSizeInfo, dataItems); in GetSyncDataWithQuery()
650 SQLiteUtils::ResetStatement(queryStmt, true, errCode); in GetSyncDataWithQuery()
654 …LiteSingleVerStorageExecutor::GetSyncDataWithQuery(sqlite3_stmt *fullStmt, sqlite3_stmt *queryStmt, in GetSyncDataWithQuery() argument
664 errCode = GetNextDataItem(queryStmt, isMemDb_, matchItem); in GetSyncDataWithQuery()
|
| H A D | sqlite_single_ver_storage_executor.h | 331 int GetSyncDataWithQuery(sqlite3_stmt *fullStmt, sqlite3_stmt *queryStmt,
|