summaryrefslogtreecommitdiffstats
path: root/common/queryrunner.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2018-02-21 15:47:50 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2018-02-21 15:47:50 +0100
commitd2d8a85aa6c56195368f7ec563a98afb6861acd9 (patch)
treebabd7454902b7e3a83b82b04cf5ffca5720aca12 /common/queryrunner.cpp
parent17f0dd179e9fd57b41b29abe84e7e49f9a7ac8a8 (diff)
downloadsink-d2d8a85aa6c56195368f7ec563a98afb6861acd9.tar.gz
sink-d2d8a85aa6c56195368f7ec563a98afb6861acd9.zip
Remember aggregated ids
Diffstat (limited to 'common/queryrunner.cpp')
-rw-r--r--common/queryrunner.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp
index 0ed4cb5..2062828 100644
--- a/common/queryrunner.cpp
+++ b/common/queryrunner.cpp
@@ -45,7 +45,6 @@ struct ReplayResult {
45template <typename DomainType> 45template <typename DomainType>
46class QueryWorker : public QObject 46class QueryWorker : public QObject
47{ 47{
48 typedef std::function<bool(const typename DomainType::Ptr &domainObject, Sink::Operation operation, const QMap<QByteArray, QVariant> &aggregateValues)> ResultCallback;
49public: 48public:
50 QueryWorker(const Sink::Query &query, const ResourceContext &context, const QByteArray &bufferType, const QueryRunnerBase::ResultTransformation &transformation, const Sink::Log::Context &logCtx); 49 QueryWorker(const Sink::Query &query, const ResourceContext &context, const QByteArray &bufferType, const QueryRunnerBase::ResultTransformation &transformation, const Sink::Log::Context &logCtx);
51 virtual ~QueryWorker(); 50 virtual ~QueryWorker();
@@ -210,6 +209,7 @@ void QueryWorker<DomainType>::resultProviderCallback(const Sink::Query &query, S
210 for (auto it = result.aggregateValues.constBegin(); it != result.aggregateValues.constEnd(); it++) { 209 for (auto it = result.aggregateValues.constBegin(); it != result.aggregateValues.constEnd(); it++) {
211 valueCopy->setProperty(it.key(), it.value()); 210 valueCopy->setProperty(it.key(), it.value());
212 } 211 }
212 valueCopy->aggregatedIds() = result.aggregateIds;
213 if (mResultTransformation) { 213 if (mResultTransformation) {
214 mResultTransformation(*valueCopy); 214 mResultTransformation(*valueCopy);
215 } 215 }