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