非同期処理(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_asyncawait_err.js

@@ -0,0 +1,49 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+import { runQueryAsync, allQueryAsync } 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 insertTitleQuery = `INSERT INTO books (title) VALUES (?)`;
+const selectAllQuery = `SELECT * FROM movies`;
+const deleteTableQuery = `DROP TABLE books`;
+
+const titles = ["I Am a Cat", "I Am a Cat", "SANSHIRO"];
+
+async function main() {
+  await runQueryAsync(db, createTableQuery);
+  console.log("Table created");
+
+  for (const title of titles) {
+    try {
+      const result = await runQueryAsync(db, insertTitleQuery, [title]);
+      console.log(`Record inserted successfully with ID: ${result.lastID}`);
+    } catch (err) {
+      console.error(`Error occurred while inserting record: ${err.message}`);
+    }
+  }
+
+  try {
+    const rows = await allQueryAsync(db, selectAllQuery);
+    console.log("All records fetched successfully");
+    for (const row of rows) {
+      console.log(`id:${row.id}, title:${row.title}`);
+    }
+  } catch (err) {
+    console.error(`Error occurred while fetching records: ${err.message}`);
+  }
+
+  await runQueryAsync(db, deleteTableQuery);
+  console.log("Table deleted");
+  db.close();
+}
+
+main();

03.asynchronous/sqlite_asyncawait_noerr.js

@@ -0,0 +1,41 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+import { runQueryAsync, allQueryAsync } 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 insertTitleQuery = `INSERT INTO books (title) VALUES (?)`;
+const selectAllQuery = `SELECT * FROM books`;
+const deleteTableQuery = `DROP TABLE books`;
+
+const titles = ["I Am a Cat", "KOKORO", "SANSHIRO"];
+
+async function main() {
+  await runQueryAsync(db, createTableQuery);
+  console.log("Table created");
+
+  for (const title of titles) {
+    const result = await runQueryAsync(db, insertTitleQuery, [title]);
+    console.log(`Record inserted successfully with ID: ${result.lastID}`);
+  }
+
+  const rows = await allQueryAsync(db, selectAllQuery);
+  console.log("All records fetched successfully");
+  for (const row of rows) {
+    console.log(`id:${row.id}, title:${row.title}`);
+  }
+
+  await runQueryAsync(db, deleteTableQuery);
+  console.log("Table deleted");
+  db.close();
+}
+
+main();

03.asynchronous/sqlite_callback_err.js

@@ -0,0 +1,73 @@
+#!/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 insertTitleQuery = `INSERT INTO books (title) VALUES (?)`;
+const selectAllQuery = `SELECT * FROM movies`;
+const deleteTableQuery = `DROP TABLE books`;
+
+const titles = ["I Am a Cat", "I Am a Cat", "SANSHIRO"];
+let insertCount = 0;
+
+function main() {
+  createTable();
+}
+
+function createTable() {
+  db.run(createTableQuery, insertTitles);
+}
+
+function insertTitles() {
+  console.log("Table created");
+  for (const title of titles) {
+    db.run(insertTitleQuery, [title], displayID);
+  }
+}
+
+function displayID(err) {
+  if (err) {
+    console.error(`Error occurred while inserting record: ${err.message}`);
+  } else {
+    console.log(`Record inserted successfully with ID: ${this.lastID}`);
+  }
+  insertCount++;
+  if (insertCount === titles.length) {
+    fetchAll();
+  }
+}
+
+function fetchAll() {
+  db.all(selectAllQuery, displayAll);
+}
+
+function displayAll(err, rows) {
+  if (err) {
+    console.error(`Error occurred while fetching records: ${err.message}`);
+  } else {
+    console.log("All records fetched successfully");
+    for (const row of rows) {
+      console.log(`id:${row.id}, title:${row.title}`);
+    }
+  }
+  deleteTable();
+}
+
+function deleteTable() {
+  db.run(deleteTableQuery, closeDB);
+}
+
+function closeDB() {
+  console.log("Table deleted");
+  db.close();
+}
+
+main();

03.asynchronous/sqlite_callback_noerr.js

@@ -0,0 +1,65 @@
+#!/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 insertTitleQuery = `INSERT INTO books (title) VALUES (?)`;
+const selectAllQuery = `SELECT * FROM books`;
+const deleteTableQuery = `DROP TABLE books`;
+
+const titles = ["I Am a Cat", "KOKORO", "SANSHIRO"];
+let insertCount = 0;
+
+function main() {
+  createTable();
+}
+
+function createTable() {
+  db.run(createTableQuery, insertTitles);
+}
+
+function insertTitles() {
+  console.log("Table created");
+  for (const title of titles) {
+    db.run(insertTitleQuery, [title], displayID);
+  }
+}
+
+function displayID() {
+  console.log(`Record inserted successfully with ID: ${this.lastID}`);
+  insertCount++;
+  if (insertCount === titles.length) {
+    fetchAll();
+  }
+}
+
+function fetchAll() {
+  db.all(selectAllQuery, displayAll);
+}
+
+function displayAll(err, rows) {
+  console.log("All records fetched successfully");
+  for (const row of rows) {
+    console.log(`id:${row.id}, title:${row.title}`);
+  }
+  deleteTable();
+}
+
+function deleteTable() {
+  db.run(deleteTableQuery, closeDB);
+}
+
+function closeDB() {
+  console.log("Table deleted");
+  db.close();
+}
+
+main();

03.asynchronous/sqlite_promise_err.js

@@ -0,0 +1,63 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+import { runQueryAsync, allQueryAsync } 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 insertTitleQuery = `INSERT INTO books (title) VALUES (?)`;
+const selectAllQuery = `SELECT * FROM movies`;
+const deleteTableQuery = `DROP TABLE books`;
+
+const titles = ["I Am a Cat", "I Am a Cat", "SANSHIRO"];
+
+function main() {
+  return runQueryAsync(db, createTableQuery)
+    .then(function () {
+      console.log("Table created");
+      const requests = titles.map(function (title) {
+        return runQueryAsync(db, insertTitleQuery, [title])
+          .then(function (result) {
+            console.log(
+              `Record inserted successfully with ID: ${result.lastID}`,
+            );
+          })
+          .catch(function (err) {
+            console.error(
+              `Error occurred while inserting record: ${err.message}`,
+            );
+          });
+      });
+      return Promise.all(requests);
+    })
+    .then(function () {
+      return allQueryAsync(db, selectAllQuery);
+    })
+    .then(function (rows) {
+      console.log("All records fetched successfully");
+      for (const row of rows) {
+        console.log(`id:${row.id}, title:${row.title}`);
+      }
+    })
+    .catch(function (err) {
+      console.error(`Error occurred while fetching records: ${err.message}`);
+    })
+    .then(function () {
+      return runQueryAsync(db, deleteTableQuery);
+    })
+    .then(function () {
+      console.log("Table deleted");
+    })
+    .finally(function () {
+      db.close();
+    });
+}
+
+main();

03.asynchronous/sqlite_promise_noerr.js

@@ -0,0 +1,54 @@
+#!/usr/bin/env node
+
+import sqlite3 from "sqlite3";
+import { runQueryAsync, allQueryAsync } 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 insertTitleQuery = `INSERT INTO books (title) VALUES (?)`;
+const selectAllQuery = `SELECT * FROM books`;
+const deleteTableQuery = `DROP TABLE books`;
+
+const titles = ["I Am a Cat", "KOKORO", "SANSHIRO"];
+
+function main() {
+  return runQueryAsync(db, createTableQuery)
+    .then(function () {
+      console.log("Table created");
+      const requests = titles.map(function (title) {
+        return runQueryAsync(db, insertTitleQuery, [title]).then(
+          function (result) {
+            console.log(
+              `Record inserted successfully with ID: ${result.lastID}`,
+            );
+          },
+        );
+      });
+      return Promise.all(requests);
+    })
+    .then(function () {
+      return allQueryAsync(db, selectAllQuery);
+    })
+    .then(function (rows) {
+      console.log("All records fetched successfully");
+      for (const row of rows) {
+        console.log(`id:${row.id}, title:${row.title}`);
+      }
+      return runQueryAsync(db, deleteTableQuery);
+    })
+    .then(function () {
+      console.log("Table deleted");
+    })
+    .finally(function () {
+      db.close();
+    });
+}
+
+main();

03.asynchronous/sqlite_utils.js

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