Ubuntu 22.04下Node.js与SQLite集成完全指南

与SQLite的连接已建立

已建立与SQLite的连接 undefined:0 [错误: SQLITE_ERROR: 鲨鱼表已存在 在数据库实例上发出’error’事件: ] { errno: 1, code: ‘SQLITE_ERROR’ } Node.js v17.6.0

错误信息表明鲨鱼表已经存在。这是因为当您第一次运行节点命令时，鱼数据库和鲨鱼表已经创建。当您重新运行该命令时，createTable() 函数会再次运行，这将触发错误，因为该表已经存在。

每当您想要在其他文件中使用数据库对象方法操作数据库时，也会触发此错误。例如，在下一步中，您将创建一个将数据插入数据库的文件。为了使用数据库对象，您将导入 db.js 文件并调用相应的插入数据方法。当您运行该文件时，它将依次运行 db.js，从而触发相同的错误。

为了解决这个问题，你可以使用fs模块的existsSync()方法检查项目目录中是否存在名为fish.db的数据库文件。如果数据库文件存在，你将建立与数据库的连接而不调用createTable()函数。如果不存在，你将建立连接并调用createTable()函数。

为了做到这一点，请再次在您的编辑器中打开db.js文件。

1. nano db.js

在你的db.js文件中，添加标记代码以检查数据库文件的存在。

const fs = require("fs");
const sqlite3 = require("sqlite3").verbose();
const filepath = "./fish.db";

function createDbConnection() {
  if (fs.existsSync(filepath)) {
    return new sqlite3.Database(filepath);
  } else {
    const db = new sqlite3.Database(filepath, (error) => {
      if (error) {
        return console.error(error.message);
      }
      createTable(db);
    });
    console.log("与SQLite的连接已经建立");
    return db;
  }
}

首先，您导入用于与文件系统交互的fs模块。其次，在添加的if语句中，您调用fs.existsSync()方法来检查给定参数中文件（此处为./fish.db）是否存在。如果文件存在，您会使用数据库文件路径调用sqlite3.Database()，并省略回调函数。然而，如果文件不存在，您将在回调函数中创建数据库实例，并调用createTable()函数来创建数据库中的表。

此时，完整的文件将会如下所示：

这是文章《如何在Ubuntu 22.04上使用Node.js使用SQLite》的第8部分（共15部分）。

const fs = require("fs");
const sqlite3 = require("sqlite3").verbose();
const filepath = "./fish.db";

function createDbConnection() {
  if (fs.existsSync(filepath)) {
    return new sqlite3.Database(filepath);
  } else {
    const db = new sqlite3.Database(filepath, (error) => {
      if (error) {
        return console.error(error.message);
      }
      createTable(db);
    });
    console.log("已成功建立与SQLite的连接");
    return db;
  }
}

function createTable(db) {
  db.exec(`
  CREATE TABLE sharks
  (
    ID INTEGER PRIMARY KEY AUTOINCREMENT,
    name   VARCHAR(50) NOT NULL,
    color   VARCHAR(50) NOT NULL,
    weight INTEGER NOT NULL
  );
`);
}

module.exports = createDbConnection();

完成更改后，请保存并关闭您的文件。

为确保多次运行db.js文件时不会出错，请使用rm命令删除fish.db文件以重新开始。

1. rm fish.db

运行db.js文件。

1. node db.js

已建立与SQLite的连接

现在，运行db.js文件以确认其是否连接到数据库，并且在所有后续重新运行db.js文件时不会再次尝试创建表格。

1. node db.js

你现在会注意到，你再也不会遇到错误了。

既然你已经建立了与SQLite数据库的连接并创建了一个表格，那么接下来你将向数据库插入数据。

第三步 – 将数据插入SQLite数据库

在这一步中，您将使用node-sqlite3模块创建一个函数，以将数据插入SQLite数据库。您将通过命令行参数将要插入的数据传递给程序。

在你的文本编辑器中创建并打开insertData.js文件。

1. nano insertData.js

