如何使用Node.js连接MySQL数据库 - 前端问答学习-微参考

Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境，它让 JavaScript 成为服务器端编程语言。由于 Node.js 具有非阻塞、事件驱动等特点，因此在处理高并发、I/O 密集型任务方面具有明显优势。而 MySQL 是一个广泛使用的关系型数据库管理系统，它在各种规模的企业中都有广泛应用。

要在 Node.js 中连接 MySQL 数据库，我们可以使用第三方库——mysql2 或 mysql。下面我将详细介绍如何使用 mysql2 库连接 MySQL 数据库。

安装 mysql2

首先，在项目中安装 mysql2 库：

npm install mysql2

建立连接

安装完成后，我们可以使用以下代码建立与 MySQL 数据库的连接：

const mysql = require('mysql2');

// 创建连接配置
const connectionConfig = {
host: 'localhost',
user: 'your_username',
password: 'your_password',
database: 'your_database'
};

// 创建连接对象
const connection = mysql.createConnection(connectionConfig);

// 连接数据库
connection.connect((err) => {
if (err) {
console.error('连接失败:', err);
} else {
console.log('连接成功');
}
});

执行查询

连接成功后，我们可以使用连接对象执行 SQL 查询：

// 查询数据
const querySQL = 'SELECT * FROM your_table';

connection.query(querySQL, (err, results, fields) => {
if (err) {
console.error('查询失败:', err);
} else {
console.log('查询结果:', results);
}
});

使用 Promise

mysql2 库支持返回 Promise 对象，这样我们可以使用 async/await 语法进行异步编程：

const mysql = require('mysql2/promise');

async function queryData() {
try {
const connectionConfig = {
host: 'localhost',
user: 'your_username',
password: 'your_password',
database: 'your_database'
};

// 创建连接对象
const connection = await mysql.createConnection(connectionConfig);

// 执行查询
const [results] = await connection.execute('SELECT * FROM your_table');
console.log('查询结果:', results);

// 关闭连接
connection.end();
} catch (err) {
console.error('查询失败:', err);
}
}

queryData();

使用 Pool

在实际应用中，为了提高性能和资源利用率，我们通常会使用连接池（Pool）来管理数据库连接：

const mysql = require('mysql2/promise');

async function queryData() {
try {
const pool = mysql.createPool({
host: 'localhost',
user: 'your_username',
password: 'your_password',
database: 'your_database',
waitForConnections: true,
connectionLimit: 10
});

// 从连接池获取连接
const connection = await pool.getConnection();

// 执行查询
const [results] = await connection.execute('SELECT * FROM your_table');
console.log('查询结果:', results);

// 释放连接
connection.release();
} catch (err) {
console.error('查询失败:', err);
}
}

queryData();

如何使用Node.js连接MySQL数据库