合并插入违反主键

Question

所以我有以下查询，该查询出现 Duplicate PK 错误 我做错了什么？

/////////////// 编辑 PK=ITEM& LOC

MERGE INTO item_loc_traits il 
USING   (
        SELECT  item, loc, reward_eligible_ind 
        FROM    (
                SELECT  dc_vert.item , dc_vert.loc, dc_vert.actie, 
                        dc_vert.reward_eligible_ind, 
                        MAX(dc_vert.actie) over 
                            (PARTITION BY dc_vert.item, dc_vert.loc) actie_max
                FROM    dc_item_loc_vert dc_vert
                ) 
        WHERE   actie = actie_max
        ) dc_vert
ON      il.item = dc_vert.item
        AND il.loc = dc_vert.loc
WHEN MATCHED THEN
       UPDATE   
       SET      il.deposit_code = reward_eligible_ind
        ,       il.last_update_datetime = SYSDATE;
WHEN NOT MATCHED THEN
       INSERT (item, loc, deposit_code, last_update_datetime, 
               last_update_ID, create_datetime)
       VALUES (dc_vert.item, dc_vert.loc, dc_vert.reward_eligible_ind,
               SYSDATE, 'CNVOBJ_SRC', SYSDATE);

Answer 1

对于特定的项目 loc，合并源中可能有多行。您可以使用以下查询对此进行测试：

SELECT  item, loc
FROM    (
        SELECT  item, loc, reward_eligible_ind 
        FROM    (
                SELECT  dc_vert.item , dc_vert.loc, dc_vert.actie, 
                        dc_vert.reward_eligible_ind, 
                        MAX(dc_vert.actie) over 
                            (PARTITION BY dc_vert.item, dc_vert.loc) actie_max
                FROM    dc_item_loc_vert dc_vert
                ) 
        WHERE   actie = actie_max
        ) sub
GROUP BY
        item, loc
HAVING  count(*) > 1

如果返回任何行，则 merge 的 when not match 部分将尝试插入具有相同 item 的多行, loc 组合。这将导致主键违规。

Answer 2

您的查询

SELECT  item, loc, reward_eligible_ind 
        FROM    (
                SELECT  dc_vert.item , dc_vert.loc, dc_vert.actie, 
                        dc_vert.reward_eligible_ind, 
                        MAX(dc_vert.actie) over 
                            (PARTITION BY dc_vert.item, dc_vert.loc) actie_max
                FROM    dc_item_loc_vert dc_vert
                ) 
        WHERE   actie = actie_max

为 dc_vert.item 和 dc_vert.loc 的同一组合返回多个值。
例如，如果有两次 5、10，第一行将被插入，第二行将看不到刚刚插入的行，因为它将与原始数据源进行比较