如何使用Node.js连接到MySQL数据库？

在Node.js中连接MySQL数据库，我们通常使用mysql模块，这是一个Node.js的第三方模块，用于连接和操作MySQL数据库。

安装mysql模块

你需要在你的项目中安装mysql模块，你可以使用npm（Node.js的包管理器）来安装，在你的项目目录中打开终端，然后输入以下命令：

npm install mysql

创建数据库连接

安装完成后，你可以在你的Node.js代码中使用require函数来引入mysql模块，并创建一个到MySQL数据库的连接。

var mysql = require('mysql');
var con = mysql.createConnection({
  host: "localhost",
  user: "yourusername",
  password: "yourpassword",
  database: "mydb"
});

在上述代码中，我们创建了一个到MySQL数据库的连接，你需要将yourusername、yourpassword和mydb替换为你的MySQL服务器的实际用户名、密码和数据库名。

连接数据库

创建连接后，你可以使用connect函数来连接到MySQL数据库。

con.connect(function(err) {
  if (err) throw err;
  console.log("Connected!");
});

如果连接成功，控制台将打印出"Connected!"。

执行SQL查询

一旦连接到数据库，你就可以执行SQL查询了，以下代码执行一个查询，获取所有用户的信息：

con.query("SELECT * FROM users", function (err, result, fields) {
  if (err) throw err;
  console.log(result);
});

关闭数据库连接

当你完成所有的数据库操作后，你应该关闭数据库连接。

con.end(function(err) {
  if (err) throw err;
  console.log("Disconnected!");
});

如果你的应用程序需要处理多个并发的数据库连接，你可能需要考虑使用连接池。mysql模块提供了一个createPool函数，可以用来创建一个连接池。

使用连接池

以下是如何使用连接池的示例：

var mysql = require('mysql');
var pool  = mysql.createPool({
  connectionLimit : 10,
  host            : 'example.org',
  user            : 'bob',
  password        : 'secret',
  database        : 'my_db'
});
pool.query('SELECT * FROM users', function (error, results, fields) {
  if (error) throw error;
  // ...
});

在这个示例中，我们创建了一个包含最多10个连接的连接池，当需要进行数据库操作时，我们从连接池中获取一个连接，而不是直接创建一个新连接，这可以提高应用程序的性能，特别是在高并发的情况下。

相关问题与解答

Q1: Node.js连接MySQL数据库时，如何防止SQL注入攻击？

A1: 为了防止SQL注入攻击，你应该始终使用参数化查询或者预处理语句，而不是直接在查询字符串中插入用户输入的数据，在mysql模块中，你可以使用?作为占位符，然后将实际的值作为数组传递给query函数。

var userId = "someuser";
con.query("SELECT * FROM users WHERE id = ?", [userId], function (err, result) {
  if (err) throw err;
  console.log(result);
});

Q2: 如果我想在Node.js中使用ORM（对象关系映射）工具，我应该使用哪个库？

A2: 在Node.js中，有几个流行的ORM库可以选择，如Sequelize、TypeORM和Bookshelf等，这些库提供了更高级的API，可以让你用面向对象的方式来操作数据库，Sequelize支持多种数据库，包括MySQL，并且提供了强大的查询生成器和模型定义功能。