1. 1var sqlite3 = require('..');
2. 1var assert = require('assert');
3. 1
4. 1describe('each', function() {
5. 1 var db;
6. 1 before(function(done) {
7. 1 db = new sqlite3.Database('test/support/big.db', sqlite3.OPEN_READONLY, done);
8. 1 });
9. 1
10. 1 it('retrieve 100,000 rows with Statement#each', function(done) {
11. 1 var total = 100000;
12. 1 var retrieved = 0;
13. 1
14. 1
15. 100000 db.each('SELECT id, txt FROM foo LIMIT 0, ?', total, function(err, row) {
16. 0 if (err) throw err;
17. 100000 retrieved++;
18. 100000
19. 1 if(retrieved === total) {
20. 1 assert.equal(retrieved, total, "Only retrieved " + retrieved + " out of " + total + " rows.");
21. 1 done();
22. 1 }
23. 100000 });
24. 1 });
25. 1
26. 1 it('Statement#each with complete callback', function(done) {
27. 1 var total = 10000;
28. 1 var retrieved = 0;
29. 1
30. 10000 db.each('SELECT id, txt FROM foo LIMIT 0, ?', total, function(err, row) {
31. 0 if (err) throw err;
32. 10000 retrieved++;
33. 1 }, function(err, num) {
34. 1 assert.equal(retrieved, num);
35. 1 assert.equal(retrieved, total, "Only retrieved " + retrieved + " out of " + total + " rows.");
36. 1 done();
37. 1 });
38. 1 });
39. 1});
40. 1