From fc3ce92e21ed01eab3331eea796e1f0da907280b 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?Revert=20"feat:crm=5Fdata=5Fsync=E3=81=AE?= =?UTF-8?q?=E6=96=B0=E8=A6=8F=E4=BD=9C=E6=88=90"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit 9b8076451f14b1ec07d5751d47cb79bbc1b709db. --- rds_mysql/stored_procedure/crm_data_sync.sql | 41 -------------------- 1 file changed, 41 deletions(-) delete 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 deleted file mode 100644 index c039a18a..00000000 --- a/rds_mysql/stored_procedure/crm_data_sync.sql +++ /dev/null @@ -1,41 +0,0 @@ --- 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