Instantly share code, notes, and snippets.

Embed
What would you like to do?
"use strict";
exports.queryAll = function(conn, sql, args, cb) {
var allRows = [];
conn.execute(sql, args, {
resultSet: true
}, function(err, result) {
if (err) return cb(err);
function fetch() {
var max = 50;
result.resultSet.getRows(max, function(err, rows) {
if (err) return cb(err);
allRows.push(rows);
if (rows.length === max) {
fetch();
} else {
result.resultSet.close(function(err) {
if (err) return cb(err);
cb(null, Array.prototype.concat.apply([], allRows));
});
}
});
}
fetch();
});
}
@nethoncho

This comment has been minimized.

nethoncho commented Aug 16, 2015

Thanks for the queryAll example.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment