SQLによるレコードの統合処理

Question

SQLによるレコードの統合処理を行いたいです。
実際に想定通り動くSQLは組めたのですが、重くて使い物になりません。
パフォーマンスの改善方法、もしくは別の案などがあれば教えていただきたいです。

実現したいこと

以下具体例です。

次のようなテーブルAがあったとします。

テーブルA

会社名	取引先名	取引金額
A社	hoge社	10000
A社	fuga社	2000
A社	piyo社	3000
B社	hoge社	40000
B社	fuga社	5000
B社	puyo社	6000
C社	hoge社	7000
C社	fuga社	8000

ここでfuga社がhoga社に吸収され、以下のようにテーブルを更新する必要が出てきました。

会社名	取引先名	取引金額
A社	hoge社	12000
A社	piyo社	3000
B社	hoge社	45000
B社	puyo社	6000
C社	hoge社	15000

前提として、元のテーブルAの取引先には会社名1つに対して必ずhoge社とfuga社が1つずつ入っています。

発生している問題

目的の処理を実現するために以下のようなSQLを作成しました。

DECLARE @CompanyName NVARCHAR(100);

		DECLARE crTriggerList CURSOR 
		FOR
		   SELECT DISTINCT [会社名] AS CompanyName --会社名の一覧
		   FROM [テーブルA]

		OPEN crTriggerList;

		FETCH NEXT FROM crTriggerList
		INTO @CompanyName;

		WHILE @@FETCH_STATUS = 0
		BEGIN
			DECLARE @Price DECIMAL(12,0);

			--統合前の合計
			SELECT @Price = SUM(取引金額)
			FROM [テーブルA]
			WHERE 会社名 = @CompanyName
			AND (取引先名= 'hoge'
			OR 取引先名 = 'fuga')

			--統合した計算結果で更新
			UPDATE テーブルA
			SET 取引金額 = @Price
			FROM [テーブルA]
			WHERE 会社名 = @CompanyName
			AND 取引先名= 'hoge'
			
			--吸収された会社削除
			DELETE FROM [テーブルA]
			WHERE 会社名 = @CompanyName
			AND 取引先名= 'fuga'

			FETCH NEXT FROM crTriggerList --会社名ごとに上記の処理を繰り返す
			INTO @CompanyName;
		END

		CLOSE crTriggerList;
		DEALLOCATE crTriggerList;

一応これで期待通りの結果は得られるのですが、レコードが増えると時間がかかりすぎてしまいます。
パフォーマンスの改善方法、もしくはカーソル処理を使わない別の案などがあれば教えていただきたいです。

よろしくお願いします。

補足情報（FW/ツールのバージョンなど）

Microsoft SQL Server Management Studio 18
Microsoft SQL Server 2019 (RTM-GDR) (KB4583458) - 15.0.2080.9 (X64) Nov 6 2020 16:50:01 Copyright (C) 2019 Microsoft Corporation Enterprise Edition (64-bit) on Windows Server 2019 Datacenter 10.0 <X64> (Build 17763: ) (Hypervisor)

Comments

[maisumakun]

> レコードが増えると時間がかかりすぎてしまいます。

定期的に行う処理ではないと思うのですが、どの程度の件数に対してどの程度時間がかかるのでしょうか。

[kakutus]

maisumakun さん
1000件のレコードに対して更新をかけたところ10分程度かかりました。
対象のレコードは200万件程あるので、単純計算でも20000分、およそ13日もかかってしまいます…。
せめて1日で終わるようにはしたいです。

Answer 1

1000件のレコードに対して更新をかけたところ10分程度かかりました。

これって、200万の内1,000件って事ですよね？
※そうでないと、質問に上げていない条件が含まれていない限り、全体で1,000件なら遅すぎます。

少なくとも(会社名, 取引先名)のインデックスが無いと遅いと思われます。

手打ちで検証もしていませんが、updateだけ記述してみました。

UPDATE テーブルA dst
SET 取引金額 = src.統合額
from (
      select 会社名, sum(取引金額) 統合額
      from	テーブルA ta
      WHERE 取引先名 in ('hoge', 'fuga')
        and exists (select 1 from [テーブルA] where 会社名=ta.会社名 and 取引先名= 'hoge')
        and exists (select 1 from [テーブルA] where 会社名=ta.会社名 and 取引先名= 'fuga')
      group by 会社名
) src
where dst.会社名=src.会社名
  and dst.取引先名='hoge'

ただ、後から統合前の状態も必要とかにならないなら良いですけど、データ規模からすると有り得そうな気もします。

Comments

[kakutus]

圧倒的に早くなりました！ありがとうございました。
使い方次第でしょうけどすぐFETCHに頼るのは良くないということがわかりました…。

＞ただ、後から統合前の状態も必要とかにならないなら良いですけど、データ規模からすると有り得そうな気もします。
そこはバックアップがあるので問題ありません。ご親切にありがとうございます。

Answer 2

SELECT 会社名, SUM(取引金額) WHERE 取引先名 IN('hoge', 'fuga') GROUP BY 会社名のような集計を行って、それで一気に置き換えるような方向性を考えたほうがいいのではないでしょうか。

Comments

[kakutus]

方針はほぼ同じでしたが、具体的なコードを載せていただいたsaziさんの回答をベストアンサーにしました。
迅速な回答ありがとうございました！