Skip to content

Commit a311180

Browse files
authored
Add getRowsModified to worker (#596)
1 parent fbc1f07 commit a311180

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

src/worker.js

+5
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,11 @@ function onModuleReady(SQL) {
3535
id: data["id"],
3636
results: db.exec(data["sql"], data["params"], config)
3737
});
38+
case "getRowsModified":
39+
return postMessage({
40+
id: data["id"],
41+
rowsModified: db.getRowsModified()
42+
});
3843
case "each":
3944
if (db === null) {
4045
createDb();

test/test_worker.js

+3
Original file line numberDiff line numberDiff line change
@@ -118,6 +118,9 @@ exports.test = async function test(SQL, assert) {
118118
assert.strictEqual(table.values[2][1], 'c', 'Reading string');
119119
assert.deepEqual(obj2array(table.values[2][2]), [0x00, 0x44], 'Reading BLOB byte');
120120

121+
data = await worker.postMessage({ action: 'getRowsModified' });
122+
assert.equal(data.rowsModified, 1, 'Number of changed rows')
123+
121124
data = await worker.postMessage({ action: 'export' });
122125
var header = "SQLite format 3\0";
123126
var actual = "";

0 commit comments

Comments
 (0)