在你的insertData.js文件中，添加以下代码以获取命令行参数:

sqlite_demo/insertData.js文件将用于插入数据到SQLite数据库。

const db = require("./db");

function insertRow() {
  const [name, color, weight] = process.argv.slice(2);
}

在第一行中，你导入了在上一步中在db.js文件中导出的数据库对象。在第二行中，你定义了函数insertRow()，你将很快用它来插入数据到表中。在这个函数中，process.argv以数组的形式返回所有的命令行参数。在索引0上的第一个元素包含Node的路径。在索引1上的第二个元素存储了JavaScript程序文件的名称。从索引2开始的所有后续元素包含你传递给文件的命令行参数。为了跳过前两个参数，你使用JavaScript的slice()方法来创建数组的一个浅拷贝，并从索引2开始返回数组的末尾处的元素。

接下来，将以下代码添加到数据库中以插入数据：

sqlite_demo/insertData.js文件演示了如何插入数据到SQLite数据库。

const db = require("./db");

function insertRow() {
  const [name, color, weight] = process.argv.slice(2);
  db.run(
    `INSERT INTO sharks (name, color, weight) VALUES (?, ?, ?)`,
    [name, color, weight],
    function (error) {
      if (error) {
        console.error(error.message);
      }
      console.log(`Inserted a row with the ID: ${this.lastID}`);
    }
  );
}

在前面的代码中，您调用了db.run()方法，它接受三个参数：SQL语句、一个数组和一个回调函数。第一个参数INSERT INTO sharks…是一个将数据插入数据库的SQL语句。在INSERT语句中的VALUES语句中，您传递一个用逗号分隔的值列表，这些值需要被插入。请注意，您传递的是?占位符，而不是直接传递值。这是为了避免SQL注入攻击。在执行过程中，SQLite会自动用db.run()方法的第二个参数中包含的命令行参数值替换占位符，该参数是一个包含值的数组。

最后，db.run() 方法的第三个参数是一个回调函数，在数据成功插入表格后运行。如果出现错误，错误消息会被记录在控制台中。如果插入成功，你将使用返回的 this.lastID 记录新插入行的 ID，同时打印出成功的信息。

现在，将高亮的行添加到调用insertRow()函数的位置。

const db = require("./db");

function insertRow() {
  const [name, color, weight] = process.argv.slice(2);
  db.run(
    `INSERT INTO sharks (name, color, weight) VALUES (?, ?, ?)`,
    [name, color, weight],
    function (error) {
      if (error) {
        console.error(error.message);
      }
      console.log(`插入了一行数据，ID为: ${this.lastID}`);
    }
  );
}

insertRow();

保存并关闭您的文件，然后使用鲨鱼名称、颜色和重量参数运行文件。

1. node insertData.js sammy blue 1900

输出表明已将行插入到具有主要ID 1的表中。

const db = require("./db");

function selectRows() {
  db.each(`SELECT * FROM sharks`, (error, row) => {
    if (error) {
      throw new Error(error.message);
    }
    console.log(row);
  });
}

const db = require("./db");

function selectRows() {
  db.each(`SELECT * FROM sharks`, (error, row) => {
    if (error) {
      throw new Error(error.message);
    }
    console.log(row);
  });
}

selectRows();

const db = require("./db");

function updateRow() {
  const [id, name] = process.argv.slice(2);
  db.run(
    `UPDATE sharks SET name = ? WHERE id = ?`,
    [name, id],
    function (error) {
      if (error) {
        console.error(error.message);
      }
      console.log(`行 ${id} 已被更新`);
    }
  );
}

updateRow();

const db = require("./db");

async function deleteRow() {
  const [id] = process.argv.slice(2);
  db.run(`DELETE FROM sharks WHERE id = ?`, [id], function (error) {
    if (error) {
      return console.error(error.message);
    }
    console.log(`ID为 ${id} 的行已被删除`);
  });
}

deleteRow();

ID为 2 的行已被删除

{ ID: 1, name: 'sammy', color: 'blue', weight: 1900 }