0

为该问题设置正确的标题有点挑战,因此我将尝试解释该问题。我们使用JCC进行Oracle --> SQL Server复制。它的工作方式是读取 Oracle 中的事务日志,然后在每次更改时发送 2 个语句:INSERT + UPDATE。因此,如果没有这样的记录,如果SQL Server中的记录已经存在,它将被插入,所以第一次INSERT将因为PK冲突而失败,然后它会尝试UPDATE记录。

现在我们正在尝试使用SQL Server 时态表进行历史跟踪。当JCC(复制)失败时问题就开始了,因为我们需要重新播放日志。例如,复制在上午 11:01 失败。为了确保我们不会错过任何记录,我们需要重播,例如从上午 10:45 开始。它适用于普通表,但是当我们处理临时表时,它只会使历史变得错误并且历史变得不准确。

所以,现在的问题。如何识别这些记录并清理它们?

在此处输入图像描述

CREATE TABLE #temptable ( [UPDATE_DATE] datetime, [SysStart] datetime2(7), [SysEnd] datetime2(7), [key_column] char(8) )
INSERT INTO #temptable
VALUES
( N'2017-10-23T17:21:34', N'2017-10-23T21:21:44.5514785', N'2017-10-25T10:24:23.604867', '41862277' ), 
( N'2017-10-23T16:21:43', N'2017-10-25T10:24:23.604867', N'2017-10-25T10:24:24.4954892', '41862277' ), 
( N'2017-10-23T16:49:02', N'2017-10-25T10:24:24.4954892', N'2017-10-25T10:24:25.5111274', '41862277' ), 
( N'2017-10-23T17:20:58', N'2017-10-25T10:24:25.5111274', N'2017-10-25T10:24:25.5111274', '41862277' ), 
( N'2017-10-23T17:21:34', N'2017-10-25T10:24:25.5111274', N'2017-10-25T10:24:25.5111274', '41862277' ), 
( N'2017-10-10T14:17:49', N'2017-10-20T14:25:24.7135228', N'2017-10-23T20:21:52.6602561', '41862277' ), 
( N'2017-10-23T16:21:43', N'2017-10-23T20:21:52.6602561', N'2017-10-23T20:49:08.6122864', '41862277' ), 
( N'2017-10-23T16:49:02', N'2017-10-23T20:49:08.6122864', N'2017-10-23T21:20:58.7073273', '41862277' ), 
( N'2017-10-23T17:20:58', N'2017-10-23T21:20:58.7073273', N'2017-10-23T21:21:34.426412', '41862277' ), 
( N'2017-10-23T17:21:34', N'2017-10-23T21:21:34.426412', N'2017-10-23T21:21:44.5514785', '41862277' )


DROP TABLE #temptable

预期成绩: 在此处输入图像描述

4

1 回答 1

2

此查询返回您对提供的示例数据的预期结果。在运行 delete 语句之前检查 CTE 中的查询

with cte as (
    select 
        *, dr = dense_rank() over (partition by [key_column], cast([UPDATE_DATE] as date) order by cast([SysStart] as date))
    from 
        #temptable
)
delete from cte
where dr > 1
于 2018-02-16T16:52:59.430 回答