Skip to content

N
node-sqlite3
Commit 288f4cfc by Brian Green
Options

Fix interrupt test: wait for exec to complete before continuing.

parent dc076bfe
Showing with 24 additions and 19 deletions
test/interrupt.test.js
...@@ -13,29 +13,34 @@ describe('interrupt', function() { ...@@ -13,29 +13,34 @@ describe('interrupt', function() {
for (var i = 0; i < 8; i += 1) { for (var i = 0; i < 8; i += 1) {
setup += 'insert into t values (' + i + ');'; setup += 'insert into t values (' + i + ');';
} }
db.exec(setup);
var query = 'select last.n ' + db.exec(setup, function(err) {
'from t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t as last';
db.each(query, function(err) {
if (err) { if (err) {
saved = err; return done(err);
} else if (!interrupted) {
interrupted = true;
db.interrupt();
} }
});
db.close(function() { var query = 'select last.n ' +
if (saved) { 'from t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t,t as last';
assert.equal(saved.message, 'SQLITE_INTERRUPT: interrupted');
assert.equal(saved.errno, sqlite3.INTERRUPT); db.each(query, function(err) {
assert.equal(saved.code, 'SQLITE_INTERRUPT'); if (err) {
done(); saved = err;
} else { } else if (!interrupted) {
done(new Error('Completed query without error, but expected error')); interrupted = true;
} db.interrupt();
}
});
db.close(function() {
if (saved) {
assert.equal(saved.message, 'SQLITE_INTERRUPT: interrupted');
assert.equal(saved.errno, sqlite3.INTERRUPT);
assert.equal(saved.code, 'SQLITE_INTERRUPT');
done();
} else {
done(new Error('Completed query without error, but expected error'));
}
});
}); });
}); });
}); });
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment