Node连接mysql数据库方法介绍

当你想要在 Node.js 中操作 MySQL 数据库时，就需要先通过连接建立起与 MySQL 的连接。下面将为你详细介绍 Node.js 连接 MySQL 数据库的方法。

安装 MySQL 模块

在使用 Node.js 连接 MySQL 数据库时，需要使用 mysql 模块，因此需要先通过 npm 安装 mysql 模块。可以通过以下命令进行安装：

npm install mysql

建立连接

安装完成 mysql 模块之后，就可以在 Node.js 中使用 require 方法导入 mysql 模块。然后，使用 mysql 模块的 createConnection() 方法来建立与 MySQL 数据库的连接，并传入连接信息，如用户名、密码等。

示例代码：

const mysql = require('mysql');

const conn = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'your-password',
  database: 'your-database-name'
});

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

以上代码创建了一个名为 conn 的连接对象，其中 host、user、password、database 属性分别为 MySQL 数据库的地址、用户名、密码和数据库名。然后使用 connect() 方法来检测是否连接成功。

执行 SQL 查询语句

连接成功之后，就可以使用 conn.query() 方法来执行 MySQL 的 SQL 查询语句了。该方法接收两个参数：第一个参数为 SQL 查询语句，第二个参数为回调函数。

示例代码：

const mysql = require('mysql');

const conn = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'your-password',
  database: 'your-database-name'
});

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

  let sql = 'SELECT * FROM your-table-name';
  conn.query(sql, (err, result) => {
    if (err) throw err;
    console.log(result);
  });
});

以上代码中，query() 方法将 SQL 查询语句作为第一个参数，回调函数作为第二个参数，并输出查询到的结果。

执行 SQL 更新语句

除了查询操作，还可以使用 conn.query() 方法执行 MySQL 的 SQL 更新语句。常见的更新语句有 INSERT、UPDATE、DELETE 等。

示例代码：

const mysql = require('mysql');

const conn = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'your-password',
  database: 'your-database-name'
});

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

  let sql = "INSERT INTO your-table-name (name, age) VALUES ('John', 25)";
  conn.query(sql, (err, result) => {
    if (err) throw err;
    console.log('Record inserted.');
  });
});

以上代码中，query() 方法的第一个参数为 INSERT SQL 语句，回调函数在执行成功后输出日志。

以上就是 Node 连接 MySQL 数据库的方法介绍。通过 connect() 方法可以建立与 MySQL 数据库的连接，通过 query() 方法可以执行 MySQL 的 SQL 查询和更新语句。