Node.js连接MySQL数据库|极客教程

Node.js连接MySQL数据库

Node.js是一种流行的服务器端JavaScript运行时环境，可以用来构建高性能的网络应用程序。MySQL是一种广泛使用的关系型数据库管理系统。在开发Web应用程序时，经常需要与数据库交互来存储和检索数据。本文将详细介绍如何使用Node.js连接MySQL数据库，并执行一些基本的数据库操作。

准备工作

在开始之前，我们需要先安装Node.js和MySQL数据库。确保你已经安装了Node.js和MySQL，并且你的数据库服务器正在运行。

接下来，我们需要安装Node.js的MySQL模块，用于连接和操作MySQL数据库。打开命令行，执行以下命令安装MySQL模块：

npm install mysql

安装完成后，我们就可以开始连接MySQL数据库了。

连接MySQL数据库

在Node.js中连接MySQL数据库需要使用MySQL模块提供的createConnection方法，该方法接受一个包含连接信息的对象作为参数，包括主机名、用户名、密码和数据库名称。以下是一个简单的示例代码：

const mysql = require('mysql');

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

connection.connect((err) => {
  if (err) {
    console.error('Error connecting to database: ' + err.stack);
    return;
  }
  console.log('Connected to database as ID ' + connection.threadId);
});

在上面的示例代码中，我们创建了一个名为connection的数据库连接对象，并使用connect方法连接到数据库。如果连接成功，控制台会输出一个类似Connected to database as ID x的信息。

执行查询操作

一旦与数据库连接成功，我们可以执行查询操作来检索或修改数据。在MySQL模块中，可以使用query方法执行SQL查询语句。以下是一个示例代码，用于查询数据库中的所有用户：

connection.query('SELECT * FROM users', (err, results, fields) => {
  if (err) {
    console.error('Error querying database: ' + err.stack);
    return;
  }
  console.log('Query results: ', results);
});

在上面的代码中，我们执行了一个简单的SELECT查询语句，检索users表中的所有数据。查询结果会在回调函数中作为results参数返回。

执行插入操作

除了查询操作，我们还可以执行插入操作来向数据库中插入新的数据。以下是一个示例代码，用于向users表中插入一条新记录：

const newUser = { username: 'johndoe', email: 'johndoe@example.com' };

connection.query('INSERT INTO users SET ?', newUser, (err, results) => {
  if (err) {
    console.error('Error inserting into database: ' + err.stack);
    return;
  }
  console.log('Inserted new user with ID ' + results.insertId);
});

在上面的代码中，我们使用INSERT INTO语句向users表中插入一个新的用户记录。插入成功后，回调函数会返回插入记录的ID。

执行更新操作

除了插入操作，我们还可以执行更新操作来修改数据库中的数据。以下是一个示例代码，用于更新users表中ID为1的用户记录：

const updatedUser = { username: 'newusername', email: 'newemail@example.com' };

connection.query('UPDATE users SET ? WHERE id = ?', [updatedUser, 1], (err, results) => {
  if (err) {
    console.error('Error updating database: ' + err.stack);
    return;
  }
  console.log('Updated user with ID 1');
});

在上面的代码中，我们使用UPDATE语句更新users表中ID为1的用户记录。更新成功后，回调函数会输出一个成功的信息。

执行删除操作

最后，我们还可以执行删除操作来从数据库中删除数据。以下是一个示例代码，用于删除users表中ID为1的用户记录：

connection.query('DELETE FROM users WHERE id = 1', (err, results) => {
  if (err) {
    console.error('Error deleting from database: ' + err.stack);
    return;
  }
  console.log('Deleted user with ID 1');
});

在上面的代码中，我们使用DELETE FROM语句删除users表中ID为1的用户记录。删除成功后，回调函数会输出一个成功的信息。

关闭数据库连接

当不再需要与数据库交互时，我们需要手动关闭数据库连接，以释放资源。以下是一个示例代码，用于关闭数据库连接：

connection.end((err) => {
  if (err) {
    console.error('Error closing database connection: ' + err.stack);
    return;
  }
  console.log('Database connection closed');
});

在上面的代码中，我们使用end方法关闭数据库连接。关闭成功后，控制台会输出一个类似Database connection closed的信息。