Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- /*
- * given an sql stmt, run it over the db and
- * call the provided storefunc on any returned
- * record
- */
- function dataGet(stmt, storefunc) {
- //open DB
- //do retry stuff
- //close DB
- var db = new sqlite3.Database(routes.fileDbRam, sqlite3.OPEN_READONLY, function(err) {
- if (err) return console.error('cannot open DB: ' + err);
- db.each(stmt
- , function item(err, row) {
- if (err) {
- console.error('error: db.each: row: ' + err);
- }
- else {
- console.log('row callback');
- // do the real stuff here
- storefunc(row);
- }
- }
- , function complete(err, nrow) {
- if (err) {
- console.error('error: db.each: complete: ' + err);
- }
- // howsoever close the DB
- console.log('complete callback (nrow = ' + nrow + ')');
- db.close(function(err) {
- if (err) return console.error('cannot close DB: ' + err);
- console.log('well done');
- });
- });
- });
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement