小编use*_*751的帖子

我试图在我试图在Redshift上实现SCD2时插入记录但是出错了.

目标表的DDL是

CREATE TABLE ditemp.ts_scd2_test (
    id INT
    ,md5 CHAR(32)
    ,record_id BIGINT IDENTITY
    ,from_timestamp TIMESTAMP
    ,to_timestamp TIMESTAMP
    ,file_id BIGINT
    ,party_id BIGINT
    )

这是insert语句:

INSERT
INTO ditemp.TS_SCD2_TEST(id, md5, from_timestamp, to_timestamp)

SELECT TS_SCD2_TEST_STAGING.id
    ,TS_SCD2_TEST_STAGING.md5
    ,from_timestamp
    ,to_timestamp
FROM (
    SELECT '20150901 16:34:02' AS from_timestamp
        ,CASE 
            WHEN last_record IS NULL
                THEN '20150901 16:34:02'
            ELSE '39991231 11:11:11.000'
            END AS to_timestamp
        ,CASE 
            WHEN rownum != 1
                AND atom.id IS NOT NULL
                THEN 1
            WHEN atom.id IS NULL
                THEN 1
            ELSE 0
            END AS transfer
        ,stage.*
    FROM …

我有这些数据,我想使用宏更新某个表

DATA WORK.t1;
    LENGTH
        POLICY_RK          8
        POLICY_VERSION     8
        TREATMENT_IND      8 ;
    FORMAT
        POLICY_RK        BEST12.
        POLICY_VERSION   BEST12.
        TREATMENT_IND    BEST12. ;
    INFORMAT
        POLICY_RK        BEST12.
        POLICY_VERSION   BEST12.
        TREATMENT_IND    BEST12. ;
    INFILE DATALINES4
        DLM='7F'x
        MISSOVER
        DSD ;
    INPUT
        POLICY_RK        : BEST32.
        POLICY_VERSION   : BEST32.
        TREATMENT_IND    : BEST32. ;
DATALINES4;
105000002
114000005
123000007
132000001
141000007
1508
;;;;

我正在尝试运行以下代码:

     %macro storno (pol_rk , pol_ver );
       PROC SQL;
            UPDATE t1
            SET POLICY_VERSION=POLICY_VERSION*3.1113
            where POLICY_RK=&pol_rk and policy_Version = &pol_ver;
       QUIT;
 %mend ;





 data _null_;
       set t1 ;

       IF …