Searched refs:SQLiteSingleVerRelationalContinueToken (Results 1 – 8 of 8) sorted by relevance
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| D | sqlite_single_ver_relational_continue_token.cpp | 20 SQLiteSingleVerRelationalContinueToken::SQLiteSingleVerRelationalContinueToken( in SQLiteSingleVerRelationalContinueToken() function in DistributedDB::SQLiteSingleVerRelationalContinueToken
25 bool SQLiteSingleVerRelationalContinueToken::CheckValid() const in CheckValid()
34 int SQLiteSingleVerRelationalContinueToken::GetStatement(sqlite3 *db, sqlite3_stmt *&queryStmt, sql… in GetStatement()
58 void SQLiteSingleVerRelationalContinueToken::SetNextBeginTime(const DataItem &theLastItem) in SetNextBeginTime()
74 void SQLiteSingleVerRelationalContinueToken::FinishGetData() in FinishGetData()
85 bool SQLiteSingleVerRelationalContinueToken::IsGetAllDataFinished() const in IsGetAllDataFinished()
90 int SQLiteSingleVerRelationalContinueToken::GetQuerySyncStatement(sqlite3 *db, sqlite3_stmt *&stmt) in GetQuerySyncStatement()
104 int SQLiteSingleVerRelationalContinueToken::GetMissQueryStatement(sqlite3 *db, sqlite3_stmt *&stmt) in GetMissQueryStatement()
114 int SQLiteSingleVerRelationalContinueToken::GetDeletedDataStmt(sqlite3 *db, sqlite3_stmt *&stmt) co… in GetDeletedDataStmt()
139 const QueryObject &SQLiteSingleVerRelationalContinueToken::GetQuery() const in GetQuery()
[all …]
|
| D | sqlite_single_ver_relational_continue_token.h | 26 class SQLiteSingleVerRelationalContinueToken {
28 …SQLiteSingleVerRelationalContinueToken(const SyncTimeRange &timeRange, const QueryObject &queryObj…
29 ~SQLiteSingleVerRelationalContinueToken() = default;
|
| D | sqlite_single_ver_relational_storage_executor.h | 114 SQLiteSingleVerRelationalContinueToken &token);
|
| D | sqlite_single_ver_relational_storage_executor.cpp | 1653 const uint32_t &maxSize, SQLiteSingleVerRelationalContinueToken &token) in GetSyncCloudData()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| D | relational_sync_able_storage.cpp | 373 SQLiteSingleVerRelationalContinueToken *&token) in ProcessContinueTokenForQuerySync()
397 SQLiteSingleVerRelationalContinueToken *&token, const DataSizeSpecInfo &dataSizeInfo) const in GetSyncDataForQuerySync()
414 std::bind(&SQLiteSingleVerRelationalContinueToken::GetStatement, *token, in GetSyncDataForQuerySync()
442 auto token = new (std::nothrow) SQLiteSingleVerRelationalContinueToken(timeRange, query); in GetSyncData()
455 auto token = static_cast<SQLiteSingleVerRelationalContinueToken *>(continueStmtToken); in GetSyncDataNext()
1085 auto token = new (std::nothrow) SQLiteSingleVerRelationalContinueToken(syncTimeRange, query); in GetCloudData()
1101 auto token = static_cast<SQLiteSingleVerRelationalContinueToken *>(continueStmtToken); in GetCloudDataNext()
1149 auto token = static_cast<SQLiteSingleVerRelationalContinueToken *>(continueStmtToken); in ReleaseCloudDataToken()
1344 auto token = static_cast<SQLiteSingleVerRelationalContinueToken *>(continueStmtToken); in ReleaseContinueToken()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| D | relational_sync_able_storage.h | 239 …etSyncDataForQuerySync(std::vector<DataItem> &dataItems, SQLiteSingleVerRelationalContinueToken *&…
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| D | distributeddb_cloud_syncer_upload_test.cpp | 437 …auto token = new (std::nothrow) SQLiteSingleVerRelationalContinueToken(syncTimeRange, queryObject);
1126 …auto token = new (std::nothrow) SQLiteSingleVerRelationalContinueToken(syncTimeRange, queryObject);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| D | distributeddb_relational_get_data_test.cpp | 268 std::unique_ptr<SQLiteSingleVerRelationalContinueToken> token = in SetNextBeginTime001()
269 std::make_unique<SQLiteSingleVerRelationalContinueToken>(SyncTimeRange {}, query); in SetNextBeginTime001()
|