从零入门：Node.js连接MySQL数据库的正确姿势

2023-11-21 14:03:04

前言：Node.js与MySQL

Node.js因其轻量、快速和跨平台等特性，受到广大开发者的青睐，广泛应用于构建各种类型的应用程序。同时，MySQL作为一款功能强大且开源的数据库管理系统，亦颇受开发者青睐，可与多种编程语言协同工作。在本文中，我们将重点探讨如何在Node.js中建立与MySQL数据库的连接，并逐步学习如何执行查询、插入、更新和删除等基本操作，让您轻松掌控数据管理之道。

建立Node.js与MySQL的连接

1. 安装必要的软件包

首先，我们需要安装必要的软件包来支持Node.js与MySQL数据库的通信。打开终端或命令提示符，输入以下命令：

npm install mysql

2. 引入软件包

安装完成后，在Node.js应用程序中导入mysql软件包：

const mysql = require('mysql');

3. 创建数据库连接

接下来，我们需要创建与MySQL数据库的连接，为此，我们可以使用mysql.createConnection()函数，并在其中指定数据库的配置信息，包括主机名、用户名、密码、数据库名称等：

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

4. 连接数据库

创建连接后，使用connection.connect()方法进行连接：

connection.connect((err) => {
  if (err) {
    console.error('Error connecting to the database:', err);
    return;
  }

  console.log('Connected to the database successfully!');
});

执行SQL查询

连接数据库后，我们可以执行SQL查询来检索、插入、更新和删除数据。

1. 查询数据

要查询数据，我们可以使用connection.query()方法。例如，以下代码将从users表中查询所有用户的数据：

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

  console.log('Query results:', results);
});

2. 插入数据

要插入数据，我们可以使用connection.query()方法并传入相应的SQL语句。例如，以下代码将向users表中插入一条新的用户数据：

connection.query('INSERT INTO users (name, email, password) VALUES ("John Doe", "johndoe@example.com", "password123")', (err, results, fields) => {
  if (err) {
    console.error('Error inserting data into the database:', err);
    return;
  }

  console.log('Data inserted successfully:', results);
});

3. 更新数据

要更新数据，我们可以使用connection.query()方法并传入相应的SQL语句。例如，以下代码将更新users表中ID为1的用户的数据：

connection.query('UPDATE users SET name = "Jane Doe" WHERE id = 1', (err, results, fields) => {
  if (err) {
    console.error('Error updating data in the database:', err);
    return;
  }

  console.log('Data updated successfully:', results);
});

4. 删除数据

要删除数据，我们可以使用connection.query()方法并传入相应的SQL语句。例如，以下代码将从users表中删除ID为1的用户的数据：

connection.query('DELETE FROM users WHERE id = 1', (err, results, fields) => {
  if (err) {
    console.error('Error deleting data from the database:', err);
    return;
  }

  console.log('Data deleted successfully:', results);
});