如何在不使用触发器的情况下用Node.js获取SQL Server实时插入事件？

可以实现，以下是几种无需触发器的可行方案，按实用性和复杂度排序：

1. 使用SQL Server变更跟踪（Change Tracking） #

这是SQL Server内置的轻量级变更追踪机制，不需要触发器，只会记录变更的行ID和变更类型（插入/更新/删除），资源消耗低。

步骤： #

• 启用数据库级变更跟踪：

  ALTER DATABASE YourDatabase
  SET CHANGE_TRACKING = ON
  (CHANGE_RETENTION = 2 DAYS, AUTO_CLEANUP = ON);
  

• 启用目标表的变更跟踪：

  ALTER TABLE YourTargetTable
  ENABLE CHANGE_TRACKING
  WITH (TRACK_COLUMNS_UPDATED = ON);
  

• Node.js端实现：
  用mssql库连接数据库，维护一个上次同步的版本号，每次拉取该版本之后的插入事件：

  const sql = require('mssql');
  const config = {
    user: 'your_user',
    password: 'your_password',
    server: 'your_server',
    database: 'YourDatabase',
    options: {
      encrypt: true // 根据你的SQL Server配置调整
    }
  };
  
  let lastSyncVersion = 0;
  
  async function checkForInserts() {
    try {
      await sql.connect(config);
      // 获取当前变更版本
      const currentVersionResult = await sql.query('SELECT CHANGE_TRACKING_CURRENT_VERSION() AS CurrentVersion');
      const currentVersion = currentVersionResult.recordset[0].CurrentVersion;
  
      if (currentVersion > lastSyncVersion) {
        // 查询上次同步后的插入记录
        const changesResult = await sql.query(`
          SELECT t.*
          FROM CHANGETABLE(CHANGES YourTargetTable, ${lastSyncVersion}) ct
          JOIN YourTargetTable t ON ct.[SYS_CHANGE_ROW_ID] = t.PrimaryKeyColumn
          WHERE ct.SYS_CHANGE_OPERATION = 'I'
        `);
  
        if (changesResult.recordset.length > 0) {
          // 这里处理插入事件，比如发送通知到业务逻辑
          console.log('检测到新插入记录:', changesResult.recordset);
          // 可触发WebSocket、HTTP请求等通知Node.js服务
        }
  
        lastSyncVersion = currentVersion;
      }
    } catch (err) {
      console.error('查询变更失败:', err);
    } finally {
      setTimeout(checkForInserts, 5000); // 每5秒轮询一次，可按需调整间隔
    }
  }
  
  checkForInserts();
  

优缺点： #

• 优点：轻量级、资源消耗低、无需触发器、内置支持
• 缺点：仅记录行ID和变更类型，无法直接获取变更前的旧值

2. 使用SQL Server变更数据捕获（CDC） #

CDC是更强大的变更捕获机制，会完整记录每行数据的变更前后状态，适合需要详细变更历史的场景，同样无需触发器。

步骤： #

• 启用数据库CDC：

  EXEC sys.sp_cdc_enable_db;
  

• 启用目标表的CDC（需表有主键）：

  EXEC sys.sp_cdc_enable_table
    @source_schema = N'dbo',
    @source_name = N'YourTargetTable',
    @role_name = NULL, -- 无需权限角色
    @supports_net_changes = 1;
  

• Node.js端实现：
  查询CDC自动生成的捕获表（格式为cdc.dbo_YourTargetTable_CT），维护上次同步的LSN（日志序列号）：

  const sql = require('mssql');
  const config = { /* 同上面的配置 */ };
  
  let lastLsn = '0x00000000000000000000';
  
  async function checkCDCInserts() {
    try {
      await sql.connect(config);
      // 获取当前最大LSN
      const maxLsnResult = await sql.query('SELECT sys.fn_cdc_get_max_lsn() AS MaxLsn');
      const maxLsn = maxLsnResult.recordset[0].MaxLsn;
  
      if (maxLsn !== lastLsn) {
        // 查询上次LSN后的插入记录
        const cdcResult = await sql.query(`
          SELECT *
          FROM cdc.dbo_YourTargetTable_CT
          WHERE __$operation = 2 -- 2代表插入操作
          AND __$start_lsn > CONVERT(BINARY(10), '${lastLsn}', 1)
        `);
  
        if (cdcResult.recordset.length > 0) {
          console.log('CDC检测到新插入记录:', cdcResult.recordset);
          // 处理通知逻辑
        }
  
        lastLsn = maxLsn;
      }
    } catch (err) {
      console.error('CDC查询失败:', err);
    } finally {
      setTimeout(checkCDCInserts, 3000); // 调整轮询间隔
    }
  }
  
  checkCDCInserts();
  

优缺点： #

• 优点：记录完整变更前后数据、内置支持、适合审计或复杂业务场景
• 缺点：资源消耗比Change Tracking高，需要数据库权限启用CDC

3. 基于时间戳/自增ID的轮询查询（最简单方案） #

如果你的表有自增主键或者更新时间戳字段，可以直接定期查询最新的记录，实现成本最低。

示例代码： #

const sql = require('mssql');
const config = { /* 配置同上 */ };

let lastMaxId = 0; // 假设主键是自增ID，也可用lastUpdatedTime字段

async function pollNewRecords() {
  try {
    await sql.connect(config);
    // 查询自增ID大于lastMaxId的新记录
    const result = await sql.query(`
      SELECT *
      FROM YourTargetTable
      WHERE PrimaryKeyColumn > ${lastMaxId}
      ORDER BY PrimaryKeyColumn ASC
    `);

    if (result.recordset.length > 0) {
      console.log('轮询到新插入记录:', result.recordset);
      // 更新lastMaxId为最新的主键值
      lastMaxId = result.recordset[result.recordset.length - 1].PrimaryKeyColumn;
      // 处理通知逻辑
    }
  } catch (err) {
    console.error('轮询失败:', err);
  } finally {
    setTimeout(pollNewRecords, 2000); // 间隔可按需调整
  }
}

pollNewRecords();

优缺点： #

• 优点：实现极其简单、无需任何SQL Server特殊配置
• 缺点：无法捕获删除/更新事件（仅关心插入则无影响）、高并发下可能有遗漏、对大表性能影响较大

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