快速入门：Node.js服务端实战，一文搞定数据库操作！

2023-10-14 08:38:20

Node.js 与 MySQL：强强联手，数据库操作如虎添翼

数据库操作的基石：Node.js

在当今瞬息万变的科技世界中，Node.js 已成为服务器端开发的当红炸子鸡，凭借其非凡的异步编程能力，它能够同时处理大量并发请求，大幅提升服务器性能。而对于服务端开发来说，数据库操作至关重要。熟练掌握 Node.js 的数据库操作技巧，将让你如虎添翼，轻松应对复杂的开发任务。

关系型数据库王者：MySQL

说到关系型数据库，MySQL 无疑是行业的翘楚。凭借其强大的功能、优异的性能和广泛的适用性，它已成为无数开发者的首选。而 Node.js 与 MySQL 的结合，更是创造了一段数据库操作史上的佳话。强强联手，它们将各自的优势完美融合，让数据库操作变得更加高效、便捷。

Node.js 与 MySQL 携手共进

首先，我们需要在项目中引入 MySQL 驱动程序，即 mysql。我们可以使用 npm 包管理器轻松安装它：

npm install mysql

接下来，我们需要创建数据库连接。我们可以使用 createConnection() 函数来实现：

const mysql = require('mysql');
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'test'
});

在这个例子中，我们连接到一个名为 “test” 的数据库，并使用 “root” 作为用户名和 “password” 作为密码。当然，你可以根据自己的实际情况修改这些参数。

连接成功后，我们就可以开始对数据库进行操作了。我们可以使用 query() 函数来执行 SQL 语句。例如，如果我们要查询所有用户，我们可以使用以下代码：

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

  console.log('Data received from Db:\n');
  console.log(rows);
});

上面的代码中，SELECT * FROM users 是 SQL 语句，用于查询所有用户。connection.query() 函数执行 SQL 语句，并将结果作为第二个参数传递给回调函数。在这个回调函数中，我们可以处理查询结果。

我们也可以使用 insert()、update() 和 delete() 函数来对数据库进行增删改查操作。这些函数的使用方法与 query() 函数类似。

最后，我们需要关闭数据库连接。我们可以使用 end() 函数来实现：

connection.end();

掌握了这些技巧，你将能够轻松应对各种数据库操作任务，在 Node.js 的开发世界中乘风破浪。

代码示例

为了加深理解，我们提供了一个代码示例，展示如何使用 Node.js 连接 MySQL 数据库并执行基本的 CRUD 操作：

const mysql = require('mysql');

// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'test'
});

// 连接数据库
connection.connect((err) => {
  if (err) throw err;
  console.log('Connected to MySQL database!');
});

// 查询所有用户
connection.query('SELECT * FROM users', (err, rows) => {
  if (err) throw err;
  console.log('Query results:');
  console.log(rows);
});

// 插入新用户
const newUser = { name: 'John Doe', email: 'john.doe@example.com' };
connection.query('INSERT INTO users SET ?', newUser, (err, result) => {
  if (err) throw err;
  console.log('New user inserted:');
  console.log(result);
});

// 更新用户
const updatedUser = { id: 1, name: 'Jane Doe' };
connection.query('UPDATE users SET name = ? WHERE id = ?', [updatedUser.name, updatedUser.id], (err, result) => {
  if (err) throw err;
  console.log('User updated:');
  console.log(result);
});

// 删除用户
connection.query('DELETE FROM users WHERE id = 1', (err, result) => {
  if (err) throw err;
  console.log('User deleted:');
  console.log(result);
});

// 关闭数据库连接
connection.end();