nodejs进阶(6)—连接MySQL数据库示例

Node.js 是一个非常流行的 JavaScript 运行时环境，可以用于开发服务器端应用程序。其中连接 MySQL 数据库是非常常见的需求，这里提供一个简单的示例来完成该操作。

步骤一：安装MySQL数据库

首先，需要在本地环境中安装 MySQL 数据库，以便连接和测试。MySQL 官方提供了可用于大多数操作系统的安装包和安装说明。一般来说，可以选择适合自己操作系统的安装包进行安装。

步骤二：安装Node.js

在开始之前，需要确保已安装 Node.js。Node.js 可以从官方网站 https://nodejs.org/ 上下载，也可以选择适合自己系统的包并进行安装。

步骤三：创建一个 Node.js 应用程序

可以使用以下命令创建一个基本的 Node.js 应用程序：

mkdir myapp
cd myapp
npm init -y

步骤四：安装 MySQL 库

在使用 Node.js 连接 MySQL 数据库之前，需要先安装 Node.js 的 MySQL 库。可以使用以下命令安装：

npm install --save mysql

步骤五：编写代码

使用以下代码创建一个 index.js 文件，该文件演示了如何使用 Node.js 连接 MySQL 数据库并执行 SELECT 语句查询：

// 引入 mysql 库
const mysql = require('mysql');

// 创建连接池
const pool = mysql.createPool({
    connectionLimit: 10,
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydb'
});

// 执行 SELECT 查询并输出结果
pool.query('SELECT * FROM mytable', (err, rows) => {
    console.log(rows);
});

// 关闭连接池
pool.end();

这段代码连接到名为 mydb 的数据库，查询名为 mytable 的表格，并输出查询结果。

示例一：插入数据

现在，我们来看一下如何向 MySQL 数据库插入一条数据。使用以下代码：

// 引入 mysql 库
const mysql = require('mysql');

// 创建连接池
const pool = mysql.createPool({
    connectionLimit: 10,
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydb'
});

// 定义插入语句
const insertSql = "INSERT INTO mytable (col1, col2) VALUES (?, ?)";

// 定义插入数据
const insertData = ['value1', 'value2'];

// 执行插入操作并输出结果
pool.query(insertSql, insertData, (err, rows) => {
    console.log(rows);
});

// 关闭连接池
pool.end();

在此示例中，我们定义了一个插入语句，将值 value1 和 value2 插入到名为 mytable 的表格中的 col1 和 col2 列。该插入操作执行完成后，将显示插入数据的结果。

示例二：参数化查询

在编写 SQL 语句时，使用参数化查询是一个重要的安全注意事项。参数化查询可以防止 SQL 注入攻击。以下是参数化查询的示例代码：

// 引入 mysql 库
const mysql = require('mysql');

// 创建连接池
const pool = mysql.createPool({
    connectionLimit: 10,
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydb'
});

// 定义查询语句和参数
const querySql = "SELECT * FROM mytable WHERE col1 = ?";
const queryParam = ['value1'];

// 执行查询操作并输出结果
pool.query(querySql, queryParam, (err, rows) => {
    console.log(rows);
});

// 关闭连接池
pool.end();

在此示例中，我们查询具有值 value1 的 col1 的行。查询语句使用了参数化查询，使查询更安全，从而防止 SQL 注入攻击。

总结

这是一个简单的连接 MySQL 数据库的示例，我们可以使用该示例来学习如何使用 Node.js 访问 MySQL 数据库。在编写有关数据库的代码时，使用参数化查询可以防止 SQL 注入攻击。此外，可以使用连接池来管理并发的数据库连接。