非同期処理プログラムの提出

03.asynchronous/async.js

@@ -0,0 +1,22 @@
+import sqlite3 from "sqlite3";
+import { run, get, close } from "./sqlite_utils.js";
+
+const bookTitles = ["booktitle_01", "booktitle_02", "booktitle_03"];
+const db = new sqlite3.Database(":memory:");
+
+await run(
+  db,
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE)",
+);
+
+for (const title of bookTitles) {
+  const result = await run(db, "INSERT INTO books (title) VALUES (?)", [title]);
+  console.log(`ADD TITLE: ${title}, ID: ${result.lastID}`);
+
+  const book = await get(db, "SELECT * FROM books WHERE title = ?", [title]);
+  console.log(`GET TITLE: ${book.title}, ID: ${book.id}`);
+}
+
+await run(db, "DROP TABLE books");
+
+await close(db);

03.asynchronous/async_error.js

@@ -0,0 +1,46 @@
+import sqlite3 from "sqlite3";
+import { run, get, close } from "./sqlite_utils.js";
+
+const bookTitles = ["booktitle_01", "booktitle_01", "booktitle_02"];
+const db = new sqlite3.Database(":memory:");
+
+await run(
+  db,
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE)",
+);
+
+for (const title of bookTitles) {
+  try {
+    const result = await run(db, "INSERT INTO books (title) VALUES (?)", [
+      title,
+    ]);
+    console.log(`ADD TITLE: ${title}, ID: ${result.lastID}`);
+  } catch (err) {
+    if (
+      err instanceof Error &&
+      "code" in err &&
+      err.code === "SQLITE_CONSTRAINT"
+    ) {
+      console.error(`ADD TITLE: ${title}, ${err.message}`);
+    } else {
+      throw err;
+    }
+  }
+
+  try {
+    const book = await get(db, "SELECT * FROM NotExistTable WHERE title = ?", [
+      title,
+    ]);
+    console.log(`GET TITLE: ${book.title}, ID: ${book.id}`);
+  } catch (err) {
+    if (err instanceof Error && "code" in err && err.code === "SQLITE_ERROR") {
+      console.error(`GET TITLE: ${title}, ${err.message}`);
+    } else {
+      throw err;
+    }
+  }
+}
+
+await run(db, "DROP TABLE books");
+
+await close(db);

03.asynchronous/callback.js

@@ -0,0 +1,21 @@
+import sqlite3 from "sqlite3";
+
+const bookTitle = "booktitle_01";
+const db = new sqlite3.Database(":memory:");
+
+db.run(
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE)",
+  () => {
+    db.run("INSERT INTO books (title) VALUES (?)", [bookTitle], function () {
+      console.log(`ADD TITLE: ${bookTitle}, ID: ${this.lastID}`);
+
+      db.get("SELECT * FROM books WHERE title = ?", [bookTitle], (_, book) => {
+        console.log(`GET TITLE: ${book.title}, ID: ${book.id}`);
+
+        db.run("DROP TABLE books", () => {
+          db.close();
+        });
+      });
+    });
+  },
+);

03.asynchronous/callback_error.js

@@ -0,0 +1,37 @@
+import sqlite3 from "sqlite3";
+
+const bookTitle = "booktitle_01";
+const db = new sqlite3.Database(":memory:");
+
+db.run(
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE)",
+  () => {
+    db.run(
+      "INSERT INTO NotExistTable (title) VALUES (?)",
+      [bookTitle],
+      function (err) {
+        if (err) {
+          console.error(`ADD TITLE: ${bookTitle}, ${err.message}`);
+        } else {
+          console.log(`ADD TITLE: ${bookTitle}, ID: ${this.lastID}`);
+        }
+
+        db.get(
+          "SELECT * FROM NotExistTable WHERE title = ?",
+          [bookTitle],
+          (err, book) => {
+            if (err) {
+              console.error(`GET TITLE: ${bookTitle}, ${err.message}`);
+            } else {
+              console.log(`GET TITLE: ${book.title}, ID: ${book.id}`);
+            }
+
+            db.run("DROP TABLE books", () => {
+              db.close();
+            });
+          },
+        );
+      },
+    );
+  },
+);