ORACLE 如果任何字段更改，则添加新记录答案

【问题标题】：ORACLE Add new record if any field changesORACLE 如果任何字段更改，则添加新记录
【发布时间】：2018-10-10 18:06:48
【问题描述】：

我正在尝试编写一个 Oracle 程序。我有一张桌子，目前我正在使用合并语句。当一条记录发生变化时，它会更新它，如果它是新的，它会添加它。

但是，我们希望跟踪更改的记录。所以我添加了三个字段：startdate、enddate、currentflag。如果有任何更改，我不想更新记录，我想添加一条新记录。但我确实想添加一个结束日期并更改旧记录上的标志。

所以，如果我有这样一张桌子：

TableID
Field1
Field2
Field3
StartDate
EndDate
CurrentFlag

它有这样的数据

TableID   Field1   Field2   Field3  StartDate   EndDate   CurrentFlag
001       DataA    Cow      Brown   3-Oct-18              Y
001       DataA    Cow      White   1-Sep-18    3-Oct-18  N
002       DataB    Horse    Dapple  3-Oct-18              Y

我想合并一些数据

TableID   Field1   Field2   Field3
001       NewData  Cow      Black 
002       DataB    Horse    Dapple
005       Data3    Cat      Black

让决赛桌看起来像这样

TableID   Field1   Field2   Field3  StartDate   EndDate   CurrentFlag
001       DataA    Cow      Brown   3-Oct-18    10-Oct-18 N
001       DataA    Cow      White   1-Sep-18    3-Oct-18  N
001       NewData  Cow      Black   10-Oct-18             Y
002       DataB    Horse    Dapple  3-Oct-18              Y
005       Data3    Cat      Black   10-Oct-18             Y

我的伪代码是

for each record in source file
   find current record in dest table (on ID and flag = Y)
   if any other fields do not match (Field1, Field2, Field3)
    then update current record, set enddate, current flag to n
        and add new record with startdate = sysdate, current flag is Y
   if no match found, then add new record with startdate = sysdate, current flag is Y

我不确定如何将该伪代码转换为 Oracle SQL 代码。我可以使用相同的 MERGE 语句，但在 WHEN MATCHED 中添加检查以查看其他字段是否不同？

我将为几个表执行此操作，其中一些表有很多记录和很多字段。所以我需要找出一些可行的方法，而且不像糖蜜那么慢。

更新我按照建议创建了一个程序，并进行了一些修改，所以它可以工作：

CREATE OR REPLACE PROCEDURE TESTPROC AS

BEGIN
DECLARE 
l_count NUMBER;
CURSOR TRN is
    SELECT * from sourceTable;

BEGIN 
    FOR each_record IN TRN
    LOOP
        -- if a record found but fields differ ...
        l_count := 0;
        SELECT COUNT(*) INTO l_count 
        FROM destTable DIM
        WHERE each_record.TableID = DIM.TableID
          and (each_record.Field1 <> DIM.Field1
          or each_record.Field2 <> DIM.Field2
          or each_record.Field13 <> DIM.Field3)
          AND DIM.CurrentFlag = 'Y';

        -- ... then update existing current record, and add with new data
        IF l_count > 0 THEN
            UPDATE destTable DIM
              SET EndDate = sysdate
                 ,CurrentFlag = 'N'
               WHERE each_record.TableID = DIM.TableID;

            INSERT INTO destTable 
                     (TableID
                    , Field1
                    , Field2
                    , Field3
                    , StartDate
                    , CurrentFlag)
            VALUES (each_record.TableID
                    , each_record.Field1
                    , each_record.Field2
                    , each_record.Field3
                    , sysdate
                    , 'Y');
          COMMIT;
        END IF;

        -- if no record found with this key...
        l_count := 0;
        SELECT COUNT(*) INTO l_count 
        FROM destTable DIM
        WHERE each_record.TableID = DIM.TableID;

        -- then add a new record
        IF l_count = 0 THEN
            INSERT INTO destTable 
                     (TableID
                    , Field1
                    , Field2
                    , Field3
                    , StartDate
                    , CurrentFlag)
            VALUES (each_record.TableID
                    , each_record.Field1
                    , each_record.Field2
                    , each_record.Field3
                    , sysdate
                    , 'Y');
        END IF;
    END LOOP;    
    COMMIT;
END;
END TESTPROC

在我的小桌子上，效果很好。现在我正在我的一个较大的表（800k 记录，但绝不是最大的表）上尝试它，并且在它运行时我正在更新这个问题。已经快一个小时了，显然这是不可接受的。一旦我的程序返回，我将在 TableID、TableID 和 CurrentFlag 上添加索引。如果指数没有帮助，对于糖蜜方面的缓慢方面有什么建议吗？

【问题讨论】：

标签： sql oracle oracle11g

【解决方案1】：

您可以为此编写一个简单的过程：

DECLARE

l_count NUMBER;
CURSOR C1 is
-- YOUR DATA FROM SOURCE 

BEGIN

 for each_record in c1
 l_count := 0;
   SELECT COUNT(*) into l_count from destination_table where field1= 
  eachrecord.field1 and .... and flag = 'Y'; -- find current record in dest table (on ID and flag = Y)

