非同期処理(JavaScript)のプログラムを作成

03.asynchronous/package.json

@@ -10,5 +10,8 @@
     "globals": "^15.9.0",
     "prettier": "^3.3.3"
   },
-  "type": "module"
+  "type": "module",
+  "dependencies": {
+    "sqlite3": "^5.1.7"
+  }
 }

03.asynchronous/sqlite_async_await_error.js

@@ -0,0 +1,56 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+import {
+  runQueryAsync,
+  allQueryAsync,
+  closeDatabaseAsync,
+} from "./sqlite_utils.js";
+
+sqlite3.verbose();
+const db = new sqlite3.Database(":memory:");
+
+const createTableQuery =
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE);";
+const insertRowQuery = "INSERT INTO books (title) VALUES (?)";
+const selectAllRowsQuery = "SELECT * FROM movies";
+const dropTableQuery = "DROP TABLE books";
+
+const titles = ["I Am a Cat", "I Am a Cat", "SANSHIRO"];
+
+try {
+  await runQueryAsync(db, createTableQuery);
+  console.log("Table was created successfully");
+
+  for (const title of titles) {
+    try {
+      const result = await runQueryAsync(db, insertRowQuery, [title]);
+      console.log(`Record was inserted successfully with ID: ${result.lastID}`);
+    } catch (err) {
+      if (err instanceof Error && err.code === "SQLITE_CONSTRAINT") {
+        console.error(`Error occurred while inserting record: ${err.message}`);
+      } else {
+        throw err;
+      }
+    }
+  }
+
+  try {
+    const rows = await allQueryAsync(db, selectAllRowsQuery);
+    console.log("All records were fetched successfully");
+    for (const row of rows) {
+      console.log(`id:${row.id}, title:${row.title}`);
+    }
+  } catch (err) {
+    if (err instanceof Error && err.code === "SQLITE_ERROR") {
+      console.error(`Error occurred while fetching records: ${err.message}`);
+    } else {
+      throw err;
+    }
+  }
+
+  await runQueryAsync(db, dropTableQuery);
+  console.log("Table was deleted successfully");
+} finally {
+  await closeDatabaseAsync(db);
+}

03.asynchronous/sqlite_async_await_no_error.js

@@ -0,0 +1,40 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+import {
+  runQueryAsync,
+  allQueryAsync,
+  closeDatabaseAsync,
+} from "./sqlite_utils.js";
+
+sqlite3.verbose();
+const db = new sqlite3.Database(":memory:");
+
+const createTableQuery =
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE);";
+const insertRowQuery = "INSERT INTO books (title) VALUES (?)";
+const selectAllRowsQuery = "SELECT * FROM books";
+const dropTableQuery = "DROP TABLE books";
+
+const titles = ["I Am a Cat", "KOKORO", "SANSHIRO"];
+
+try {
+  await runQueryAsync(db, createTableQuery);
+  console.log("Table was created successfully");
+
+  for (const title of titles) {
+    const result = await runQueryAsync(db, insertRowQuery, [title]);
+    console.log(`Record was inserted successfully with ID: ${result.lastID}`);
+  }
+
+  const rows = await allQueryAsync(db, selectAllRowsQuery);
+  console.log("All records were fetched successfully");
+  for (const row of rows) {
+    console.log(`id:${row.id}, title:${row.title}`);
+  }
+
+  await runQueryAsync(db, dropTableQuery);
+  console.log("Table was deleted successfully");
+} finally {
+  await closeDatabaseAsync(db);
+}

03.asynchronous/sqlite_callback_error.js

