8

这个过程有几个步骤，反映在数据库的各种表中：

生产->UPDATE使用类似的东西到库存表

UPDATE STOR SET
    STOR.BLOC1 = T.BLOC1,
    STOR.BLOC2 = T.BLOC2,
    STOR.BLOC3 = T.BLOC3,
    STOR.PRODUCTION = T.PROD,
    STOR.DELTA = T.DELTA
FROM BLDG B INNER JOIN STOR S
ON S.B_ID = B.B_ID
CROSS APPLY dbo.INVENTORIZE(B.B_ID) AS T;

上面提供了一个日志表，TRIGGER如下所示：

CREATE TRIGGER trgrCYCLE
ON STOR
FOR UPDATE
AS
INSERT INTO dbo.INVT
    (TS, BLDG, PROD, ACT, VAL)
    SELECT CURRENT_TIMESTAMP, B_ID, PRODUCTION,
        CASE WHEN DELTA < 0 THEN 'SELL' ELSE 'BUY' END,
        DELTA
    FROM inserted WHERE COALESCE(DELTA,0) <> 0

最后，每次更新都应该 在我添加到上面 TRIGGER 的财务表中占INSERT 一行：

INSERT INTO dbo.FINS
    (COMPANY, TS, COST2, BAL)
    SELECT CORP, CURRENT_TIMESTAMP, COST,
    ((SELECT TOP 1 BAL FROM FINS WHERE COMPANY = CORP ORDER BY TS DESC)- COST)
    FROM inserted WHERE COALESCE(COST,0) <> 0

问题在于这一行：

((SELECT TOP 1 BAL FROM FINS WHERE COMPANY = CORP ORDER BY TS DESC)- COST)

这意味着计算帐户的最新余额。但是因为CROSS APPLY将所有这些都INSERTS视为一个批次，所以计算是根据相同的最后一条记录完成的，我得到了一个不正确的余额数字。例子：

 COST    BALANCE
----------------
          1,000   <-- initial balance
 -150       850
 -220       780   <-- should be 630

解决这个问题的方法是什么？表上的触发器FINS而不是余额计算？

4

6 回答 6

2

了解查询中的现有逻辑

UPDATE对于满足连接条件的集合或批次，语句只会触发trigger一次，插入的语句将包含所有正在更新的记录。这是因为 BATCH 处理不是因为，CROSS APPLY而是因为UPDATE.

在你的这个查询中

   SELECT CORP, CURRENT_TIMESTAMP, COST,
    ((SELECT TOP 1 BAL FROM FINS WHERE COMPANY = CORP ORDER BY TS DESC)- COST)
    FROM inserted WHERE COALESCE(COST,0) <> 0

对于来自外部查询的每个 CORP，将返回相同的 BAL。

(SELECT TOP 1 BAL FROM FINS WHERE COMPANY = CORP ORDER BY TS DESC)

话虽如此，每次 CORP = 'XYZ' 时，您的内部查询将被 1000（您在示例中使用的值）替换

   SELECT CORP, CURRENT_TIMESTAMP, COST, (1000- COST)        
    FROM inserted WHERE COALESCE(COST,0) <> 0

现在您的插入语句具有所有正在插入的记录。因此，每条记录的成本将减去 1000。因此，您会得到意想不到的结果。

建议的解决方案

根据我的理解，您想计算一些累积频率之类的东西。或上次运行总计

问题陈述的数据准备。用我的虚拟数据给你一个想法。

--Sort data based on timestamp in desc order
SELECT PK_LoginId AS Bal, FK_RoleId AS Cost, AddedDate AS TS
, ROW_NUMBER() OVER (ORDER BY AddedDate DESC) AS Rno 
INTO ##tmp 
FROM dbo.M_Login WHERE AddedDate IS NOT NULL


--Check how data looks
SELECT Bal, Cost, Rno, TS FROM ##tmp

--Considering ##tmp as your inserted table, 
--I just added Row_Number to apply Top 1 Order by desc logic 

+-----+------+-----+-------------------------+
| Bal | Cost | Rno |           TS            |
+-----+------+-----+-------------------------+
| 172 |   10 |   1 | 2012-12-05 08:16:28.767 |
| 171 |   10 |   2 | 2012-12-04 14:36:36.483 |
| 169 |   12 |   3 | 2012-12-04 14:34:36.173 |
| 168 |   12 |   4 | 2012-12-04 14:33:37.127 |
| 167 |   10 |   5 | 2012-12-04 14:31:21.593 |
| 166 |   15 |   6 | 2012-12-04 14:30:36.360 |
+-----+------+-----+-------------------------+

从上次运行余额中减去成本的替代逻辑。

--Start a recursive query to subtract balance based on cost
;WITH cte(Bal, Cost, Rno)
AS
(
    SELECT t.Bal, 0, t.Rno FROM ##tmp t WHERE t.Rno = 1
    UNION ALL
    SELECT c.Bal - t.Cost, t.Cost, t.Rno FROM ##tmp t 
      INNER JOIN cte c ON t.RNo - 1 = c.Rno
)
SELECT * INTO ##Fin FROM cte;

SELECT * FROM ##Fin

输出

+-----+------+-----+
| Bal | Cost | Rno |
+-----+------+-----+
| 172 |    0 |   1 |
| 162 |   10 |   2 |
| 150 |   12 |   3 |
| 138 |   12 |   4 |
| 128 |   10 |   5 |
| 113 |   15 |   6 |
+-----+------+-----+

