Advertisement
gizero

Untitled

Sep 11th, 2014
227
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.02 KB | None | 0 0
  1. /*
  2. * given an sql stmt, run it over the db and
  3. * call the provided storefunc on any returned
  4. * record
  5. */
  6. function dataGet(stmt, storefunc) {
  7. //open DB
  8. //do retry stuff
  9. //close DB
  10.  
  11. var db = new sqlite3.Database(routes.fileDbRam, sqlite3.OPEN_READONLY, function(err) {
  12.  
  13. if (err) return console.error('cannot open DB: ' + err);
  14.  
  15. db.each(stmt
  16. , function item(err, row) {
  17. if (err) {
  18. console.error('error: db.each: row: ' + err);
  19. }
  20. else {
  21. console.log('row callback');
  22. // do the real stuff here
  23. storefunc(row);
  24. }
  25. }
  26. , function complete(err, nrow) {
  27. if (err) {
  28. console.error('error: db.each: complete: ' + err);
  29. }
  30. // howsoever close the DB
  31. console.log('complete callback (nrow = ' + nrow + ')');
  32. db.close(function(err) {
  33. if (err) return console.error('cannot close DB: ' + err);
  34. console.log('well done');
  35. });
  36. });
  37.  
  38. });
  39. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement