How can I run multiple raw queries with sequelize in MySql?

在使用 Sequelize 进行 MySQL 数据操作时，运行多个原始查询是一个非常常见的需求。Sequelize 提供了一个名为 sequelize.query() 的方法来执行原始 SQL 语句。以下是如何使用这个方法来执行多个原始查询的步骤：

步骤 1: 引入 Sequelize 和配置数据库连接

首先，确保已经安装了 Sequelize 和相应的数据库驱动（例如，对于 MySQL 是 mysql2 包）。然后，创建 Sequelize 实例并配置数据库连接。

javascript
const { Sequelize } = require('sequelize');

// 创建一个 Sequelize 实例并连接到数据库
const sequelize = new Sequelize('database', 'username', 'password', {
  host: 'host',
  dialect: 'mysql'  // 使用 mysql 方言
});

步骤 2: 使用 sequelize.query() 执行查询

sequelize.query() 方法可以用来执行任何 SQL 语句。你可以使用占位符来避免 SQL 注入。

javascript
async function executeQueries() {
  try {
    // 执行第一个查询
    const users = await sequelize.query("SELECT * FROM `users` WHERE `age` > ?", {
      replacements: [18],
      type: Sequelize.QueryTypes.SELECT
    });
    console.log(users);

    // 执行第二个查询
    const activeUsers = await sequelize.query("SELECT * FROM `users` WHERE `status` = ?", {
      replacements: ['active'],
      type: Sequelize.QueryTypes.SELECT
    });
    console.log(activeUsers);

  } catch (error) {
    console.error('Error executing queries:', error);
  }
}

executeQueries();

步骤 3: 确保异步操作

由于 sequelize.query() 返回的是一个 Promise，因此你需要使用 async/await 或 .then/.catch 来处理异步逻辑。在上面的例子中，我使用了 async/await 来确保查询按顺序执行且能够正确处理结果或捕获错误。

实际应用示例

想象一个场景，我们需要从数据库中获取所有成年用户和所有活跃用户的列表。通过上述方式，我们可以轻松地执行这两个查询，并分别处理结果。这种方式在处理报告生成或用户管理系统中非常实用。

通过这种方法，我们能够保持代码的清晰性和效率，同时也利用 Sequelize 提供的安全特性（如防止 SQL 注入）来确保应用程序的安全。