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

03.asynchronous/async.js

@@ -0,0 +1,27 @@
+import sqlite3 from "sqlite3";
+import { run, get } from "./sqlite_utils.js";
+
+const bookTitles = ["booktitle_01", "booktitle_02", "booktitle_03"];
+const db = new sqlite3.Database(":memory:");
+
+const main = async () => {
+  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");
+  db.close();
+};
+
+main();

03.asynchronous/async_error.js

@@ -0,0 +1,47 @@
+import sqlite3 from "sqlite3";
+import { run, get } from "./sqlite_utils.js";
+
+const bookTitles = ["booktitle_01", "booktitle_01", "booktitle_02"];
+const db = new sqlite3.Database(":memory:");
+
+const main = async () => {
+  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.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.code === "SQLITE_ERROR") {
+        console.error(`GET TITLE: ${title}, ${err.message}`);
+      } else {
+        throw err;
+      }
+    }
+  }
+
+  await run(db, "DROP TABLE books");
+  db.close();
+};
+
+main();

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();
+            });
+          },
+        );
+      },
+    );
+  },
+);