如何使用MERGE语句按源SELECT指定顺序插入数据行？

刚好碰到过类似的问题，MERGE操作本身确实不会保证按照源查询的排序顺序来插入新行——毕竟数据库优化器会根据执行计划调整数据处理顺序，哪怕你在源SELECT里加了ORDER BY，默认也不会被MERGE遵循。不过我们可以通过几种方式来实现你要的效果，分场景来看：

一、如果需要物理存储顺序和源排序一致 #

这种场景比较严格，得依赖你使用的数据库特性：

1. Oracle（12c及以上） #

可以用查询提示（hint）强制优化器按源查询的顺序处理数据，同时配合串行执行来保证插入顺序：

MERGE /*+ ORDERED */ INTO HCI_STD_STAGING.STAGE.DEF_DATA TRG
USING (
    SELECT 
        TMP.DEF_DATA_SK, 
        TMP.VAL, 
        TMP.CD, 
        TMP.DESCR, 
        TMP.DEF_TP_SK TYPE_SK,
        -- 生成排序序号，方便后续验证或辅助排序
        ROW_NUMBER() OVER(ORDER BY TMP.DEF_DATA_SK) AS SORT_ORDER
    FROM 你的源表 TMP
    -- 这里保留你原有的关联逻辑（比如PRN、TYP表的关联）
    ORDER BY TMP.DEF_DATA_SK
) SRC
ON (TRG.DEF_DATA_SK = SRC.DEF_DATA_SK)
WHEN NOT MATCHED THEN
    INSERT (DEF_DATA_SK, VAL, CD, DESCR, TYPE_SK, SORT_ORDER)
    VALUES (SRC.DEF_DATA_SK, SRC.VAL, SRC.CD, SRC.DESCR, SRC.TYPE_SK, SRC.SORT_ORDER);

/*+ ORDERED */提示会强制优化器按照USING子查询的定义顺序处理数据，加上源查询的ORDER BY，基本能保证物理插入顺序和源一致。

2. SQL Server #

SQL Server官方虽然明确说MERGE不保证顺序，但如果必须实现，可以通过限制并行度（强制串行执行）+ 源查询排序的方式尝试：

MERGE INTO HCI_STD_STAGING.STAGE.DEF_DATA TRG
USING (
    SELECT 
        TMP.DEF_DATA_SK, 
        TMP.VAL, 
        TMP.CD, 
        TMP.DESCR, 
        TMP.DEF_TP_SK TYPE_SK,
        ROW_NUMBER() OVER(ORDER BY TMP.DEF_DATA_SK) AS SORT_ORDER
    FROM 你的源表 TMP
    -- 保留原有关联逻辑
    ORDER BY TMP.DEF_DATA_SK
) SRC
ON (TRG.DEF_DATA_SK = SRC.DEF_DATA_SK)
WHEN NOT MATCHED THEN
    INSERT (DEF_DATA_SK, VAL, CD, DESCR, TYPE_SK, SORT_ORDER)
    VALUES (SRC.DEF_DATA_SK, SRC.VAL, SRC.CD, SRC.DESCR, SRC.TYPE_SK, SRC.SORT_ORDER)
OPTION (MAXDOP 1); -- 强制串行执行，避免并行执行打乱顺序

注意：这种方式不是官方百分百保证的，但实际场景中大部分情况下能生效。

二、如果只需要逻辑顺序（查询时能按源排序返回） #

如果不需要纠结物理存储顺序，只是后续查询时能得到和源SELECT一致的顺序，更稳妥的方式是给目标表加个排序字段，比如SORT_ORDER，在源查询中生成这个字段的值，插入/更新到目标表：

-- 先给目标表新增排序字段（如果还没有的话）
ALTER TABLE HCI_STD_STAGING.STAGE.DEF_DATA ADD SORT_ORDER INT;

-- 执行MERGE
MERGE INTO HCI_STD_STAGING.STAGE.DEF_DATA TRG
USING (
    SELECT 
        TMP.DEF_DATA_SK, 
        TMP.VAL, 
        TMP.CD, 
        TMP.DESCR, 
        TMP.DEF_TP_SK TYPE_SK,
        -- 按DEF_DATA_SK生成连续的排序序号
        ROW_NUMBER() OVER(ORDER BY TMP.DEF_DATA_SK) AS SORT_ORDER
    FROM 你的源表 TMP
    -- 保留原有关联逻辑
    ORDER BY TMP.DEF_DATA_SK
) SRC
ON (TRG.DEF_DATA_SK = SRC.DEF_DATA_SK)
WHEN NOT MATCHED THEN
    INSERT (DEF_DATA_SK, VAL, CD, DESCR, TYPE_SK, SORT_ORDER)
    VALUES (SRC.DEF_DATA_SK, SRC.VAL, SRC.CD, SRC.DESCR, SRC.TYPE_SK, SRC.SORT_ORDER)
WHEN MATCHED THEN
    UPDATE SET 
        TRG.VAL = SRC.VAL,
        TRG.CD = SRC.CD,
        TRG.DESCR = SRC.DESCR,
        TRG.TYPE_SK = SRC.TYPE_SK,
        TRG.SORT_ORDER = SRC.SORT_ORDER; -- 更新时同步排序序号

-- 后续查询时，按SORT_ORDER排序就能得到源查询的顺序
SELECT * FROM HCI_STD_STAGING.STAGE.DEF_DATA ORDER BY SORT_ORDER;

几个关键提醒 #

• 不管用哪种方式，源查询一定要明确加ORDER BY TMP.DEF_DATA_SK，这是所有排序逻辑的基础。
• 物理存储顺序的控制非常依赖数据库特性，比如MySQL的处理方式就和Oracle/SQL Server不同，建议结合你实际使用的数据库调整。
• 如果目标表有主键或唯一索引，数据库可能会根据索引结构调整存储顺序，这时候物理顺序还是可能被打乱，所以用逻辑排序字段的方式更通用可靠。

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