@@ -0,0 +1,59 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+
+sqlite3.verbose();
+const db = new sqlite3.Database(":memory:");
+
+const createTableQuery =
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE);";
+const insertRowQuery = "INSERT INTO books (title) VALUES (?)";
+const selectAllRowsQuery = "SELECT * FROM movies";
+const dropTableQuery = "DROP TABLE books";
+
+const titles = ["I Am a Cat", "I Am a Cat", "SANSHIRO"];
+
+db.run(createTableQuery, () => {
+  console.log("Table was created successfully");
+  db.run(insertRowQuery, titles[0], function (err) {
+    if (err) {
+      console.error(`Error occurred while inserting record: ${err.message}`);
+    } else {
+      console.log(`Record was inserted successfully with ID: ${this.lastID}`);
+    }
+    db.run(insertRowQuery, titles[1], function (err) {
+      if (err) {
+        console.error(`Error occurred while inserting record: ${err.message}`);
+      } else {
+        console.log(`Record was inserted successfully with ID: ${this.lastID}`);
+      }
+      db.run(insertRowQuery, titles[2], function (err) {
+        if (err) {
+          console.error(
+            `Error occurred while inserting record: ${err.message}`,
+          );
+        } else {
+          console.log(
+            `Record was inserted successfully with ID: ${this.lastID}`,
+          );
+        }
+        db.all(selectAllRowsQuery, (err, rows) => {
+          if (err) {
+            console.error(
+              `Error occurred while fetching records: ${err.message}`,
+            );
+          } else {
+            console.log("All records were fetched successfully");
+            for (const row of rows) {
+              console.log(`id:${row.id}, title:${row.title}`);
+            }
+          }
+          db.run(dropTableQuery, () => {
+            console.log("Table was deleted successfully");
+            db.close();
+          });
+        });
+      });
+    });
+  });
+});

03.asynchronous/sqlite_callback_no_error.js

@@ -0,0 +1,37 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+
+sqlite3.verbose();
+const db = new sqlite3.Database(":memory:");
+
+const createTableQuery =
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE);";
+const insertRowQuery = "INSERT INTO books (title) VALUES (?)";
+const selectAllRowsQuery = "SELECT * FROM books";
+const dropTableQuery = "DROP TABLE books";
+
+const titles = ["I Am a Cat", "KOKORO", "SANSHIRO"];
+
+db.run(createTableQuery, () => {
+  console.log("Table was created successfully");
+  db.run(insertRowQuery, titles[0], function () {
+    console.log(`Record was inserted successfully with ID: ${this.lastID}`);
+    db.run(insertRowQuery, titles[1], function () {
+      console.log(`Record was inserted successfully with ID: ${this.lastID}`);
+      db.run(insertRowQuery, titles[2], function () {
+        console.log(`Record was inserted successfully with ID: ${this.lastID}`);
+        db.all(selectAllRowsQuery, (err, rows) => {
+          console.log("All records were fetched successfully");
+          for (const row of rows) {
+            console.log(`id:${row.id}, title:${row.title}`);
+          }
+          db.run(dropTableQuery, () => {
+            console.log("Table was deleted successfully");
+            db.close();
+          });
+        });
+      });
+    });
+  });
+});

03.asynchronous/sqlite_promise_error.js

