Node.js mysql2详解|极客教程

Node.js mysql2详解

介绍

在传统的Web开发中，数据库是不可或缺的一部分。而Node.js作为一种高效的服务器端编程语言，也提供了丰富的数据库连接库。在本文中，我们将重点介绍Node.js下的一个流行的MySQL数据库连接库——mysql2。

什么是mysql2？

mysql2是一个基于Node.js的MySQL数据库连接库，它是mysql之后的一个新版本，性能更加出色。它基于纯JavaScript编写，并且提供了对Promise的支持，使得操作数据库更简洁、高效。mysql2的API设计也更加友好，使用起来更加直观。

安装mysql2

要使用mysql2，首先需要安装它。在Node.js项目的根目录下，打开命令行，输入以下命令进行安装：

npm install mysql2

安装完成后，就可以在代码中引入mysql2了。首先在代码文件的顶部加入如下代码：

const mysql = require('mysql2');

连接数据库

使用mysql2连接数据库非常简单。首先，我们需要创建一个数据库连接对象，然后调用连接方法进行连接。下面是一个示例：

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

connection.connect((err) => {
  if (err) throw err;

  // 连接成功后的操作
});

在上面代码中，我们调用了mysql的createConnection方法创建了一个名为connection的数据库连接对象。connect方法用于连接数据库，如果连接过程中出错会抛出异常。

执行SQL查询

连接数据库之后，我们可以执行各种各样的SQL查询了。mysql2提供了多个执行SQL查询的方法，包括query、execute和queryOne等。

首先，我们来看一下query方法的用法：

const query = 'SELECT * FROM users';

connection.query(query, (err, results) => {
  if (err) throw err;

  // 处理查询结果
});

在上面代码中，我们调用了connection对象的query方法来执行SQL查询，query方法接受两个参数，第一个参数是要执行的SQL语句，第二个参数是一个回调函数，用于处理查询结果。

除了query方法，mysql2还提供了execute方法来执行SQL查询。execute方法的用法和query方法类似，只是语法略有不同：

const query = 'SELECT * FROM users';

connection.execute(query, (err, results) => {
  if (err) throw err;

  // 处理查询结果
});

值得一提的是，mysql2的query和execute方法都支持使用占位符的方式，来防止SQL注入攻击。以下是一个使用占位符的查询示例：

const query = 'SELECT * FROM users WHERE id > ?';

connection.query(query, [10], (err, results) => {
  if (err) throw err;

  // 处理查询结果
});

在上面代码中，[10]是一个数组，数组中的元素将替换掉SQL语句中的占位符。

查询结果处理

常规来说，查询结果是一个包含多个行的数组。每一行是一个包含键值对的对象。我们可以通过遍历这个数组，对每一行进行处理。以下是一个处理查询结果的示例：

const query = 'SELECT * FROM users';

connection.query(query, (err, results) => {
  if (err) throw err;

  results.forEach((row) => {
    console.log(row.name);
  });
});

在上面代码中，我们使用forEach方法对查询结果进行遍历，并输出了每一行的name字段。

此外，当我们只需要查询结果的第一行时，可以使用queryOne方法。queryOne方法的用法和query方法类似，只是它回调函数的结果只包含一个对象，而不是数组：

const query = 'SELECT * FROM users';

connection.queryOne(query, (err, row) => {
  if (err) throw err;

  console.log(row.name);
});

在上面代码中，我们使用queryOne方法查询users表的第一行，并输出name字段。

执行SQL更新

除了查询，我们还可以使用mysql2执行SQL更新操作，例如插入、更新和删除数据。

插入数据

要插入数据，我们可以使用query方法或execute方法。插入数据的SQL语句通常使用INSERT INTO语句。以下是一个插入数据的示例：

const query = 'INSERT INTO users(name, age) VALUES(?, ?)';

connection.query(query, ['John Doe', 25], (err, results) => {
  if (err) throw err;

  // 插入成功后的操作
});

在上面代码中，我们插入了一个新用户，包括name和age字段。我们可以使用占位符的方式将实际的值传递给query方法。

更新数据

要更新数据，我们可以使用query方法或execute方法。更新数据的SQL语句通常使用UPDATE语句。以下是一个更新数据的示例：

const query = 'UPDATE users SET age = ? WHERE id = ?';

connection.query(query, [30, 2], (err, results) => {
  if (err) throw err;

  // 更新成功后的操作
});

在上面代码中，我们更新了id为2的用户的age字段为30。

删除数据

要删除数据，我们可以使用query方法或execute方法。删除数据的SQL语句通常使用DELETE FROM语句。以下是一个删除数据的示例：

const query = 'DELETE FROM users WHERE id = ?';

connection.query(query, [3], (err, results) => {
  if (err) throw err;

  // 删除成功后的操作
});

在上面代码中，我们删除了id为3的用户。

使用Promise

mysql2对Promise提供了良好的支持，可以通过使用Promise来简化异步操作。以下是一个使用Promise的示例：

const query = 'SELECT * FROM users';

connection.promise().query(query)
  .then(([results, fields]) => {
    results.forEach((row) => {
      console.log(row.name);
    });
  })
  .catch((err) => {
    throw err;
  });

在上面代码中，我们使用promise方法将连接对象转换为Promise风格，并调用query方法进行查询。query方法返回一个Promise对象，我们可以通过then和catch方法对其进行处理。

总结

mysql2是一个强大且易于使用的Node.js数据库连接库，可以帮助我们轻松地连接MySQL数据库并执行各种SQL操作。在本文中，我们介绍了mysql2的安装方法、连接数据库、执行SQL查询和更新等常用操作。同时，我们也了解了如何使用Promise来简化异步操作。通过掌握mysql2，我们可以更好地进行数据库相关的开发工作。