--  if any other fields do not match (Field1, Field2, Field3)
IF L_COUNT > 0 THEN 
   update current record, set enddate, current flag to n
END IF;
    INSERT new record with startdate = sysdate, current flag is Y
END;

OP 修改：这导致了正确的方向。下面的代码可以解决问题，前提是 TableID 和 (TableID, CurrentFlag) 上还有一个索引。

CREATE OR REPLACE PROCEDURE TESTPROC AS

BEGIN
DECLARE 
l_count NUMBER;
CURSOR TRN is
    SELECT * from sourceTable;

BEGIN 
    FOR each_record IN TRN
    LOOP
        -- if a record found but fields differ ...
        l_count := 0;
        SELECT COUNT(*) INTO l_count 
        FROM destTable DIM
        WHERE each_record.TableID = DIM.TableID
          and (each_record.Field1 <> DIM.Field1
          or each_record.Field2 <> DIM.Field2
          or each_record.Field13 <> DIM.Field3)
          AND DIM.CurrentFlag = 'Y';

        -- ... then update existing current record, and add with new data
        IF l_count > 0 THEN
            UPDATE destTable DIM
              SET EndDate = sysdate
                 ,CurrentFlag = 'N'
               WHERE each_record.TableID = DIM.TableID;

            INSERT INTO destTable 
                     (TableID
                    , Field1
                    , Field2
                    , Field3
                    , StartDate
                    , CurrentFlag)
            VALUES (each_record.TableID
                    , each_record.Field1
                    , each_record.Field2
                    , each_record.Field3
                    , sysdate
                    , 'Y');
          COMMIT;
        END IF;

        -- if no record found with this key...
        l_count := 0;
        SELECT COUNT(*) INTO l_count 
        FROM destTable DIM
        WHERE each_record.TableID = DIM.TableID;

        -- then add a new record
        IF l_count = 0 THEN
            INSERT INTO destTable 
                     (TableID
                    , Field1
                    , Field2
                    , Field3
                    , StartDate
                    , CurrentFlag)
            VALUES (each_record.TableID
                    , each_record.Field1
                    , each_record.Field2
                    , each_record.Field3
                    , sysdate
                    , 'Y');
        END IF;
    END LOOP;    
    COMMIT;
END;
END TESTPROC

【讨论】：

您能解释一下每个步骤中发生了什么吗？我正在浏览每个源记录（光标）。如果找到完全匹配，它将添加到计数中……但在这种情况下，我不应该修改我当前的标志：在这种情况下，我什么都不做。我想也许这给了我一些线索，但可能不是正确的逻辑。也许吧。
例如，是什么阻止它插入源表中的每条记录？如果存在完全匹配，则不需要发生。
我认为触发器可能是更好的选择并努力解决这个问题，但我会在早上回到这个。
如果不断更新同一条记录，触发器可能会变成变异触发器。
此代码将检查您的记录是否完全匹配，它将使用 flag = N 更新现有记录并始终插入新记录。我相信这是您的要求。

【解决方案2】：

也许您可以使用触发器来执行此操作。

CREATE OR REPLACE TRIGGER insTableID
BEFORE INSERT OR UPDATE
ON tableID
FOR EACH ROW
DECLARE
    v_exists NUMBER := -1;
BEGIN
    SELECT COUNT(1) INTO v_exists FROM tableID t where t.Field1 = :new.Field1 and ... ;
    IF INSERTING THEN
        IF v_exist > 0 THEN
            null;--your DML update statement
        ELSE
            null;--your DML insert statement
        END;
    END IF;
    IF UPDATING THEN
        null;--your DML statement for update the old registry and a DML for insert the new registry.
    END IF;
END;

通过这种方式，您可以更新与旧值相关的注册表并使用新值插入新行。

我希望这可以帮助您解决问题。

【讨论】：

IF INSERTING 和 IF UPDATING 是否知道记录是否已经完全匹配？我不想做的是添加另一个精确的记录副本，并具有新的开始日期。我会玩这个。
您需要在插入或更新记录之前检查记录是否存在，我已经编辑了代码以检查记录是否已经存在。在 IF INSERTING 和 IF UPDATING 中，您将根据需要实现插入或更新的逻辑。
我创建了一个可以编译的触发器。我不能使用我现有的合并语句，因为我收到一个错误：表正在变异，触发器/函数可能看不到它。同上直接插入语句从我的源表中选择所有。
我有 IF INSERTING 和 v_exists > 1 然后 NULL 否则插入语句。并且 IF UPDATING 和 v_exists > 1 然后是更新和插入语句。但是，仅仅因为触发器编译，这并不意味着我的语法是正确的。您是否有机会根据我的假示例表添加有关 DML 语句的更多详细信息？
对于变异表使用复合触发器。您将有一个 BEFORE STATEMENT 部分和一个 BEFORE EACH ROW。在 BEFORE STATEMENT 中，您将使用 select 语句，在 EACH ROW 中，您将使用 merge 语句。