Added compose query

biolab-unige · Nov 21, 2016 · a6a2682 · a6a2682
1 parent 00ebc55
commit a6a2682
Show file tree

Hide file tree

Showing 4 changed files with 667 additions and 147 deletions.
diff --git a/lib/crud/WtCrudManager.js b/lib/crud/WtCrudManager.js
@@ -9,6 +9,7 @@
 "use strict";
 
 let WtKnexCrudStrategy = require("./WtCrudStrategies.js").WtKnexCrudStrategy;
+let WtPromiseCrudStrategy = require("./WtCrudStrategies.js").WtPromiseCrudStrategy;
 
 /**
  * @class
@@ -24,6 +25,7 @@ class WtCrudManager {
             strategy = new WtKnexCrudStrategy(fileSystemConnection);
         }
         this.strategy = strategy;
+        this.streamStrategy = new WtPromiseCrudStrategy(fileSystemConnection);
     }
 
     /**
@@ -134,6 +136,10 @@ class WtCrudManager {
         }
 
     }
+
+    queryStream(queryObj, next){
+        return this.streamStrategy.queryStream(queryObj.statement, queryObj.parameters, next);
+    }
 }
 
 module.exports = WtCrudManager;