20240909 非同期処理(JavaScript)

03.asynchronous/async_await/existing_error.js

@@ -0,0 +1,44 @@
+#!/usr/bin/env node
+
+import { createDatabase, run, all, close } from "../db_operations.js";
+
+let db = await createDatabase();
+console.log("メモリ内のSQLiteデータベースに接続しました。");
+
+try {
+  await run(
+    db,
+    "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE)",
+  );
+  console.log("テーブルが作成されました。");
+
+  try {
+    const result = await run(db, "INSERT INTO books (title) VALUES (?)", [
+      "Node.js入門",
+    ]);
+    console.log(`行が追加されました。id: ${result.lastID}`);
+    await run(db, "INSERT INTO books (title) VALUES (?)", ["Node.js入門"]);
+  } catch (err) {
+    if (
+      String(err).includes(
+        "SQLITE_CONSTRAINT: UNIQUE constraint failed: books.title",
+      )
+    ) {
+      console.error(`エラーが発生しました: ${String(err)}`);
+    } else {
+      throw err;
+    }
+  }
+
+  try {
+    await all(db, "SELECT * FROM nonexistent_table WHERE id = ?", [-1]);
+  } catch (err) {
+    console.error(`エラーが発生しました: ${err.message}`);
+  }
+
+  await run(db, "DROP TABLE books");
+  console.log("テーブルが削除されました。");
+} finally {
+  await close(db);
+  console.log("データベース接続を閉じました。");
+}

03.asynchronous/async_await/nonexistent_error.js

@@ -0,0 +1,30 @@
+#!/usr/bin/env node
+
+import { createDatabase, run, all, close } from "../db_operations.js";
+
+let db = await createDatabase();
+console.log("メモリ内のSQLiteデータベースに接続しました。");
+
+try {
+  await run(
+    db,
+    "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE)",
+  );
+  console.log("テーブルが作成されました。");
+
+  const result = await run(db, "INSERT INTO books (title) VALUES (?)", [
+    "Node.js入門",
+  ]);
+  console.log(`行が追加されました。id: ${result.lastID}`);
+
+  const rows = await all(db, "SELECT * FROM books");
+  rows.forEach((row) => {
+    console.log(`${row.id}: ${row.title}`);
+  });
+
+  await run(db, "DROP TABLE books");
+  console.log("テーブルが削除されました。");
+} finally {
+  await close(db);
+  console.log("データベース接続を閉じました。");
+}

03.asynchronous/callback/existing_error.js

@@ -0,0 +1,46 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+
+const db = new sqlite3.Database(":memory:", () => {
+  console.log("メモリ内のSQLiteデータベースに接続しました。");
+
+  db.run(
+    "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE)",
+    () => {
+      console.log("テーブルが作成されました。");
+
+      db.run(
+        "INSERT INTO books (title) VALUES (?)",
+        ["Node.js入門"],
+        function () {
+          console.log(`行が追加されました。id: ${this.lastID}`);
+
+          db.run(
+            "INSERT INTO books (title) VALUES (?)",
+            ["Node.js入門"],
+            (err) => {
+              if (err) {
+                console.error(`エラーが発生しました: ${err.message}`);
+              }
+
+              db.all("SELECT content FROM books", (err) => {
+                if (err) {
+                  console.error(`エラーが発生しました: ${err.message}`);
+                }
+
+                db.run("DROP TABLE books", () => {
+                  console.log("テーブルが削除されました。");
+
+                  db.close(() => {
+                    console.log("データベース接続を閉じました。");
+                  });
+                });
+              });
+            },
+          );
+        },
+      );
+    },
+  );
+});

03.asynchronous/callback/nonexistent_error.js

@@ -0,0 +1,36 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+
+const db = new sqlite3.Database(":memory:", () => {
+  console.log("メモリ内のSQLiteデータベースに接続しました。");
+
+  db.run(
+    "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE)",
+    () => {
+      console.log("テーブルが作成されました。");
+
+      db.run(
+        "INSERT INTO books (title) VALUES (?)",
+        ["Node.js入門"],
+        function () {
+          console.log(`行が追加されました。id: ${this.lastID}`);
+
+          db.all("SELECT * FROM books", (_, rows) => {
+            rows.forEach((row) => {
+              console.log(`${row.id}: ${row.title}`);
+            });
+
+            db.run("DROP TABLE books", () => {
+              console.log("テーブルが削除されました。");
+
+              db.close(() => {
+                console.log("データベース接続を閉じました。");
+              });
+            });
+          });
+        },
+      );
+    },
+  );
+});

03.asynchronous/db_operations.js

@@ -0,0 +1,49 @@
+import sqlite3 from "sqlite3";
+
+export const createDatabase = () => {
+  return new Promise((resolve, reject) => {
+    const db = new sqlite3.Database(":memory:", (err) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(db);
+      }
+    });
+  });
+};
+
+export function run(db, sql, params) {
+  return new Promise((resolve, reject) => {
+    db.run(sql, params, function (err) {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(this);
+      }
+    });
+  });
+}
+
+export function all(db, sql, params) {
+  return new Promise((resolve, reject) => {
+    db.all(sql, params, (err, rows) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(rows);
+      }
+    });
+  });
+}
+
+export function close(db) {
+  return new Promise((resolve, reject) => {
+    db.close((err) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve();
+      }
+    });
+  });
+}