diff options
-rw-r--r-- | common/facade.h | 1 | ||||
-rw-r--r-- | common/query.h | 2 | ||||
-rw-r--r-- | common/queryrunner.cpp | 10 | ||||
-rw-r--r-- | common/typeindex.cpp | 1 |
4 files changed, 7 insertions, 7 deletions
diff --git a/common/facade.h b/common/facade.h index a85b1de..99fbcdc 100644 --- a/common/facade.h +++ b/common/facade.h | |||
@@ -26,7 +26,6 @@ | |||
26 | #include <Async/Async> | 26 | #include <Async/Async> |
27 | 27 | ||
28 | #include "resourceaccess.h" | 28 | #include "resourceaccess.h" |
29 | #include "resultset.h" | ||
30 | #include "domaintypeadaptorfactoryinterface.h" | 29 | #include "domaintypeadaptorfactoryinterface.h" |
31 | #include "storage.h" | 30 | #include "storage.h" |
32 | 31 | ||
diff --git a/common/query.h b/common/query.h index 29cff78..60c5630 100644 --- a/common/query.h +++ b/common/query.h | |||
@@ -115,7 +115,9 @@ public: | |||
115 | } | 115 | } |
116 | requestedProperties += rhs.requestedProperties; | 116 | requestedProperties += rhs.requestedProperties; |
117 | parentProperty = rhs.parentProperty; | 117 | parentProperty = rhs.parentProperty; |
118 | sortProperty = rhs.sortProperty; | ||
118 | liveQuery = rhs.liveQuery; | 119 | liveQuery = rhs.liveQuery; |
120 | limit = rhs.limit; | ||
119 | return *this; | 121 | return *this; |
120 | } | 122 | } |
121 | 123 | ||
diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp index 1ef076e..2f627bf 100644 --- a/common/queryrunner.cpp +++ b/common/queryrunner.cpp | |||
@@ -400,11 +400,11 @@ qint64 QueryWorker<DomainType>::load(const Sink::Query &query, const std::functi | |||
400 | QSet<QByteArray> remainingFilters; | 400 | QSet<QByteArray> remainingFilters; |
401 | QByteArray remainingSorting; | 401 | QByteArray remainingSorting; |
402 | auto resultSet = baseSetRetriever(transaction, remainingFilters, remainingSorting); | 402 | auto resultSet = baseSetRetriever(transaction, remainingFilters, remainingSorting); |
403 | Trace() << "Base set retrieved. " << time.elapsed(); | 403 | Trace() << "Base set retrieved. " << Log::TraceTime(time.elapsed()); |
404 | auto filteredSet = filterAndSortSet(resultSet, getFilter(remainingFilters, query), db, initialQuery, remainingSorting); | 404 | auto filteredSet = filterAndSortSet(resultSet, getFilter(remainingFilters, query), db, initialQuery, remainingSorting); |
405 | Trace() << "Filtered set retrieved. " << time.elapsed(); | 405 | Trace() << "Filtered set retrieved. " << Log::TraceTime(time.elapsed()); |
406 | replaySet(filteredSet, resultProvider, query.requestedProperties, offset, batchSize); | 406 | replaySet(filteredSet, resultProvider, query.requestedProperties, offset, batchSize); |
407 | Trace() << "Filtered set replayed. " << time.elapsed(); | 407 | Trace() << "Filtered set replayed. " << Log::TraceTime(time.elapsed()); |
408 | resultProvider.setRevision(Sink::Storage::maxRevision(transaction)); | 408 | resultProvider.setRevision(Sink::Storage::maxRevision(transaction)); |
409 | return Sink::Storage::maxRevision(transaction); | 409 | return Sink::Storage::maxRevision(transaction); |
410 | } | 410 | } |
@@ -420,7 +420,7 @@ qint64 QueryWorker<DomainType>::executeIncrementalQuery(const Sink::Query &query | |||
420 | auto revision = load(query, [&](Sink::Storage::Transaction &transaction, QSet<QByteArray> &remainingFilters, QByteArray &remainingSorting) -> ResultSet { | 420 | auto revision = load(query, [&](Sink::Storage::Transaction &transaction, QSet<QByteArray> &remainingFilters, QByteArray &remainingSorting) -> ResultSet { |
421 | return loadIncrementalResultSet(baseRevision, query, transaction, remainingFilters); | 421 | return loadIncrementalResultSet(baseRevision, query, transaction, remainingFilters); |
422 | }, resultProvider, false, 0, 0); | 422 | }, resultProvider, false, 0, 0); |
423 | Trace() << "Incremental query took: " << time.elapsed() << " ms"; | 423 | Trace() << "Incremental query took: " << Log::TraceTime(time.elapsed()); |
424 | return revision; | 424 | return revision; |
425 | } | 425 | } |
426 | 426 | ||
@@ -443,7 +443,7 @@ qint64 QueryWorker<DomainType>::executeInitialQuery(const Sink::Query &query, co | |||
443 | auto revision = load(modifiedQuery, [&](Sink::Storage::Transaction &transaction, QSet<QByteArray> &remainingFilters, QByteArray &remainingSorting) -> ResultSet { | 443 | auto revision = load(modifiedQuery, [&](Sink::Storage::Transaction &transaction, QSet<QByteArray> &remainingFilters, QByteArray &remainingSorting) -> ResultSet { |
444 | return loadInitialResultSet(modifiedQuery, transaction, remainingFilters, remainingSorting); | 444 | return loadInitialResultSet(modifiedQuery, transaction, remainingFilters, remainingSorting); |
445 | }, resultProvider, true, offset, batchsize); | 445 | }, resultProvider, true, offset, batchsize); |
446 | Trace() << "Initial query took: " << time.elapsed() << " ms"; | 446 | Trace() << "Initial query took: " << Log::TraceTime(time.elapsed()); |
447 | resultProvider.initialResultSetComplete(parent); | 447 | resultProvider.initialResultSetComplete(parent); |
448 | return revision; | 448 | return revision; |
449 | } | 449 | } |
diff --git a/common/typeindex.cpp b/common/typeindex.cpp index e945dcb..3ee2492 100644 --- a/common/typeindex.cpp +++ b/common/typeindex.cpp | |||
@@ -153,7 +153,6 @@ ResultSet TypeIndex::query(const Sink::Query &query, QSet<QByteArray> &appliedFi | |||
153 | appliedSorting = it.value(); | 153 | appliedSorting = it.value(); |
154 | Trace() << "Index lookup on " << it.key() << it.value() << " found " << keys.size() << " keys."; | 154 | Trace() << "Index lookup on " << it.key() << it.value() << " found " << keys.size() << " keys."; |
155 | return ResultSet(keys); | 155 | return ResultSet(keys); |
156 | |||
157 | } | 156 | } |
158 | } | 157 | } |
159 | for (const auto &property : mProperties) { | 158 | for (const auto &property : mProperties) { |