JavaScript/Node.js + PostgreSQL 数据库 - CRUD 教程

本教程将向您介绍如何使用 JavaScript/Node.js 编程语言对 PostgreSQL 数据库执行 CRUD 操作(创建、读取、更新、删除)。

发布于

本教程将向您介绍如何使用 JavaScript/Node.js 编程语言对 PostgreSQL 数据库执行 CRUD 操作(创建、读取、更新、删除)。我们将从介绍数据库和编程语言开始,然后逐步指导您完成连接和操作 PostgreSQL 数据库的步骤。最后,我们将提供一个简单的示例,以便您更好地理解如何应用这些概念。

先决条件

为了连接 PostgreSQL 数据库,需要具备以下先决条件:

  1. 安装 Node.js:确保您已成功安装 Node.js 运行时环境。您可以从 Node.js 官方网站下载适用于您的操作系统的 Node.js 安装程序。

  2. PostgreSQL 数据库:您需要安装和配置 PostgreSQL 数据库服务器。您可以从 PostgreSQL 官方网站下载适用于您的操作系统的数据库服务器。

  3. Node.js 库和包:您需要在 Node.js 项目中安装适用于 PostgreSQL 数据库的相关库和包,如pg-promise。您可以使用 Node 包管理器(npm)来安装这些库。

  4. 文本编辑器:使用文本编辑器如 Visual Studio Code 来编写 Node.js 代码。

连接 PostgreSQL 数据库

在开始执行 CRUD 操作之前,我们需要建立与 PostgreSQL 数据库的连接。以下是连接到 PostgreSQL 数据库的步骤:

步骤:安装 pg-promise

在项目文件夹中执行以下命令来安装pg-promise包:

npm install pg-promise

步骤 2:导入必要的模块

在 Node.js 脚本中导入所需的模块,包括pg-promise模块和其他必要的模块。

const promise = require("bluebird")
const pgp = require("pg-promise")({ promiseLib: promise })
const db = pgp("postgres://username:password@localhost:5432/database_name")

确保将username替换为您的数据库用户名,password替换为您的数据库密码,localhost替换为您的数据库主机地址,5432替换为您的数据库端口,database_name替换为您的数据库名称。

执行 CRUD 操作

现在,我们已经建立了与 PostgreSQL 数据库的连接,让我们继续执行 CRUD 操作。

创建记录

要创建新的记录,使用以下代码:

const createRecord = {
  username: "john_doe",
  email: "[email protected]"
}

db.none(
  "INSERT INTO user(username, email) VALUES(${username}, ${email})",
  createRecord
)
  .then(() => {
    console.log("Record created successfully")
  })
  .catch((error) => {
    console.error("Error creating record: " + error.message)
  })

读取记录

要读取记录,使用以下代码:

db.any("SELECT * FROM user")
  .then((records) => {
    records.forEach((record) => {
      console.log("Username: " + record.username + ", Email: " + record.email)
    })
  })
  .catch((error) => {
    console.error("Error reading records: " + error.message)
  })

更新记录

要更新记录,使用以下代码:

const updateRecord = {
  email: "[email protected]"
}

db.none(
  "UPDATE user SET email = ${email} WHERE username = 'john_doe'",
  updateRecord
)
  .then(() => {
    console.log("Record updated successfully")
  })
  .catch((error) => {
    console.error("Error updating record: " + error.message)
  })

删除记录

要删除记录,使用以下代码:

db.none("DELETE FROM user WHERE username = 'john_doe'")
  .then(() => {
    console.log("Record deleted successfully")
  })
  .catch((error) => {
    console.error("Error deleting record: " + error.message)
  })

简单示例

以下是一个简单的示例,演示如何创建、读取、更新和删除用户记录:

const promise = require("bluebird")
const pgp = require("pg-promise")({ promiseLib: promise })
const db = pgp("postgres://username:password@localhost:5432/database_name")

// 创建记录
const createRecord = {
  username: "john_doe",
  email: "[email protected]"
}

db.none(
  "INSERT INTO user(username, email) VALUES(${username}, ${email})",
  createRecord
)
  .then(() => {
    console.log("Record created successfully")
  })
  .catch((error) => {
    console.error("Error creating record: " + error.message)
  })

// 读取记录
db.any("SELECT * FROM user")
  .then((records) => {
    records.forEach((record) => {
      console.log("Username: " + record.username + ", Email: " + record.email)
    })
  })
  .catch((error) => {
    console.error("Error reading records: " + error.message)
  })

// 更新记录
const updateRecord = {
  email: "[email protected]"
}

db.none(
  "UPDATE user SET email = ${email} WHERE username = 'john_doe'",
  updateRecord
)
  .then(() => {
    console.log("Record updated successfully")
  })
  .catch((error) => {
    console.error("Error updating record: " + error.message)
  })

// 删除记录
db.none("DELETE FROM user WHERE username = 'john_doe'")
  .then(() => {
    console.log("Record deleted successfully")
  })
  .catch((error) => {
    console.error("Error deleting record: " + error.message)
  })

总结

通过本教程,您已经学会了如何使用 JavaScript/Node.js 编程语言连接 PostgreSQL 数据库并执行 CRUD 操作。这些基本的数据库操作是构建更复杂应用程序的基础,希望本文能够帮助您在 Node.js 中使用 PostgreSQL 数据库时更加自信和熟练。如果您希望进行更高级的操作,还可以研究 PostgreSQL 数据库的更多功能和 API。