@@ -0,0 +1,64 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+import {
+  runQueryAsync,
+  allQueryAsync,
+  closeDatabaseAsync,
+} from "./sqlite_utils.js";
+
+sqlite3.verbose();
+const db = new sqlite3.Database(":memory:");
+
+const createTableQuery =
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE);";
+const insertRowQuery = "INSERT INTO books (title) VALUES (?)";
+const selectAllRowsQuery = "SELECT * FROM movies";
+const dropTableQuery = "DROP TABLE books";
+
+const titles = ["I Am a Cat", "I Am a Cat", "SANSHIRO"];
+
+runQueryAsync(db, createTableQuery)
+  .then(() => {
+    console.log("Table was created successfully");
+    return runQueryAsync(db, insertRowQuery, titles[0]);
+  })
+  .then((result) => {
+    console.log(`Record was inserted successfully with ID: ${result.lastID}`);
+  })
+  .catch((err) => {
+    console.error(`Error occurred while inserting record: ${err.message}`);
+  })
+  .then(() => runQueryAsync(db, insertRowQuery, titles[1]))
+  .then((result) => {
+    console.log(`Record was inserted successfully with ID: ${result.lastID}`);
+  })
+  .catch((err) => {
+    console.error(`Error occurred while inserting record: ${err.message}`);
+  })
+  .then(() => runQueryAsync(db, insertRowQuery, titles[2]))
+  .then((result) => {
+    console.log(`Record was inserted successfully with ID: ${result.lastID}`);
+  })
+  .catch((err) => {
+    if (err.code === "SQLITE_CONSTRAINT") {
+      console.error(`Error occurred while inserting record: ${err.message}`);
+    }
+  })
+  .then(() => allQueryAsync(db, selectAllRowsQuery))
+  .then((rows) => {
+    console.log("All records were fetched successfully");
+    for (const row of rows) {
+      console.log(`id:${row.id}, title:${row.title}`);
+    }
+  })
+  .catch((err) => {
+    if (err.code === "SQLITE_ERROR") {
+      console.error(`Error occurred while fetching records: ${err.message}`);
+    }
+  })
+  .then(() => runQueryAsync(db, dropTableQuery))
+  .then(() => {
+    console.log("Table was deleted successfully");
+  })
+  .finally(() => closeDatabaseAsync(db));

03.asynchronous/sqlite_promise_no_error.js

@@ -0,0 +1,48 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+import {
+  runQueryAsync,
+  allQueryAsync,
+  closeDatabaseAsync,
+} from "./sqlite_utils.js";
+
+sqlite3.verbose();
+const db = new sqlite3.Database(":memory:");
+
+const createTableQuery =
+  "CREATE TABLE books (id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL UNIQUE);";
+const insertRowQuery = "INSERT INTO books (title) VALUES (?)";
+const selectAllRowsQuery = "SELECT * FROM books";
+const dropTableQuery = "DROP TABLE books";
+
+const titles = ["I Am a Cat", "KOKORO", "SANSHIRO"];
+
+runQueryAsync(db, createTableQuery)
+  .then(() => {
+    console.log("Table was created successfully");
+    return runQueryAsync(db, insertRowQuery, titles[0]);
+  })
+  .then((result) => {
+    console.log(`Record was inserted successfully with ID: ${result.lastID}`);
+    return runQueryAsync(db, insertRowQuery, titles[1]);
+  })
+  .then((result) => {
+    console.log(`Record was inserted successfully with ID: ${result.lastID}`);
+    return runQueryAsync(db, insertRowQuery, titles[2]);
+  })
+  .then((result) => {
+    console.log(`Record was inserted successfully with ID: ${result.lastID}`);
+    return allQueryAsync(db, selectAllRowsQuery);
+  })
+  .then((rows) => {
+    console.log("All records were fetched successfully");
+    for (const row of rows) {
+      console.log(`id:${row.id}, title:${row.title}`);
+    }
+    return runQueryAsync(db, dropTableQuery);
+  })
+  .then(() => {
+    console.log("Table was deleted successfully");
+  })
+  .finally(() => closeDatabaseAsync(db));

03.asynchronous/sqlite_utils.js

@@ -0,0 +1,35 @@
+export function runQueryAsync(db, query, params) {
+  return new Promise((resolve, reject) => {
+    db.run(query, params, function (err) {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(this);
+      }
+    });
+  });
+}
+
+export function allQueryAsync(db, query, params) {
+  return new Promise((resolve, reject) => {
+    db.all(query, params, (err, rows) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve(rows);
+      }
+    });
+  });
+}
+
+export function closeDatabaseAsync(db) {
+  return new Promise((resolve, reject) => {
+    db.close((err) => {
+      if (err) {
+        reject(err);
+      } else {
+        resolve();
+      }
+    });
+  });
+}