如果插入新的相同行，则设置end_date

Question

我无法找到处理历史数据的最有效的一组语句。可以说我有两张桌子。一个分段和一个存档表。每次将数据导入登台表我想用下面的逻辑将它插入到归档表中。低于该

if circuitId = circuitId and checksum = checksum(*) 
    then do nothing 

if circuitId = circuiId and checksum <> checksum(*) 
    then insert new row and set end_date of old row. 

if rows exists in archive but not in staging 
    then change delete_flag to 1 

到目前为止，我已经创建处理delete_flag，如果checksum = checksum(*)，但我似乎无法弄清楚，如果checksum <> checksum(*)如何整合和对旧行设置END_DATE。

UPDATE ARCHIVE.F1_CIRCUITS n 
     SET 
      n.DELETE_FLAG = 1 
     FROM 
      ARCHIVE.F1_CIRCUITS n 
       LEFT JOIN EXTRACT.F1_CIRCUITS o 
       ON o."circuitId" = n.CIRCUITID 
       WHERE o."circuitId" IS NULL; 

INSERT INTO ARCHIVE.F1_CIRCUITS 
      SELECT ("circuitId","circuitRef","name","location","country","lat","lng","alt","url", CURRENT_TIMESTAMP, NULL, HASH_MD5("circuitId","circuitRef","name","location","country","lat","lng","alt","url"), 'C', 0) FROM EXTRACT.F1_CIRCUITS o 
      WHERE NOT EXISTS (SELECT 1 
           FROM ARCHIVE.F1_CIRCUITS n 
           WHERE o."circuitId" = n.CIRCUITID AND 
           HASH_MD5(o."circuitId",o."circuitRef",o."name",o."location",o."country",o."lat",o."lng",o."alt",o."url") = n.cheetax_checksum 
          ); 

舞台架构表

CREATE TABLE EXTRACT.F1_CIRCUITS (
    "circuitId" DECIMAL(11,0), 
    "circuitRef" VARCHAR(255) UTF8, 
    "name"  VARCHAR(255) UTF8, 
    "location" VARCHAR(255) UTF8, 
    "country" VARCHAR(255) UTF8, 
    "lat"  DOUBLE PRECISION, 
    "lng"  DOUBLE PRECISION, 
    "alt"  DECIMAL(11,0), 
    "url"  VARCHAR(255) UTF8 
); 

归档架构表

CREATE TABLE F1_CIRCUITS (
    ID      DECIMAL(18,0) IDENTITY, 
    CIRCUITID    DECIMAL(11,0), 
    CIRCUITREF    VARCHAR(255) UTF8, 
    NAME     VARCHAR(255) UTF8, 
    LOCATION    VARCHAR(255) UTF8, 
    COUNTRY     VARCHAR(255) UTF8, 
    LAT      DOUBLE PRECISION, 
    LNG      DOUBLE PRECISION, 
    ALT      DECIMAL(11,0), 
    URL      VARCHAR(255) UTF8, 
    START_TIMESTAMP TIMESTAMP, 
    END_TIMESTAMP TIMESTAMP, 
    CHECKSUM  CHAR(32) UTF8, 
    STATUS   CHAR(1) UTF8, 
    DELETE_FLAG  DECIMAL(1,0) 
); 

Answer 1

对于你的情况，我建议使用触发器，并使汽车的操作。 以下触发条件会随时插入一个新行到您的EXTRACT表（条件1/2）或从中删除（条件3），并且将检查：

当插入到EXTRACT：

if circuitId = circuitId and checksum = checksum(*) 
    then do nothing 

if circuitId = circuiId and checksum <> checksum(*) 
    then insert new row and set end_date of old row. 

当从EXTRACT正在删除：

if rows exists in archive but not in staging 
    then change delete_flag to 1 

触发您的条件：

