1

我想要一个 +1 计数器，用于我的缓慢变化的维度 DIM_Object。每次当 PMEObject 表中的记录发生更改时，我希望 DIM_Object.Versie 增加 1。

关于代码的一切工作正常，这也可以在没有任何错误的情况下运行。但是，在我有“+1 Versie”的地方，我需要它来实际计数并参考过去的行，它显示了需要将 +1 添加到的实际数字。我不知道如何正确引用旧记录。

INSERT  INTO DIM_Object
    SELECT  ObjectId 
            , Name 
            , Eff_Date 
            , End_Date 
            , Current_Flag
            , Versie
    FROM    ( MERGE DIM_Object CM
                USING PMEOBJECT CS
                    ON ( CM.ObjectId = CS.ObjectId )
                        WHEN NOT MATCHED 
                            THEN
    INSERT VALUES
            ( CS.ObjectId 
            , CS.Name 
            , CONVERT(CHAR(10), GETDATE() - 1, 101) 
            , '12/31/2199' 
            , 'y'
            , '1'
            )
                WHEN MATCHED AND CM.Current_Flag = 'y'
                    AND ( CM.Name <> CS.Name )
                        THEN
     UPDATE SET
            CM.Current_Flag = 'n' ,
            CM.End_date = CONVERT(CHAR(10), GETDATE() - 2, 101)
                OUTPUT
                    $Action Action_Out 
                    , CS.ObjectId 
                    , CS.Name 
                    , CONVERT(CHAR(10), GETDATE() - 1, 101) Eff_Date 
                    , '12/31/2199' End_Date 
                    , 'y' Current_Flag 
                    , +1 Versie) AS MERGE_OUT
    WHERE   MERGE_OUT.Action_Out = 'UPDATE';

在我放置“+1 Versie”的地方，我希望它根据之前的 DIM_Object.Versie 数量实际累积。现在它只会保持“1”，因为我猜它只在当前记录中看到 NULL。

你有什么想法？

亲切的问候，

广告

4

2 回答 2

0

在 MERGE 中更新的值作为“已删除”返回，您可以在输出中捕获它们。输出子句 (Transact-SQL)

INSERT  INTO DIM_Object
SELECT  ObjectId 
        , Name 
        , Eff_Date 
        , End_Date 
        , Current_Flag
        , Versie
FROM    ( 
MERGE DIM_Object CM
USING PMEOBJECT CS
ON ( CM.ObjectId = CS.ObjectId )
WHEN NOT MATCHED THEN
    INSERT VALUES
            ( CS.ObjectId 
            , CS.Name 
            , CONVERT(CHAR(10), GETDATE() - 1, 101) 
            , '12/31/2199' 
            , 'y'
            , '1'
            )
WHEN MATCHED AND CM.Current_Flag = 'y' AND ( CM.Name <> CS.Name ) THEN
    UPDATE SET
        CM.Current_Flag = 'n' ,
        CM.End_date = CONVERT(CHAR(10), GETDATE() - 2, 101)
OUTPUT
    $Action Action_Out 
    , CS.ObjectId 
    , CS.Name 
    , CONVERT(CHAR(10), GETDATE() - 1, 101) Eff_Date 
    , '12/31/2199' End_Date 
    , 'y' Current_Flag 
    , deleted.Versie + 1 /* capture the modified row data */
    ) AS MERGE_OUT
WHERE   MERGE_OUT.Action_Out = 'UPDATE';
于 2019-01-07T20:30:17.547 回答
0

这种修改对你有用吗？我在您的 [插入值...] 中添加了一个子查询

Create Table #DIM_Object
(
ObjectId Int,
[Name] NVarChar(25),
End_Date Date,
Eff_Date Date,
Current_Flag Char(1),
Versie Int
)
Insert Into #DIM_Object Values
(1,'Me','2019-01-06','2020-12-31','y',1)


Create Table #PMEObject
(
ObjectId Int,
[Name] NVarChar(25),
End_Date Date,
Eff_Date Date,
Current_Flag Char(1),
Versie Int
)
Insert Into #PMEObject Values
(2,'You','2019-01-30','2019-01-07','n',1),
(1,'Him','2019-01-06','2020-12-31','n',1)

INSERT  INTO #DIM_Object
    SELECT  ObjectId 
            , Name 
            , Eff_Date 
            , End_Date 
            , Current_Flag
            , Versie
    FROM    ( 

    MERGE #DIM_Object CM
          USING #PMEOBJECT CS
          ON ( CM.ObjectId = CS.ObjectId )
          WHEN NOT MATCHED 
         THEN
            INSERT VALUES
               ( CS.ObjectId 
               , CS.Name 
               , CONVERT(CHAR(10), GETDATE() - 1, 101) 
               , '12/31/2199' 
               , 'y'
               , (Select Versie From #PMEObject p Where p.ObjectId = CS.ObjectId ) + 1
               )
          WHEN MATCHED AND CM.Current_Flag = 'y'
                       AND ( CM.Name <> CS.Name )
                  THEN
                     UPDATE SET
                       CM.Current_Flag = 'n' ,
                       CM.End_date = CONVERT(CHAR(10), GETDATE() - 2, 101)
                       OUTPUT
                          $Action Action_Out 
                          , CS.ObjectId 
                          , CS.Name 
                          , CONVERT(CHAR(10), GETDATE() - 1, 101) Eff_Date 
                          , '12/31/2199' End_Date 
                          , 'y' Current_Flag 
                          , +1 Versie   
       ) AS MERGE_OUT
      WHERE   MERGE_OUT.Action_Out = 'UPDATE';

结果：

ObjectId    Name    End_Date    Eff_Date    Current_Flag    Versie
1           Me      2019-01-05  2020-12-31      n           1
2           You     2019-01-06  2199-12-31      y           2
1           Him     2019-01-06  2199-12-31      y           1
于 2019-01-07T20:15:47.980 回答