我有一个类似于以下的表结构:
CREATE TABLE Customer_Subscription
(
Customer_ID INT
, Product_ID INT
, Subscription_START DATETIME
, Subscription_END DATETIME
, PRIMARY KEY (Customer_ID, Product_ID)
)
然后,我还有一个审计表,如下所示:
CREATE TABLE Customer_Subscription_Audit
(
Audit_Code CHAR(1)
, AuditCreatedDateTime DATETIME
, Customer_ID INT
, Product_ID INT
, Subscription_START DATETIME
, Subscription_END DATETIME
)
每当对表Customer_Subscription进行更改时,我都有一个触发器,它还会向Audit表写入一行,记录以前更改的值(未修改的版本(,其中INSERT UPDATE DELETE由Audit_Code"I"、"U"、"D"表示
我有一个问题,我希望能够使用我的Customer_Subscription_Audit表在过去的任何给定时间点重新创建Customer_Subscribe表中的内容,我想知道最好的方法是什么?
(为了让它发挥作用,我目前正在考虑逐行循环浏览审计表……我知道RBAR很糟糕……但它应该能完成任务……但我想看看是否还有更有效的方法(
审核表备份每一行在修改前的状态。您可以用窗口函数实现逻辑:
select customer_id, product_id, subscription_start, subscription_end
from (
select csa.*,
row_number() over(
partition by customer_id, product_id
order by auditcreateddatetime
) rn
from customer_subscription_audit csa
where auditcreateddatetime >= @targetdatetime
) csa
where rn = 1 and audit_code <> 'I'
基本上,逻辑是筛选比恢复点新的审计行,并为每个客户/产品元组选择最早的记录。应忽略插入事件。