你必须在你的列上发一点推文才能让这个功能进入你的触发器。

于 2014-02-26T20:03:49.060 回答
0

Something like that, Isn't complete. 

CREATE TRIGGER trgrCYCLE
ON STOR
FOR UPDATE
AS
begin

declare @last_bal int

declare @company varchar(50)
declare @ts  --type
declare @cost  int
declare @bal  --type
--etc whatever you need

select @company = company, @ts= ts , @cost = cost , @bal = bal from INSERTED

 --others selects  and sets

set @last_bal = select bal from dbo.FINS where you_primary_key = IDENT_CURRENT('FINS'))

set @last_bal = @last_bal - @cost

Insert INTO FINS (company, ts, cost2, bal) VALUES (@company, @ts, @cost, @last_bal) where --your conditions


end
于 2014-02-27T19:11:32.670 回答
0

我认为您可以尝试在鳍上触发。

您可以使用 IDENT_CURRENT('Table')) 从表中获取最后一个主键并进行选择。

我认为这比“选择前1名”要好。

要获取最后一个余额值，请设置一个变量 last_bal = select bal from FINS where primary_key = Ident_Current("FINS")

于 2014-02-26T12:04:51.670 回答
0

如果与@Shantanu 的方法类似，您可以将序列与插入的、与触发器关联的虚拟表关联起来，您可以通过减去当前记录之前的所有 COST 来做到这一点。

这可以通过向 STOR 添加 rowversion 来完成，每次删除都会自动更新。

然后代替：

((SELECT TOP 1 BAL FROM FINS WHERE COMPANY = CORP ORDER BY TS DESC)- COST) from inserted ...

制作 rowversion RV，并且：

(SELECT SUM(X.B) FROM
      (SELECT TOP 1 BAL B 
           FROM FINS 
           WHERE COMPANY = CORP
           ORDER BY TS DESC
       UNION
       SELECT -COST B 
           FROM inserted ii
           WHERE ii.RV >= i.RV AND ii.CORP = i.CORP
       ) AS X)
    FROM inserted i WHERE COALESCE(COST,0) <> 0

应该做你想做的。可以想象，您可以使用比 CURRENT_TIMESTAMP 更精细的时间戳来执行此操作，我相信，CURRENT_TIMESTAMP 只会下降到几秒钟，但这需要您在 UPDATE 语句中更新它。rowversion 可能会导致您的 STOR 插入语句出现问题。

于 2014-02-27T22:26:49.767 回答
0

出色地

第一个 sql 是一个游戏，它与组一起工作，或者更确切地说是“设置”，所以你总是要考虑这一点。

如果您使用一个简单的项目是正确的，那可能是更好的方法

declare @myinsert table(id int identity(1,1), company VArchar(35), ts datetime, cost2 smallmoney, bal smallmoney)


insert into @myinsert(company,ts, cost2, bal)
SELECT CORP, CURRENT_TIMESTAMP, COST, 
FROM inserted WHERE COALESCE(COST,0) <> 0


declare @current int

select @current = min(id) from @myinsert

while exists(select * from @myinsert where id = @current)
begin
  INSERT INTO dbo.FINS
  (COMPANY, TS, COST2, BAL)
  SELECT COMPANY, CURRENT_TIMESTAMP, COST,
  ((SELECT TOP 1 BAL FROM FINS WHERE COMPANY = my.COMPANY ORDER BY TS DESC)- COST)
  from @myinsert my where id = @current

  select @current = min(id) from @myinsert where id > @current
end
于 2014-02-26T16:54:31.560 回答
0

我没有给你确切的查询。暂时忘记触发器。因为你无法测试你的查询。我建议使用 Output 子句。这至少可以帮助您构建正确的查询并对其进行测试。该查询运行正常，（如果您可以使用合并，那最好）。

Declare @t table 
( 
  BLOC1,BLOC2,BLOC3 ,PRODUCTION ,DELTA --whatever column is require here
)  

UPDATE STOR SET
    STOR.BLOC1 = T.BLOC1,
    STOR.BLOC2 = T.BLOC2,
    STOR.BLOC3 = T.BLOC3,
    STOR.PRODUCTION = T.PROD,
    STOR.DELTA = T.DELTA
Output inserted.BLOC1 ,inserted.BLOC2,  and so on into @t
FROM BLDG B INNER JOIN STOR S
ON S.B_ID = B.B_ID
CROSS APPLY dbo.INVENTORIZE(B.B_ID) AS T;

现在您已在表变量@t 中插入值

 SELECT CORP, CURRENT_TIMESTAMP, COST,
 BAL,Row_Number() over(partition by company order by TS desc) RN 
FROM @t inner join FINS on COMPANY = CORP
WHERE COALESCE(COST,0) <> 0

在此处验证此查询。考虑稍后优化或触发。我想我给出了很好的建议。我想减法不是问题。我告诉将所有内容放在输出子句中并分析查询并测试它。

您也可以在触发器中使用 CTE，但您将如何测试它。

  ;With CTE as
    (
      SELECT CORP, CURRENT_TIMESTAMP, COST,BAL
   ROW_NUMBER()over(ORDER BY TS DESC )rn
    FROM inserted
        inner join FINS on COMPANY = CORP

     WHERE COALESCE(COST,0) <> 0
    )
    select * from CTE --check this what you are getting
于 2014-02-27T09:49:18.733 回答