如何在每个 Sequelize 连接上执行命令？

Question

我需要aurora_replica_read_consistency在我的 Nodejs 应用程序的每个 Sequelize 连接上设置一个 Mysql 会话变量 ( )。

我可以使用下面的代码设置此会话变量，但我很确定不会为所有 Sequelize 连接设置此变量，我需要一种在每次打开新的数据库连接/将其添加到连接池时设置此变量的方法。

await sequelize.query("set aurora_replica_read_consistency = 'eventual'");

有没有办法在我的 Sequeilize 实例上配置此会话变量，或者扩展/覆盖 Sequelize 以便我可以在每次创建新连接时进行设置？

Answer 1

老问题，但如果出现其他问题，您可以使用sequelize hooks 在每个连接上设置会话变量：

sequelize.addHook('afterConnect', (connection) => {
  // This function will be called after each successful connection
  connection.query('SET aurora_replica_read_consistency = "eventual"', (err) => {
    if (err) {
      // Handle any errors that may occur during the query execution
      console.error('Failed to set session variable:', err);
    } else {
      console.log('Session variable set successfully for the new connection');
    }
  });
});