如何用Node.js追踪Oracle数据库的数据插入事件并触发消息推送？

下面是几种可行的实现方案，按需选择：

1. 触发器 + Oracle高级队列（AQ）实现实时通知 #

这是最接近实时的方案，需要先在Oracle端配置触发器和队列，再用Node.js监听队列：

• Oracle端配置：
  1. 创建队列表和队列，用于存储插入事件的关键数据
  2. 创建触发器，当目标表有新数据插入时，将新数据的核心信息（如ID、插入时间）推送至队列
• Node.js端实现：
  使用官方oracledb驱动连接数据库并监听队列消息，示例代码：

  const oracledb = require('oracledb');
  
  async function listenAQ() {
    let connection;
    try {
      connection = await oracledb.getConnection({
        user: '你的数据库用户',
        password: '你的数据库密码',
        connectString: '你的数据库连接串'
      });
  
      // 启动队列监听
      await connection.callProcedure('DBMS_AQ.START_QUEUE', ['你的队列名称']);
  
      // 持续接收队列消息
      while (true) {
        const msg = await connection.receiveMessage('你的队列名称');
        if (msg) {
          // 处理新插入事件，比如发送通知消息
          console.log('捕获到新插入数据:', msg.payload);
          // 确认消息已处理
          await connection.acknowledgeMessage(msg);
        }
      }
    } catch (err) {
      console.error('队列监听出错:', err);
    } finally {
      if (connection) {
        try {
          await connection.close();
        } catch (err) {
          console.error('关闭连接出错:', err);
        }
      }
    }
  }
  
  listenAQ();
  

• 优缺点：实时性强，但需要具备Oracle队列和触发器的创建权限，配置相对复杂。

2. 轮询查询（简单易实现） #

如果对实时性要求不高（允许几秒延迟），可以定期查询目标表，通过对比上次查询的最大ID或最新时间戳获取新数据：

const oracledb = require('oracledb');

let lastMaxId = 0; // 初始值设为表中当前最大ID，或0
const POLL_INTERVAL = 3000; // 3秒轮询一次

async function pollNewData() {
  let connection;
  try {
    connection = await oracledb.getConnection({
      user: '你的数据库用户',
      password: '你的数据库密码',
      connectString: '你的数据库连接串'
    });

    const result = await connection.execute(
      `SELECT * FROM 你的目标表 WHERE ID > :lastId ORDER BY ID`,
      [lastMaxId],
      { outFormat: oracledb.OUT_FORMAT_OBJECT }
    );

    if (result.rows.length > 0) {
      // 处理新插入的数据
      result.rows.forEach(row => {
        console.log('新插入数据:', row);
        // 此处添加发送消息的逻辑
      });
      // 更新lastMaxId为最新记录的ID
      lastMaxId = result.rows[result.rows.length - 1].ID;
    }
  } catch (err) {
    console.error('轮询出错:', err);
  } finally {
    if (connection) {
      try {
        await connection.close();
      } catch (err) {
        console.error('关闭连接出错:', err);
      }
    }
  }
}

// 启动轮询定时器
setInterval(pollNewData, POLL_INTERVAL);
// 首次立即执行查询
pollNewData();

• 优缺点：实现简单，无需额外数据库配置，但存在延迟，频繁轮询会增加数据库负载。

3. Oracle变更数据捕获（CDC） #

如果数据库已开启CDC功能，可直接捕获表的插入变更：

• 先由DBA为目标表开启CDC，之后通过查询Oracle的CDC视图（如ALL_CHANGE_TABLES、CDC$你的目标表）获取插入事件
• Node.js端定期查询这些视图，筛选出未处理的插入记录进行处理
• 优缺点：适合大规模数据变更场景，对业务代码侵入小，但需要DBA配置CDC，且权限要求较高

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