如何记录Sequelize生成的RAW查询及结果以获取插入ID？

我完全懂你的痛点——用Sequelize执行RAW插入查询时，明明默认应该返回插入ID，但自带的logging函数只能捕获SQL语句本身，根本拿不到这个关键的ID。下面给你几个实用的解决思路，既能记录查询语句，又能获取插入生成的ID：

1. 直接从RAW查询的返回结果中提取ID #

Sequelize执行RAW插入后，返回的结果对象里其实已经包含了插入ID，只是不同数据库的存储位置不一样：

• MySQL/MariaDB：存在result[0].insertId
• PostgreSQL：需要在SQL末尾加RETURNING id，然后从result[0][0].id获取
• SQLite：存在result[0].lastID

你可以保留logging来记录SQL语句，同时在查询完成后手动提取ID并记录。举个MySQL的实际例子：

const sequelize = new Sequelize('your_db', 'your_user', 'your_pwd', {
  dialect: 'mysql',
  // 用logging记录执行的SQL语句
  logging: (sqlStr) => console.log(`执行的RAW SQL: ${sqlStr}`)
});

async function insertUser() {
  try {
    const insertResult = await sequelize.query(
      'INSERT INTO users (username, email) VALUES (:uname, :email)',
      {
        replacements: { uname: 'sockyone', email: 'sockyone@example.com' },
        type: sequelize.QueryTypes.INSERT
      }
    );
    // 提取插入ID
    const insertedId = insertResult[0].insertId;
    console.log(`插入成功，生成的ID: ${insertedId}`);
    // 这里可以把SQL语句和ID整合写入日志文件（比如用winston/pino等日志库）
    return insertedId;
  } catch (err) {
    console.error('插入失败:', err);
  }
}

2. 自定义完整的日志流程（不依赖默认logging） #

如果你想把SQL语句、执行结果、插入ID整合到同一条日志里，可以完全自定义日志逻辑，不用依赖Sequelize的logging选项：

async function insertAndLogFull() {
  const rawSql = 'INSERT INTO users (username, email) VALUES (:uname, :email)';
  const replacements = { uname: 'test_user', email: 'test@example.com' };
  
  // 先格式化SQL，把占位符替换成实际值（方便日志查看）
  const formattedSql = rawSql.replace(/:(\w+)/g, (match, key) => 
    `'${replacements[key]}'`
  );
  console.log(`准备执行RAW SQL: ${formattedSql}`);

  try {
    const result = await sequelize.query(rawSql, {
      replacements,
      type: sequelize.QueryTypes.INSERT
    });
    const insertedId = result[0].insertId; // 这里根据你的数据库调整
    console.log(`SQL执行成功 | 插入ID: ${insertedId} | 执行语句: ${formattedSql}`);
    return insertedId;
  } catch (error) {
    console.error(`SQL执行失败 | 错误信息: ${error.message} | 执行语句: ${formattedSql}`);
    throw error;
  }
}

针对PostgreSQL的特殊处理 #

PostgreSQL默认不会返回插入ID，必须在INSERT语句末尾加上RETURNING id（这里的id是你表的主键字段名），才能拿到返回的ID：

const pgResult = await sequelize.query(
  'INSERT INTO users (username, email) VALUES (:uname, :email) RETURNING id',
  { replacements: { uname: 'pg_user', email: 'pg@example.com' }, type: sequelize.QueryTypes.INSERT }
);
const pgInsertedId = pgResult[0][0].id;

这样你就能同时记录RAW查询的语句和插入生成的ID了，完美解决你的问题！

内容的提问来源于stack exchange，提问作者sockyone