MySQL - Node.js 语法



Node.js 是一个 JavaScript 运行时环境,允许开发人员在 Web 浏览器之外运行 JavaScript 代码,从而实现服务器端脚本。

当我们谈论 Node.js MySQL 连接器时,我们指的是一个特定的库,它促进了 Node.js 应用程序与 MySQL 数据库之间的通信。此连接器使开发人员能够通过提供简化任务的方法和功能来与 MySQL 数据库交互,例如使用 JavaScript 代码查询、更新和管理数据库中的数据。从本质上讲,它充当桥梁,允许 Node.js 应用程序无缝连接并操作存储在 MySQL 数据库中的数据。

安装 "mysql" 包

要将 MySQL 与 Node.js 一起使用,您可以使用“mysql”包,它是 Node.js 的一个流行的 MySQL 驱动程序。以下是安装 Node.js 和 MySQL 包的步骤:

步骤 1:安装 Node.js

访问 Node.js 官方网站 (https://node.org.cn/) 并下载适合您操作系统的最新版本 Node.js。按照网站上提供的安装说明进行操作。

步骤 2:创建 Node.js 项目

为您的 Node.js 项目创建一个新目录,并使用您的终端或命令提示符导航到该目录。

mkdir mynodeproject
cd mynodeproject

步骤 3:初始化 Node.js 项目

运行以下命令初始化一个新的 Node.js 项目。这将创建一个“package.json”文件。

npm init -y

步骤 4:安装 MySQL 包

使用以下命令安装“mysql”包

npm install mysql

步骤 5:创建 JavaScript 文件

在您的项目目录中创建一个 JavaScript 文件(例如,app.js)。

步骤 6:运行 Node.js 脚本

使用以下命令运行您的 Node.js 脚本

node app.js

现在,您已成功为您的 Node.js 项目安装了 MySQL Node.js 连接器(mysql 包)。

访问 MySQL 的 NodeJS 函数

在 Node.js 中,“mysql”包提供了一组与 MySQL 数据库交互的函数。以下是一些您可以使用的主要函数:

序号 函数和描述
1

createConnection(config)

创建一个新的 MySQL 连接。

2

connect(callback)

建立与 MySQL 服务器的连接。

3

query(sql, values, callback)

在连接的 MySQL 数据库上执行 SQL 查询。您可以在 SQL 查询中提供占位符,并将值作为数组传递以替换占位符。

4

execute(sql, values, callback)

类似于 query 函数,但专门用于执行非选择查询(例如,INSERT、UPDATE、DELETE)。

5

beginTransaction(callback)

开始一个新的事务。

6

commit(callback)

提交当前事务。

7

rollback(callback)

回滚当前事务。

8

end()

关闭 MySQL 连接。

基本示例

以下是使用 Node.js 连接和与 MySQL 数据库通信的步骤:

  • 下载并安装 Node.js
  • 创建一个新目录,导航到该目录,然后运行“npm init -y”。
  • 运行“npm install mysql”。
  • 创建一个 JavaScript 文件(例如,app.js)并使用“mysql”包连接到 MySQL 数据库。
  • 使用 query 或 execute 函数对数据库执行 SQL 查询。
  • 为数据库操作实现错误处理。完成后关闭数据库连接。
  • 使用 node app.js 执行您的 Node.js 脚本。

以下示例显示了 NodeJS 调用任何 MySQL 查询的通用语法。

const mysql = require("mysql2");

// Create a connection to the MySQL database
const connection = mysql.createConnection({
  host: 'your-mysql-hostname',
  user: 'your-mysql-username',
  password: 'your-mysql-password',
  database: 'your-mysql-database',
});

// Connect to the database
connection.connect((err) => {
  if (err) {
    console.error('Error connecting to MySQL:', err);
    return;
  }
  console.log('Connected to MySQL database');
  
  // Perform MySQL operations here
  connection.query("SELECT * FROM your_table", (err, results) => {
    if (err) throw err;
    console.log('Query result:', results);
  });

  // Close the connection when done
  connection.end((err) => {
    if (err) console.error('Error closing MySQL connection:', err);
    else console.log('Connection closed');
  });
});
广告