在 Node.js 中连接到 MySQL 数据库服务器通常需要使用适当的 MySQL 驱动程序。以下是使用 mysql2 驱动程序连接到 MySQL 数据库服务器的基本步骤:

步骤 1: 安装 mysql2 模块

首先,在项目目录下执行以下命令安装 mysql2 模块:
npm install mysql2

步骤 2: 编写连接代码

创建一个 Node.js 文件(例如,app.js)并编写以下连接 MySQL 数据库的代码:
const mysql = require('mysql2');

// 创建数据库连接池
const pool = mysql.createPool({
  host: 'your_database_host',
  user: 'your_database_user',
  password: 'your_database_password',
  database: 'your_database_name',
  waitForConnections: true,
  connectionLimit: 10,
  queueLimit: 0
});

// 获取连接
pool.getConnection((err, connection) => {
  if (err) {
    console.error('Error getting connection: ' + err.message);
  } else {
    console.log('Connected to the database');

    // 在这里可以执行数据库查询等操作

    // 释放连接
    connection.release();
  }
});

// 关闭连接池
pool.end(err => {
  if (err) {
    console.error('Error closing the database connection pool: ' + err.message);
  } else {
    console.log('Database connection pool closed');
  }
});

替换 your_database_host、your_database_user、your_database_password 和 your_database_name 分别为你的 MySQL 数据库的主机、用户名、密码和数据库名。

步骤 3: 执行数据库查询

在获取连接的回调函数中,你可以执行数据库查询等操作。以下是一个简单的例子:
// 获取连接
pool.getConnection((err, connection) => {
  if (err) {
    console.error('Error getting connection: ' + err.message);
  } else {
    console.log('Connected to the database');

    // 执行查询
    connection.query('SELECT * FROM your_table', (queryErr, results) => {
      if (queryErr) {
        console.error('Error executing query: ' + queryErr.message);
      } else {
        console.log('Query result:', results);
      }

      // 释放连接
      connection.release();
    });
  }
});

替换 your_table 为你的数据库表名。

以上是一个简单的连接到 MySQL 数据库服务器的示例。实际中,你可能需要处理连接池的生命周期,封装数据库查询,处理错误,以及在应用程序中正确使用数据库连接。


转载请注明出处:http://www.zyzy.cn/article/detail/8033/MySQL