diff options
author | Rémi Nicole <nicole@kolabsystems.com> | 2018-07-27 13:37:32 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2018-07-27 13:47:54 +0200 |
commit | 0a9b39a1f58c1f5b1a424acbe369db520a12df42 (patch) | |
tree | 4c64e5680150f50088bf114cbab39f79f781d242 /common/datastorequery.h | |
parent | 620c4f551d3de830a516475ad02965695cb25945 (diff) | |
download | sink-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.h | 20 |
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 | ||
27 | class Source; | 27 | class Source; |
28 | class Bloom; | 28 | class 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(); } |