Node.js跨Oracle数据库迁移：MERGE INTO与DUAL用法问询

• 区分数据库连接：确保配置源库和目标库两个独立的数据库连接，分别用于数据查询与写入。
• 从源库提取数据：执行查询语句获取需要同步的目标数据行。
• 构造合规MERGE语句：针对每条数据，以DUAL作为临时数据源，编写符合Oracle语法的MERGE INTO语句。
• 目标库执行MERGE：使用目标库连接执行构造好的MERGE操作，完成数据同步。

console.log("starting test.js here");
import { sourceDbConfig, targetDbConfig } from "../lib/database/dbconfig"; // 拆分源库与目标库配置
import { db_Query } from "../query"; // 假设db_Query支持传入指定连接配置

export const testRoute = {
    method: 'GET',
    path: '/api/test',
    handler: async (req, h) => {
        try {
            // 1. 从源数据库查询待同步数据
            const sql1 = `SELECT value1, value2, value3 FROM table1 WHERE value1 = 'a' AND value2 = 'B'`;
            const { results: sourceResults } = await db_Query(sql1, {}, sourceDbConfig);
            const dataRows = sourceResults.rows;

            if (!dataRows.length) {
                console.log("无待同步数据");
                return [];
            }

            // 2. 遍历数据，在目标库执行MERGE INTO
            const syncRecords = [];
            for (const row of dataRows) {
                const { value1, value2, value3 } = row;
                // 构造正确的MERGE语句，用DUAL传入单条数据
                const sql2 = `
                    MERGE INTO table2 tgt
                    USING (
                        SELECT '${value1}' AS value1, 
                               '${value2}' AS value2, 
                               '${value3}' AS value3
                        FROM DUAL
                    ) src
                    ON (src.value1 = tgt.value1)
                    WHEN MATCHED THEN
                        UPDATE SET tgt.value2 = src.value2, tgt.value3 = src.value3
                    WHEN NOT MATCHED THEN
                        INSERT (value1, value2, value3)
                        VALUES (src.value1, src.value2, src.value3)
                `;
                const syncResult = await db_Query(sql2, {}, targetDbConfig);
                syncRecords.push(syncResult);
            }

            console.log("数据同步完成");
            return dataRows;
        } catch (error) {
            console.error("同步失败:", error);
            throw error;
        }
    }
};

• SQL注入风险：上述字符串拼接方式存在注入风险，建议改用绑定变量优化：

  const sql2 = `
      MERGE INTO table2 tgt
      USING (
          SELECT :value1 AS value1, 
                 :value2 AS value2, 
                 :value3 AS value3
          FROM DUAL
      ) src
      ON (src.value1 = tgt.value1)
      WHEN MATCHED THEN
          UPDATE SET tgt.value2 = src.value2, tgt.value3 = src.value3
      WHEN NOT MATCHED THEN
          INSERT (value1, value2, value3)
          VALUES (src.value1, src.value2, src.value3)
  `;
  const syncResult = await db_Query(sql2, { value1, value2, value3 }, targetDbConfig);
  

• 批量处理优化：若数据量较大，建议通过UNION ALL拼接多个DUAL数据源，减少数据库调用次数，提升同步效率。
• 事务一致性：如需保证数据同步的原子性，可在目标库的MERGE操作外层添加事务控制，确保所有数据要么同步成功，要么全部回滚。

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