add "partial" parameter

knonomura · knonomura · commit 99472eeb1d8d · 2018-03-29T18:53:50.000+09:00
diff --git a/src/Query.cpp b/src/Query.cpp
@@ -90,11 +90,22 @@ namespace griddb {
     /**
      * Set fetch limit option
      */
-    void Query::set_fetch_options(int limit){
-        GSFetchOption fetchOption = GS_FETCH_LIMIT;
-        GSResult ret = gsSetFetchOption(mQuery, fetchOption, &limit, GS_TYPE_INTEGER);
-        if (ret != GS_RESULT_OK) {
-            throw GSException(mQuery, ret);
+    void Query::set_fetch_options(int limit, bool partial){
+    	if (limit >= 0) {
+	        GSFetchOption fetchOption = GS_FETCH_LIMIT;
+	        GSResult ret = gsSetFetchOption(mQuery, fetchOption, &limit, GS_TYPE_INTEGER);
+	        if (ret != GS_RESULT_OK) {
+	            throw GSException(mQuery, ret);
+	        }
+    	}
+        if (partial == true) {
+#if GS_COMPATIBILITY_SUPPORT_4_0
+            GSFetchOption fetchOption = GS_FETCH_PARTIAL_EXECUTION;
+            GSResult ret = gsSetFetchOption(mQuery, fetchOption, &partial, GS_TYPE_BOOL);
+            if (ret != GS_RESULT_OK) {
+                throw GSException(mQuery, ret);
+            }
+#endif
         }
     }
 }
diff --git a/src/Query.h b/src/Query.h
@@ -42,7 +42,7 @@ class Query {
         RowSet* fetch(bool for_update = false);
         void set_fetch_option_integer(GSFetchOption fetchOption, int32_t value);
         void set_fetch_option_long(GSFetchOption fetchOption, int64_t value);
-        void set_fetch_options(int limit = -1);
+        void set_fetch_options(int limit = -1, bool partial = false);
         RowSet* get_row_set();
         GSQuery* gs_ptr();
 
