Add tests for WasmDatabaseEngine.updateCellBatch

tests/unit/sqlite_db.test.ts

@@ -0,0 +1,121 @@
+
+import { describe, it, before, after } from 'node:test';
+import assert from 'node:assert';
+import { createDatabaseEngine } from '../../src/core/sqlite-db';
+import type { DatabaseOperations, CellUpdate } from '../../src/core/types';
+
+describe('WasmDatabaseEngine', () => {
+    let engine: DatabaseOperations;
+
+    before(async () => {
+        // Initialize with empty DB
+        const result = await createDatabaseEngine({
+            content: null,
+            maxSize: 0,
+            readOnlyMode: false
+        });
+        engine = result.operations;
+
+        // Setup table
+        await engine.executeQuery("CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER, data TEXT)");
+    });
+
+    it('should update multiple cells in a batch', async () => {
+        // Setup initial data
+        await engine.executeQuery("DELETE FROM users");
+        await engine.insertRow('users', { id: 1, name: 'Alice', age: 30, data: '{}' });
+        await engine.insertRow('users', { id: 2, name: 'Bob', age: 25, data: '{}' });
+
+        const updates: CellUpdate[] = [
+            { rowId: 1, column: 'name', value: 'Alice Smith' },
+            { rowId: 2, column: 'age', value: 26 }
+        ];
+
+        await engine.updateCellBatch('users', updates);
+
+        const result = await engine.executeQuery("SELECT * FROM users ORDER BY id");
+        const rows = result[0].rows;
+
+        // Alice updated
+        assert.strictEqual(rows[0][1], 'Alice Smith');
+        assert.strictEqual(rows[0][2], 30); // Age unchanged
+
+        // Bob updated
+        assert.strictEqual(rows[1][1], 'Bob'); // Name unchanged
+        assert.strictEqual(rows[1][2], 26);
+    });
+
+    it('should handle JSON patch updates', async () => {
+        // Setup initial data
+        await engine.executeQuery("DELETE FROM users");
+        await engine.insertRow('users', { id: 1, name: 'Charlie', age: 40, data: '{"a": 1, "b": 2}' });
+
+        const updates: CellUpdate[] = [
+            { rowId: 1, column: 'data', value: '{"b": 3, "c": 4}', operation: 'json_patch' }
+        ];
+
+        await engine.updateCellBatch('users', updates);
+
+        const result = await engine.executeQuery("SELECT data FROM users WHERE id = 1");
+        const dataStr = result[0].rows[0][0] as string;
+        const data = JSON.parse(dataStr);
+
+        assert.deepStrictEqual(data, { a: 1, b: 3, c: 4 });
+    });
+
+    it('should handle mixed standard and JSON patch updates', async () => {
+         // Setup initial data
+         await engine.executeQuery("DELETE FROM users");
+         await engine.insertRow('users', { id: 1, name: 'David', age: 50, data: '{"x": 10}' });
+         await engine.insertRow('users', { id: 2, name: 'Eve', age: 55, data: '{"y": 20}' });
+
+         const updates: CellUpdate[] = [
+             { rowId: 1, column: 'name', value: 'David Jones' },
+             { rowId: 1, column: 'data', value: '{"x": 11}', operation: 'json_patch' },
+             { rowId: 2, column: 'age', value: 56 },
+             { rowId: 2, column: 'data', value: '{"z": 30}', operation: 'json_patch' }
+         ];
+
+         await engine.updateCellBatch('users', updates);
+
+         const result = await engine.executeQuery("SELECT name, age, data FROM users ORDER BY id");
+         const rows = result[0].rows;
+
+         // David
+         assert.strictEqual(rows[0][0], 'David Jones');
+         assert.strictEqual(rows[0][1], 50); // Age unchanged
+         assert.deepStrictEqual(JSON.parse(rows[0][2] as string), { x: 11 });
+
+         // Eve
+         assert.strictEqual(rows[1][0], 'Eve');
+         assert.strictEqual(rows[1][1], 56);
+         assert.deepStrictEqual(JSON.parse(rows[1][2] as string), { y: 20, z: 30 });
+    });
+
+    it('should handle empty updates gracefully', async () => {
+        await engine.updateCellBatch('users', []);
+        assert.ok(true);
+    });
+
+    it('should rollback transaction on error', async () => {
+        // Setup initial data
+        await engine.executeQuery("DELETE FROM users");
+        await engine.insertRow('users', { id: 1, name: 'Frank', age: 60, data: '{}' });
+
+        const updates: CellUpdate[] = [
+            { rowId: 1, column: 'name', value: 'Frank Sinatra' }, // Valid update
+            { rowId: 1, column: 'non_existent_column', value: 'Error' } // Invalid update
+        ];
+
+        try {
+            await engine.updateCellBatch('users', updates);
+            assert.fail('Should have thrown an error');
+        } catch (e) {
+            assert.ok(e);
+        }
+
+        // Verify rollback
+        const result = await engine.executeQuery("SELECT name FROM users WHERE id = 1");
+        assert.strictEqual(result[0].rows[0][0], 'Frank'); // Should remain original value
+    });
+});