node.js + SQLite WASM example

package.json

{
  "type": "module",
  "scripts": {},
  "dependencies": {
    "dotenv": "^17.2.1",
    "sql.js": "^1.13.0"
  }
}

table.sql

CREATE TABLE todos (
  id INTEGER PRIMARY KEY AUTOINCREMENT,
  title TEXT NOT NULL,
  created_at TEXT NOT NULL,
  updated_at TEXT NOT NULL
);

test1.js

import initSqlJs from "sql.js";
import fs from "fs";

(async () => {
  const SQL = await initSqlJs({
  });
  // 既存のDBファイルを読み込む
  let db;
  const filename = "test.sqlite";
  if (fs.existsSync(filename)) {
    const fileBuffer = fs.readFileSync(filename);
    db = new SQL.Database(fileBuffer);
  } else {
    db = new SQL.Database();
  }

  const now = new Date().toISOString();
  // データ挿入
  db.run(`INSERT INTO todos (title , created_at , updated_at) VALUES (? , ? , ?)`
    , ["t-1", now , now ]
  );
  // データ取得
  const stmt = db.prepare("SELECT * FROM todos");
  while (stmt.step()) {
    console.log(stmt.getAsObject());
  }
  stmt.free();

  // メモリ上のDBを Uint8Array としてエクスポート
  const data = db.export();

  // ファイルに書き込み
  fs.writeFileSync(filename, Buffer.from(data));

  console.log("保存しました:", filename);
})();

test2.js

import initSqlJs from "sql.js";
import fs from "fs";

(async () => {
  const SQL = await initSqlJs({
  });
  // 既存のDBファイルを読み込む
  let db;
  const filename = "test.sqlite";
  if (fs.existsSync(filename)) {
    const fileBuffer = fs.readFileSync(filename);
    db = new SQL.Database(fileBuffer);
  } else {
    db = new SQL.Database();
  }

  const now = new Date().toISOString();

  // データ取得
  const stmt = db.prepare("SELECT COUNT(*) FROM todos");
  while (stmt.step()) {
    console.log(stmt.getAsObject());
  }
  stmt.free();

  // メモリ上のDBを Uint8Array としてエクスポート
  const data = db.export();

  // ファイルに書き込み
  fs.writeFileSync(filename, Buffer.from(data));

  console.log("保存しました:", filename);
})();