CREATE OR REPLACE TRIGGER archiver 
     AFTER INSERT OR DELETE 
      ON EXTRACT.F1_Circuits 
     REFERENCES OLD AS OLD NEW AS NEW 
      FOR EACH ROW 


    DECLARE 

      v_extr_new_row VARCHAR2 (500); --- for storing new inserting row data 
      v_extr_row_checksum RAW(500); --- for storing new row as RAW 
      v_encrypted_raw RAW(2048);  --- encrypted to md5 data 
      v_arch_cir_id NUMBER (11) := 0; --- circuitId from ARCHIVE table 
      v_arch_checksum VARCHAR2 (32) := '0'; --- checksum from ARCHIVE table 
      v_arch_last_chsum NUMBER (3); --- for finding the latest data by checksum in ARCH table 
      v_arch_start_date TIMESTAMP; --- for finding the latest data by start_date in ARCH table 

     BEGIN 

     IF INSERTING THEN 
       --- taking the inserting data into the variable for further converting to md5 
       v_extr_new_row := :NEW."circuitId" || ',' || :NEW."circuitRef" || ',' || :NEW."name" || ',' || 
           :NEW."location" || ',' || :NEW."country" || ',' || :NEW."lat" || ',' || 
           :NEW."lng" || ',' || :NEW."alt" || ',' || :NEW."url"; 

       --- converting the inserting data to hash_md5, checksum 
       v_extr_row_checksum := utl_raw.cast_to_raw(v_extr_new_row); 
       v_encrypted_raw := dbms_crypto.hash(v_extr_row_checksum, 2); 

       --- taking the latest row from the ARCH table for changing the Updating the END_DATE; 
       SELECT START_TIMESTAMP, r_last_chsum, CHECKSUM, circuitId 
         INTO v_arch_start_date, v_arch_last_chsum, v_arch_checksum, v_arch_cir_id 
         FROM 
          (SELECT START_TIMESTAMP, ROW_NUMBER() 
           OVER (PARTITION BY arch_in.circuitId ORDER BY arch_in.START_TIMESTAMP DESC) r_last_chsum, 
           CIRCUITID, CHECKSUM 
           FROM ARCHIVE.F1_CIRCUITS arch_in 
           WHERE arch_in.circuitId = :NEW."circuitId") 
          WHERE r_last_chsum = 1; 


      ---- checking whether the data already exist in the ARCH table 
      IF (v_arch_cir_id = :NEW."circuitId" AND v_arch_checksum <> v_encrypted_raw) 
       THEN 

        ---- Update end_date for old row 
       UPDATE ARCHIVE.F1_CIRCUITS arch 
         SET arch.END_TIMESTAMP = CURRENT_TIMESTAMP 
          WHERE arch.circuitId = :NEW."circuitId" 
            AND arch.CHECKSUM = v_arch_checksum 
            AND arch.START_TIMESTAMP = v_arch_start_date; 

       --- inserting the new data into ARCH table 
       INSERT INTO ARCHIVE.F1_CIRCUITS 
         (CIRCUITID, CIRCUITREF, NAME, LOCATION, COUNTRY, LAT, LNG, ALT, URL, START_TIMESTAMP, END_TIMESTAMP, CHECKSUM, 
          STATUS, DELETE_FLAG) 
         VALUES (:NEW."circuitId", :NEW."circuitRef", :NEW."name", :NEW."location", :NEW."country", 
           :NEW."lat", :NEW."lng", :NEW."alt", :NEW."url", CURRENT_TIMESTAMP, NULL, v_encrypted_raw, 'C', to_number (0)); 

       ---- else if they are EQUAL then DO NOTHING, but if you need you can do;) 
      ELSIF (v_arch_cir_id = :NEW."circuitId" AND v_arch_checksum = v_encrypted_raw) 
        THEN 
        dbms_output.put_line ('Do Nothing!'); 
    /*     INSERT INTO ikrom.f1_circuits_arch ---- ARCHIVE.F1_CIRCUITS 
         (CIRCUITID, CIRCUITREF, NAME, LOCATION, COUNTRY, LAT, LNG, ALT, URL, START_TIMESTAMP, END_TIMESTAMP, CHECKSUM, 
          STATUS, DELETE_FLAG) 
         VALUES (:NEW."circuitId", :NEW."circuitRef", :NEW."name", :NEW."location", :NEW."country", 
           :NEW."lat", :NEW."lng", :NEW."alt", :NEW."url", CURRENT_TIMESTAMP, NULL, v_encrypted_raw, 'C', to_number (0));*/ 
      END IF; 

     END IF; 

     IF DELETING THEN 
        --- taking the inserting data into the variable for further converting to md5 
       v_extr_new_row := :OLD."circuitId" || ',' || :OLD."circuitRef" || ',' || :OLD."name" || ',' || 
           :OLD."location" || ',' || :OLD."country" || ',' || :OLD."lat" || ',' || 
           :OLD."lng" || ',' || :OLD."alt" || ',' || :OLD."url"; 

       --- converting the inserting data to hash_md5, checksum 
       v_extr_row_checksum := utl_raw.cast_to_raw(v_extr_new_row); 
       v_encrypted_raw := dbms_crypto.hash(v_extr_row_checksum, 2); 

       --- taking the latest row from the ARCH table for changing the Updating the END_DATE; 
       SELECT START_TIMESTAMP, r_last_chsum, CHECKSUM, circuitId 
         INTO v_arch_start_date, v_arch_last_chsum, v_arch_checksum, v_arch_cir_id 
         FROM 
          (SELECT START_TIMESTAMP, ROW_NUMBER() 
           OVER (PARTITION BY arch_in.circuitId ORDER BY arch_in.START_TIMESTAMP DESC) r_last_chsum, 
           CIRCUITID, CHECKSUM 
           FROM ARCHIVE.F1_CIRCUITS arch_in 
           WHERE arch_in.circuitId = :OLD."circuitId") 
          WHERE r_last_chsum = 1; 


      ---- checking whether the data already exist in the ARCH table 
      IF (v_arch_cir_id = :OLD."circuitId") 
       THEN 

        ---- Update end_date for old row 
       UPDATE ARCHIVE.F1_CIRCUITS arch 
         SET arch.DELETE_FLAG = 1 
          WHERE arch.circuitId = :OLD."circuitId" 
            AND arch.DELETE_FLAG = 0; 
       END IF;     
      END IF; 

      EXCEPTION 
      WHEN NO_DATA_FOUND 
       THEN 
       ---- if no data found in ARCH table by SELECTING in INSERTING process then just INSERT the new row 
       INSERT INTO ARCHIVE.F1_CIRCUITS 
          (CIRCUITID, CIRCUITREF, NAME, LOCATION, COUNTRY, LAT, LNG, ALT, URL, START_TIMESTAMP, END_TIMESTAMP, CHECKSUM, 
           STATUS, DELETE_FLAG) 
          VALUES (:NEW."circuitId", :NEW."circuitRef", :NEW."name", :NEW."location", :NEW."country", 
            :NEW."lat", :NEW."lng", :NEW."alt", :NEW."url", CURRENT_TIMESTAMP, NULL, v_encrypted_raw, 'C', to_number (0)); 

    END; 

重要说明：从Extract表中删除时，ARCHIVE中具有相同circuitId的所有行都将被更新; 也为dbms_crypto授予触发器运行用户的执行权限;

Answer 2

好像每个circuitid，你想END_DATE/end_timestamp对于最近插入的行始终为空。为什么不直接这样做，并为所有不是最近插入的行设置结束时间戳？

update ARCHIVE.F1_CIRCUITS set end_timestamp = current_timestamp 
    where end_timestamp is null 
    and exists (select 1 from ARCHIVE.F1_CIRCUITS n 
     where n.circuitid = f1_circuits.circuitid 
     and n.start_timestamp > f1_circuits.start_timestamp); 

在不同的音符，当我听到“每次发生事情到这个表的时候，我想要做的事对另一个表”，我首先想到的是使用触发器。如果您最终在触发器（或另一个PL/SQL块）中执行此操作，那么如果您将校验和分配给像这样的变量，那么这也很容易：new_checksum;你可以这样做：

update ARCHIVE.F1_CIRCUITS set end_timestamp = current_timestamp 
    where end_timestamp is null and circuitid = :new.circuitid and checksum <> :new_checksum;