如何使用TypeORM监听外部应用引发的数据库变更？

当然可以实现，不过TypeORM本身的实体生命周期钩子（比如@AfterInsert这类）只对自身应用发起的数据库操作生效，外部应用直接写入的数据不会触发这些钩子。你需要从数据库层面或者借助中间件来实现监听，下面是几个可行的方案：

方案1：数据库触发器 + 中间表/消息队列 #

• 在Songs表上创建INSERT触发器，每当外部应用插入新歌曲时，自动把变更数据写入一个专门的中间表，或者直接推送到消息队列（比如Redis、RabbitMQ）
• TypeORM应用通过轮询中间表，或者订阅消息队列来获取新增数据，再做后续处理
• 以MySQL触发器为例的示例代码：

DELIMITER //
CREATE TRIGGER after_song_insert
AFTER INSERT ON Songs
FOR EACH ROW
BEGIN
  -- 把新增歌曲的关键信息写入变更记录表
  INSERT INTO SongChangeLogs (songId, title, artist, changeType, createdAt)
  VALUES (NEW.id, NEW.title, NEW.artist, 'INSERT', NOW());
END //
DELIMITER ;

• TypeORM侧可以定时用Repository查询SongChangeLogs表，处理未消费的变更记录

方案2：数据库CDC（变更数据捕获） #

• 利用数据库自带的CDC能力，比如MySQL的binlog、PostgreSQL的逻辑复制、SQL Server的CDC功能
• 可以用Debezium这类工具捕获数据库日志里的变更事件，TypeORM应用直接订阅这些事件即可获取外部应用的写入操作
• 这种方式不需要写触发器，直接从数据库底层日志获取数据，可靠性和实时性都更高

方案3：定时轮询Songs表 #

• 最简单的实现方式：TypeORM应用定时查询Songs表，对比上次查询的最大ID或最新创建时间，捞取新增的记录
• TypeORM侧示例代码：

import { getRepository } from "typeorm";
import { Songs } from "./entities/Songs";

let lastMaxId = 0;

async function fetchNewSongs() {
  const songRepo = getRepository(Songs);
  const newSongs = await songRepo.find({
    where: { id: { gt: lastMaxId } },
    order: { id: "ASC" }
  });

  if (newSongs.length) {
    // 在这里处理新增的歌曲数据
    console.log("检测到新增歌曲:", newSongs);
    lastMaxId = newSongs[newSongs.length - 1].id;
  }
}

// 每10秒轮询一次，可根据需求调整间隔
setInterval(fetchNewSongs, 10000);

• 缺点是有延迟，频繁查询可能影响数据库性能，适合变更频率不高的场景

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