编辑:-对于任何有类似问题的人,都有一篇不错的文章介绍了各种解决方案here
鉴于下表记录和审核,SQL中的一个将如何转换为结果表。
有点背景,前一个表是在CRUD应用程序中收集数据的标准SQL表的简化示例。在对列进行任何更新时,都会以EAV格式将记录写入审核表。现在,需要将recs表转换为历史表,并在报告的时间点将其复制为每行的副本(数据最终将存储在星型模式数据仓库中。
似乎在过程语言中这足够简单,并且可以使用游标进行管理(如果很丑陋,但是有一种基于集合的方法行得通吗?
我现在正在使用T-SQL,但我想我可以移植任何足够丰富的SQL方言中的任何示例或想法。
create table recs
(
ID int identity(1,1) not null primary key,
Column1 nvarchar(30) not null,
Column2 nvarchar(30) not null,
sys_updated_on datetime not null
)
create table audit
(
ID int identity(1,1) not null primary key,
recs_id int not null,
fieldname nvarchar(30) not null,
old_value nvarchar(30) not null,
new_value nvarchar(30) not null,
sys_updated_on datetime not null
)
insert into recs (Column1, Column2, sys_updated_on)
values ('A', 'B', '2012-10-31 22:00')
, ('C', 'D', '2012-10-31 22:30')
insert into audit (recs_id, fieldname, old_value, new_value, sys_updated_on)
values (1, 'Column1', 'Z', 'A', '2012-10-31 22:00')
, (2, 'Column2','X', 'D', '2012-10-31 22:30')
, (1, 'Column1', 'Y', 'Z', '2012-10-31 21:00')
记录ID列1列2 sys_updated_on1 A B 31/10/2012 22:00:002 C D 31/10/2012 22:30:00
审计ID recs_id字段名old_value new_value sys_updated_on1 1列1 Z A 31/10/2012 22:00:002 2列2 X D 2012年10月31日22:30:003 1 Column1 Y Z 31/10/2012 21:00:00
recs_id sys_updated_on Column1 Column21个无效的Y B1 31/10/2012 21:00:00 Z B1 31/10/2012 22:00:00 A B2空C X2 31/10/2012 22:30:00 C D
有趣。...
尝试一下
;with cte as
(
select recs_id, sys_updated_on, column1, column2,
ROW_NUMBER() over (order by sys_updated_on) rn
from audit a
pivot
(max(old_value) for fieldname in (column1,column2)) p
)
select
recs_id,
case when ud1>ud2 then ud1 else ud2 end as updateddate,
coalesce(cte.column1,mc1,recs.column1),
coalesce(cte.column2,mc2,recs.column2)
from cte
outer apply
(
select top 1
column1 as mc1, sys_updated_on as ud1
from cte prev1
where prev1.recs_id=cte.recs_id and prev1.rn<cte.rn
order by prev1.rn desc
) r1
outer apply
(
select top 1
column2 as mc2, sys_updated_on as ud2
from cte prev2
where prev2.recs_id=cte.recs_id and prev2.rn<cte.rn
order by prev2.rn desc
) r2
inner join recs on cte.recs_id = recs.id
where cte.sys_updated_on is not null
union
select id, sys_updated_on, Column1, Column2 from recs
order by recs_id, cte.updateddate