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

03.asynchronous/c1_callback.js

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

03.asynchronous/c2_callback_contain_error.js

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

03.asynchronous/c3_promise.js

@@ -0,0 +1,36 @@
+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:");
+
+run(
+  db,
+  `CREATE TABLE books (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    title TEXT NOT NULL UNIQUE
+  )`,
+)
+  .then(() => {
+    let promise = Promise.resolve();
+
+    bookTitles.forEach((title) => {
+      promise = promise
+        .then(() =>
+          run(db, "INSERT INTO books (title) VALUES (?)", [title]).then(() =>
+            console.log(`ADD TITLE: ${title}`),
+          ),
+        )
+        .then(() =>
+          get(db, "SELECT * FROM books WHERE title = ?", [title]).then(
+            (book) => {
+              console.log(`GET TITLE: ${book.title}, ID: ${book.id}`);
+            },
+          ),
+        );
+    });
+
+    return promise;
+  })
+  .then(() => run(db, "DROP TABLE books"))
+  .then(() => db.close());

03.asynchronous/c4_promise_contain_error.js

@@ -0,0 +1,40 @@
+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:");
+
+run(
+  db,
+  `CREATE TABLE books (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    title TEXT NOT NULL UNIQUE
+  )`,
+)
+  .then(() => {
+    let promise = Promise.resolve();
+
+    bookTitles.forEach((title) => {
+      promise = promise
+        .then(() =>
+          run(db, "INSERT INTO books (title) VALUES (?)", [title])
+            .then(() => console.log(`ADD TITLE: ${title}`))
+            .catch((err) => {
+              console.error(`ADD TITLE: ${title}, ${err.message}`);
+            }),
+        )
+        .then(() =>
+          get(db, "SELECT * FROM NotExistTable WHERE title = ?", [title])
+            .then((book) => {
+              console.log(`GET TITLE: ${book.title}, ID: ${book.id}`);
+            })
+            .catch((err) => {
+              console.error(`GET TITLE: ${title}, ${err.message}`);
+            }),
+        );
+    });
+
+    return promise;
+  })
+  .then(() => run(db, "DROP TABLE books"))
+  .then(() => db.close());

03.asynchronous/c5_async.js

@@ -0,0 +1,28 @@
+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) {
+    await run(db, "INSERT INTO books (title) VALUES (?)", [title]);
+    console.log(`ADD TITLE: ${title}`);
+
+    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/c6_async_contain_error.js

@@ -0,0 +1,48 @@
+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 {
+      await run(db, "INSERT INTO books (title) VALUES (?)", [title]);
+      console.log(`ADD TITLE: ${title}`);
+    } 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();