如何使用动态 SQL Server 存储过程逐行使用事务日志更新表

如何解决如何使用动态 SQL Server 存储过程逐行使用事务日志更新表

我有一个表格，其中显示了 Ticket ID 及其状态以及在 BI 数据库上分配给谁。这里没有重复和粒度是每张票。

Ticket_ID   Status  Assigned_To   Date
--------------------------------------------------
001         Open    Team A        01/01/2020 10:01
002         Working Team B        01/01/2020 10:01
003         Open    Team C        02/01/2020 18:50
004         ResolvedTeam B        02/01/2020 19:22

现在，有一个包含每个更改的每日事务日志。然而，列 更改显示为如下行。

每日交易日志

Ticket_id     Field_Name        New Value     Date
---------------------------------------------------------------
001           Assigned_to       Team B        02/01/2020 10:23
002           Assigned_to       Team A        02/01/2020 10:23
002           Status            Resolved      02/01/2020 10:24
003           status            Resolved      03/01/2020 10:24
004           Assigned_to       Team C        03/01/2020 13:50
004           Assigned_to       Team A        03/01/2020 13:51
004           Status            Resolved      03/01/2020 13:51

现在我想使用动态 SQL 脚本编写一个更新脚本，使用游标（我想这是最好的方法）根据日志上的新值更新 Ticket 表。我需要 SQL 脚本在事务日志表上逐行执行并使用新值更新 Ticket 表。

预期输出如下：

Ticket_ID     Status     Assigned_To  Date
------------------------------------------------------
001           Open       Team B       02/01/2020 10:23
002           Resolved   Team A       02/01/2020 10:24
003           Resolved   TeamC        03/01/2020 10:24
004           Resolved   Team A       03/01/2020 13:51

解决方法

那种

update t
set
   Status = case log.Field_Name when 'Status' then log.NewValue else t.Status end,...
   Assigned_To = case log.Field_Name when 'Assigned_To' then log.NewValue else t.Assigned_To end,Date = log.LastDate
from tickets t
join ( -- take only last row for Ticket_id + Field_Name
   select top(1) with ties Ticket_id,Field_Name,NewValue,max(Date) over (partition by Ticket_id) LastDate
   from DailyLog
   order by row_number() over(partition by Ticket_id,Field_Name order by Date desc)
  ) log on t.Ticket_ID = log.Ticket_ID

,

这里有一个您可以用作模板的解决方案，只需修改您拥有的其他类型的日志操作即可。

首先去除不必要的重复，只留下每张票的最终状态，然后转入每个属性的一列，最后加入tickets进行更新。

好吧，也许不是那那么简单，但不需要光标:)

with l as (
    select *,Row_Number() over(partition by Ticket_id,Field_Name order by [date] desc)rn
    from TransactionLogs
),u as (
select l.ticket_id,Max(case when field_name='status' then newvalue end) [Status],Max(case when field_name='assigned_to' then newvalue end) Assigned_to,/* Add additionalfield name properties here */
    Max(l.[date]) [Date]
from l 
where l.rn=1 
group by l.ticket_id
)

update t set
    t.[status]=IsNull(u.[status],t.[status]),t.Assigned_To=IsNull(u.Assigned_to,t.Assigned_To),/* Include additional columns here */
    t.[date]=isnull(u.[date],t.[date])
from u join tickets t on t.Ticket_Id=u.Ticket_id;

见working fiddle