summaryrefslogtreecommitdiffstats
path: root/common/datastorequery.h
diff options
context:
space:
mode:
authorRémi Nicole <nicole@kolabsystems.com>2018-07-27 13:37:32 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2018-07-27 13:47:54 +0200
commit0a9b39a1f58c1f5b1a424acbe369db520a12df42 (patch)
tree4c64e5680150f50088bf114cbab39f79f781d242 /common/datastorequery.h
parent620c4f551d3de830a516475ad02965695cb25945 (diff)
downloadsink-0a9b39a1f58c1f5b1a424acbe369db520a12df42.tar.gz
sink-0a9b39a1f58c1f5b1a424acbe369db520a12df42.zip
Use Key API in DataStoreQuery
Reviewers: cmollekopf Reviewed By: cmollekopf Tags: #sink Differential Revision: https://phabricator.kde.org/D14099
Diffstat (limited to 'common/datastorequery.h')
-rw-r--r--common/datastorequery.h20
1 files changed, 10 insertions, 10 deletions
diff --git a/common/datastorequery.h b/common/datastorequery.h
index 2311585..a224e64 100644
--- a/common/datastorequery.h
+++ b/common/datastorequery.h
@@ -22,7 +22,7 @@
22#include "resultset.h" 22#include "resultset.h"
23#include "log.h" 23#include "log.h"
24#include "storage/entitystore.h" 24#include "storage/entitystore.h"
25 25#include "storage/key.h"
26 26
27class Source; 27class Source;
28class Bloom; 28class Bloom;
@@ -59,13 +59,13 @@ private:
59 typedef std::function<bool(const Sink::ApplicationDomain::ApplicationDomainType &entity, Sink::Operation)> FilterFunction; 59 typedef std::function<bool(const Sink::ApplicationDomain::ApplicationDomainType &entity, Sink::Operation)> FilterFunction;
60 typedef std::function<void(const Sink::ApplicationDomain::ApplicationDomainType &entity, Sink::Operation)> BufferCallback; 60 typedef std::function<void(const Sink::ApplicationDomain::ApplicationDomainType &entity, Sink::Operation)> BufferCallback;
61 61
62 QVector<QByteArray> indexLookup(const QByteArray &property, const QVariant &value); 62 QVector<Sink::Storage::Identifier> indexLookup(const QByteArray &property, const QVariant &value);
63 63
64 void readEntity(const QByteArray &key, const BufferCallback &resultCallback); 64 void readEntity(const Sink::Storage::Identifier &id, const BufferCallback &resultCallback);
65 void readPrevious(const QByteArray &key, const std::function<void (const Sink::ApplicationDomain::ApplicationDomainType &)> &callback); 65 void readPrevious(const Sink::Storage::Identifier &id, const std::function<void (const Sink::ApplicationDomain::ApplicationDomainType &)> &callback);
66 66
67 ResultSet createFilteredSet(ResultSet &resultSet, const FilterFunction &); 67 ResultSet createFilteredSet(ResultSet &resultSet, const FilterFunction &);
68 QVector<QByteArray> loadIncrementalResultSet(qint64 baseRevision); 68 QVector<Sink::Storage::Key> loadIncrementalResultSet(qint64 baseRevision);
69 69
70 void setupQuery(const Sink::QueryBase &query_); 70 void setupQuery(const Sink::QueryBase &query_);
71 QByteArrayList executeSubquery(const Sink::QueryBase &subquery); 71 QByteArrayList executeSubquery(const Sink::QueryBase &subquery);
@@ -96,22 +96,22 @@ public:
96 96
97 virtual ~FilterBase(){} 97 virtual ~FilterBase(){}
98 98
99 void readEntity(const QByteArray &key, const std::function<void(const Sink::ApplicationDomain::ApplicationDomainType &entity, Sink::Operation)> &callback) 99 void readEntity(const Sink::Storage::Identifier &id, const std::function<void(const Sink::ApplicationDomain::ApplicationDomainType &entity, Sink::Operation)> &callback)
100 { 100 {
101 Q_ASSERT(mDatastore); 101 Q_ASSERT(mDatastore);
102 mDatastore->readEntity(key, callback); 102 mDatastore->readEntity(id, callback);
103 } 103 }
104 104
105 QVector<QByteArray> indexLookup(const QByteArray &property, const QVariant &value) 105 QVector<Sink::Storage::Identifier> indexLookup(const QByteArray &property, const QVariant &value)
106 { 106 {
107 Q_ASSERT(mDatastore); 107 Q_ASSERT(mDatastore);
108 return mDatastore->indexLookup(property, value); 108 return mDatastore->indexLookup(property, value);
109 } 109 }
110 110
111 void readPrevious(const QByteArray &key, const std::function<void (const Sink::ApplicationDomain::ApplicationDomainType &)> &callback) 111 void readPrevious(const Sink::Storage::Identifier &id, const std::function<void (const Sink::ApplicationDomain::ApplicationDomainType &)> &callback)
112 { 112 {
113 Q_ASSERT(mDatastore); 113 Q_ASSERT(mDatastore);
114 mDatastore->readPrevious(key, callback); 114 mDatastore->readPrevious(id, callback);
115 } 115 }
116 116
117 virtual void skip() { mSource->skip(); } 117 virtual void skip() { mSource->skip(); }