MySQL - Node.js 语法
Node.js 是一个 JavaScript 运行时环境,允许开发者在 Web 浏览器之外运行 JavaScript 代码,从而实现服务器端脚本编写。
当我们谈论 Node.js MySQL 连接器时,我们指的是一个特定的库,它促进了 Node.js 应用程序和 MySQL 数据库之间的通信。该连接器通过提供方法和功能,简化了使用 JavaScript 代码在数据库中查询、更新和管理数据等任务,从而使开发者能够与 MySQL 数据库进行交互。本质上,它充当桥梁的作用,使 Node.js 应用程序能够无缝连接并操作存储在 MySQL 数据库中的数据。
安装"mysql"包
要将 MySQL 与 Node.js 结合使用,您可以使用"mysql"包,这是一个流行的 Node.js MySQL 驱动程序。以下是安装 Node.js 和 MySQL 包的步骤 -
步骤 1:安装 Node.js
访问 Node.js 官方网站 (https://nodejs.org/) 并下载适用于您操作系统的最新版本的 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 数据库交互的函数。以下是一些您可以使用的主要函数:
S.No | 函数 &说明 |
---|---|
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 数据库。
- 使用查询或执行函数对数据库执行 SQL 查询。
- 实现数据库操作的错误处理。完成后关闭数据库连接。
- 使用 node app.js 执行 Node.js 脚本。
以下示例展示了 NodeJS 调用任何 MySQL 查询的通用语法。
const mysql = require("mysql2"); // 创建与 MySQL 数据库的连接 const connection = mysql.createConnection({ host: 'your-mysql-hostname', user: 'your-mysql-username', password: 'your-mysql-password', database: 'your-mysql-database', }); // 连接数据库 connection.connect((err) => { if (err) { console.error('Error connecting to MySQL:', err); return; } console.log('Connected to MySQL database'); // 在这里执行 MySQL 操作 connection.query("SELECT * FROM your_table", (err, results) => { if (err) throw err; console.log('Query result:', results); }); // 完成后关闭连接 connection.end((err) => { if (err) console.error('Error closing MySQL connection:', err); else console.log('Connection closed'); }); });