用30M行更新SQL数据库表

我有一个大约30M行的MS SQL表，我需要根据以前的记录更新一个字段。这里是工作的一个更新，但它走的时间了难以置信的：用30M行更新SQL数据库表

UPDATE AccountTransaction 
SET EndingBalance = (SELECT COALESCE(SUM(b.amount), 0) 
FROM AccountTransaction AS b 
WHERE b.AccountId = AccountTransaction.AccountId 
and b.Date <= AccountTransaction.Date 
and (b.Date != AccountTransaction.Date 
    or b.CreatedDate < AccountTransaction.CreatedDate)) 
+ Amount

以下是完整的DDL：

CREATE TABLE [dbo].[AccountTransaction](
    [AccountTransactionId] [uniqueidentifier] NOT NULL, 
    [AccountId] [uniqueidentifier] NOT NULL, 
    [Amount] [decimal](16, 2) NOT NULL, 
    [EndingBalance] [decimal](16, 2) NOT NULL, 
    [Date] [date] NOT NULL, 
    [CreatedDate] [datetime2](3) NOT NULL, 
CONSTRAINT [PkAccountTransaction] PRIMARY KEY CLUSTERED 
(
    [AccountTransactionId] ASC 
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] 
) ON [PRIMARY] 

GO 

CREATE NONCLUSTERED INDEX [IxAccountTransaction_AccountId_Date_CreatedDate] ON [dbo].[AccountTransaction] 
(
    [AccountId] ASC, 
    [Date] ASC, 
    [CreatedDate] ASC 
) 
INCLUDE ([AccountTransactionId], 
    [Amount], 
    [EndingBalance]) WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, SORT_IN_TEMPDB = OFF, DROP_EXISTING = OFF, ONLINE = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] 
GO 

CREATE NONCLUSTERED INDEX [IxAccountTransaction_AccountId] ON [dbo].[AccountTransaction] 
(
    [AccountId] ASC 
) 
INCLUDE ([AccountTransactionId], 
    [Amount], 
    [EndingBalance], 
    [Date], 
    [CreatedDate]) WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, SORT_IN_TEMPDB = OFF, DROP_EXISTING = OFF, ONLINE = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] 
GO

来源

2017-09-15 Display Name

查询中没有表（或别名）'AccountTransaction'。 – joop

那30M行有多少个不同的'Table1Id'？ – SqlZim

如果'table1id'是唯一的，并且只引用相同的行，为什么要使用子查询，那么您正在更新'table1'，使用从'table1'中加上数量的子查询，但是在'table1id'上加入了数量？以及如果引用同一行，'b.createddate'如何小于'table1.createddate'或'b.date！= table1.date'？ – SqlZim

以下应该产生更好的性能，并能够利用的IxAccountTransaction_AccountId_Date_CreatedDate索引...

WITH 
    cte_Runningtotal AS (
    SELECT 
     at1.EndingBalance, 
     NewEB = SUM(at1.Amount) OVER (PARTITION BY at1.AccountId ORDER BY at1.[Date] ROWS UNBOUNDED PRECEDING) 
    FROM 
     dbo.AccountTransaction at1 
    ) 
UPDATE rt SET 
    rt.EndingBalance = rt.NewEB 
FROM 
    cte_Runningtotal rt;

来源

2017-09-15 20:53:54

用30M行更新SQL数据库表

回答

相关问题