From d92c5418cf2c349dfaf879e0c83378830e017cf9 Mon Sep 17 00:00:00 2001
From: y-ono-r <95060536+y-ono-r@users.noreply.github.com>
Date: Tue, 2 Aug 2022 16:19:32 +0900
Subject: [PATCH] =?UTF-8?q?feat:crm=5Fdata=5Fsync=E3=81=AE=E6=96=B0?=
 =?UTF-8?q?=E8=A6=8F=E4=BD=9C=E6=88=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 rds_mysql/stored_procedure/crm_data_sync.sql | 41 ++++++++++++++++++++
 1 file changed, 41 insertions(+)
 create mode 100644 rds_mysql/stored_procedure/crm_data_sync.sql

diff --git a/rds_mysql/stored_procedure/crm_data_sync.sql b/rds_mysql/stored_procedure/crm_data_sync.sql
new file mode 100644
index 00000000..c039a18a
--- /dev/null
+++ b/rds_mysql/stored_procedure/crm_data_sync.sql
@@ -0,0 +1,41 @@
+-- A5M2で実行時にSQL区切り文字を「;」以外にすること
+-- $$から始まる文字は後からREPLACEする文字を示す独自ルール
+-- crm_data_syncストアドプロシージャは、同一セッション内での並列処理を実行することができない
+CREATE PROCEDURE crm_data_sync(target_table VARCHAR(255), target_table_all VARCHAR(255), target_column VARCHAR(255))
+BEGIN
+	-- 例外処理
+	-- エラーが発生した場合に一時テーブルの削除を実施
+	DECLARE EXIT HANDLER FOR SQLEXCEPTION 
+		BEGIN
+			GET DIAGNOSTICS CONDITION 1
+				@error_state = RETURNED_SQLSTATE, @error_msg = MESSAGE_TEXT;
+			ROLLBACK;
+			SIGNAL SQLSTATE '45000'
+				SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
+		END;
+
+	SET @error_state = NULL, @error_msg = NULL;
+	START TRANSACTION;
+
+	-- ①-1 Salesforce側で物理削除されたデータを検出し更新する
+	SET @update_end_datetime = '
+		UPDATE $$target_table$$ tt 
+			LEFT JOIN $$target_table_all$$ tta 
+				ON tt.id = tta.id
+				AND tt.$$target_column$$ = tta.$$target_column$$ 
+		SET
+			tt.end_datetime = CURRENT_TIMESTAMP()
+			, tt.upd_user = CURRENT_USER() 
+			, tt.upd_date = CURRENT_TIMESTAMP()
+		WHERE
+			tta.id IS NULL
+			AND tt.end_datetime = "9999-12-31 00:00:00"
+	';
+	SET @update_end_datetime = REPLACE(@update_end_datetime, "$$target_table$$", target_table);
+    SET @update_end_datetime = REPLACE(@update_end_datetime, "$$target_table_all$$", target_table_all);
+    SET @update_end_datetime = REPLACE(@update_end_datetime, "$$target_column$$", target_column);
+	PREPARE update_end_datetime_stmt from @update_end_datetime;
+	EXECUTE update_end_datetime_stmt;
+
+	COMMIT;
+END
\ No newline at end of file