"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(); | |
}); | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
This comment has been minimized.
nethoncho commentedAug 16, 2015
Thanks for the queryAll example.