我的数据库有一个表:tableX。
Task1将密集的 INSERT(每分钟 1000 条记录)作为要处理的记录,并且很少将 UPDATE(每分钟 1-2 条记录)作为要重新计算的记录。
同时其他Task2 SELECT 未处理记录(由 Task1 插入),然后在一个事务中将新记录(已处理)插入同一个 tableX (计算时间太长,最多 10 秒)。
Task3重新计算 UPDATED 记录(通过 Task1):只是 UPDATEs tableX。
有人可以推荐设计以避免这种情况下的长时间锁定和死锁。按插入顺序处理所有 INSERTED 记录非常重要!
1)我应该分开(创建一个新的tableX2)已处理和未处理的记录吗?
2) 我应该在 Task1 中分离事务并在两个单独的事务中执行 SELECT 和 INSERT 吗?
3) 我应该使用 rowlock、readpast...提示以及在哪里(它可以帮助我)吗?
简单这个。
Task1 不应插入到主表中,而是插入到临时表中,比如 tableXstaging。该表应包括标识列或 row_processed(TINYINT 或 BIT)列。
Task1 一直在插入 tableXstaging。我会允许更新直接更新主表,因为它们很少见。
每分钟运行一次的另一项任务将是:从 tableXstaging 设置 MaxID = max(identity column),或者如果您改为使用 row_processed,则设置 row_processed = 1。这将为您提供要处理的批次。此任务将在 tableX 中插入所有记录,其中 identity<=MaxID,或者如果您使用 row_processed,WHERE row_processed = 1。单次插入到您的主 tableX 中非常快。然后从 tableXstaging 中删除 row_processed = 1,或者 WHERE identity<=MaxID。我会选择身份,因为您不需要更新 row_processed = 1 where row_processed = 0,这样会更快。
tableX 现在每分钟只插入一次。
实际上重新阅读你的问题,我会选择 row_processed,为你的第一批设置 row_processed = 1。
任务 2 在 row_processed = 1 的暂存表上工作。然后设置 row_processed = 2。
任务 3 在 row_processed = 2 的暂存表上工作。然后设置 row_processed = 3。
最后,SET XACT_ABORT ON;BEGIN TRAN,您一次性将记录插入 tableX (row_processed=3)。这是非常有效的,因为登台表很小,而 tableX 会很大而且很慢(相对于登台表而言)。然后从 row_processed = 3 的暂存中删除。COMMIT;