Support query fetch limits.

1 files changed, 18 insertions, 0 deletions

diff --git a/src/main/java/com/amazon/carbonado/repo/logging/LoggingQuery.java b/src/main/java/com/amazon/carbonado/repo/logging/LoggingQuery.java
index d1f21ce..56e4e33 100644
--- a/src/main/java/com/amazon/carbonado/repo/logging/LoggingQuery.java
+++ b/src/main/java/com/amazon/carbonado/repo/logging/LoggingQuery.java
@@ -137,6 +137,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.fetch();

     }

 

+    public Cursor<S> fetch(long from, Long to) throws FetchException {

+        Log log = mStorage.mLog;

+        if (log.isEnabled()) {

+            log.write("Query.fetch(start, to) on " + this +

+                      ", from: " + from + ", to: " + to);

+        }

+        return mQuery.fetch(from, to);

+    }

+

     public Cursor<S> fetchAfter(S start) throws FetchException {

         Log log = mStorage.mLog;

         if (log.isEnabled()) {

@@ -145,6 +154,15 @@ class LoggingQuery<S extends Storable> implements Query<S> {
         return mQuery.fetchAfter(start);

     }

 

+    public Cursor<S> fetchAfter(S start, long from, Long to) throws FetchException {

+        Log log = mStorage.mLog;

+        if (log.isEnabled()) {

+            log.write("Query.fetchAfter(start, from, to) on " + this + ", start: " + start +

+                      ", from: " + from + ", to: " + to);

+        }

+        return mQuery.fetchAfter(start);

+    }

+

     public S loadOne() throws FetchException {

         Log log = mStorage.mLog;

         if (log.isEnabled()) {