MySQL 与 Node.js

作者:编程家 分类: 编程代码 时间:2025-07-17

使用MySQL与Node.js进行数据库操作

连接MySQL数据库

在使用Node.js进行MySQL数据库操作之前,首先需要安装MySQL驱动程序。可以使用`npm`命令来安装`mysql`模块:

javascript

npm install mysql

安装完毕后,可以使用以下代码来连接MySQL数据库:

javascript

const mysql = require('mysql');

const connection = mysql.createConnection({

host: 'localhost',

user: 'root',

password: 'password',

database: 'mydatabase'

});

connection.connect((err) => {

if (err) throw err;

console.log('Connected to MySQL database');

});

查询数据

可以使用以下代码来执行简单的SELECT查询并输出结果:

javascript

connection.query('SELECT * FROM users', (err, rows) => {

if (err) throw err;

console.log('Users:');

rows.forEach((row) => {

console.log(row.name);

});

});

插入数据

可以使用以下代码来执行INSERT语句插入数据:

javascript

const user = { name: 'John', email: 'john@example.com' };

connection.query('INSERT INTO users SET ?', user, (err, result) => {

if (err) throw err;

console.log('Inserted new user with ID:', result.insertId);

});

更新数据

可以使用以下代码来执行UPDATE语句更新数据:

javascript

const userId = 1;

const newName = 'Jane';

connection.query('UPDATE users SET name = ? WHERE id = ?', [newName, userId], (err, result) => {

if (err) throw err;

console.log('Updated', result.changedRows, 'rows');

});

删除数据

可以使用以下代码来执行DELETE语句删除数据:

javascript

const userId = 1;

connection.query('DELETE FROM users WHERE id = ?', userId, (err, result) => {

if (err) throw err;

console.log('Deleted', result.affectedRows, 'rows');

});

关闭连接

当数据库操作完成后,应该关闭数据库连接,以释放资源:

javascript

connection.end((err) => {

if (err) throw err;

console.log('Disconnected from MySQL database');

});

以上是使用MySQL与Node.js进行数据库操作的基本步骤和示例代码。通过连接数据库、查询数据、插入数据、更新数据和删除数据等操作,可以实现对MySQL数据库的增删改查功能。使用Node.js进行数据库操作可以实现高效、灵活的数据处理,适用于各种Web应用程序的开发。