Merge pull request #264 from github1337/gh1337-streaming

Updated adapter stream function
balderdashy · Nov 28, 2015 · 0a30e21 · 0a30e21
2 parents 901ea51 + b832fd7
commit 0a30e21
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/lib/adapter.js b/lib/adapter.js
@@ -904,7 +904,18 @@ module.exports = (function() {
         var tableName = collectionName;
 
         // Build find query
-        var query = sql.selectQuery(tableName, options);
+        var schema = connectionObject.schema;
+        var _query;
+
+        var sequel = new Sequel(schema, sqlOptions);
+
+        // Build a query for the specific query strategy
+        try {
+          _query = sequel.find(collectionName, options);
+        } catch(e) {
+          return cb(e);
+        }
+        var query = _query.query[0];
 
         // Run query
         log('MySQL.stream: ', query);