nik/newdwh2021
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:指摘事項修正

Browse Source
This commit is contained in:
daido 2023-10-24 11:36:31 +09:00
parent 6bf655b228
commit a9f7b0e6df
1 changed files with 200 additions and 200 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
rds_mysql/stored_procedure/internal02/crm_distribution_Call2_vod__c.sql
View File

@ -1,6 +1,6 @@
-- A5M2で実行時に[SQL] - [スラッシュ(/)のみの行でSQLを区切る]に変えてから実行する -- A5M2で実行時に[SQL] - [スラッシュ(/)のみの行でSQLを区切る]に変えてから実行する
-- $$から始まる文字は後からREPLACEする文字を示す独自ルール -- $$から始まる文字は後からREPLACEする文字を示す独自ルール
-- crm_distribution_Call2_vod__cストアドプロシージャは、同一セッション内での並列処理を実行することができない -- 当プロシージャは、同一セッション内での並列処理を実行することができない
-- 実行者の権限でストアドプロシージャを実行するために、「SQL SECURITY INVOKER」を付与している -- 実行者の権限でストアドプロシージャを実行するために、「SQL SECURITY INVOKER」を付与している
CREATE PROCEDURE `internal02`.`crm_distribution_Call2_vod__c`() CREATE PROCEDURE `internal02`.`crm_distribution_Call2_vod__c`()
SQL SECURITY INVOKER SQL SECURITY INVOKER
@ -16,7 +16,7 @@ DECLARE temp_table_id VARCHAR(18);
DECLARE fetch_done BOOLEAN DEFAULT FALSE; DECLARE fetch_done BOOLEAN DEFAULT FALSE;
-- カーソル設定 -- カーソル設定
DECLARE table_cursor CURSOR FOR SELECT Id, RecordTypeId FROM internal02.crm_call2_vod__c; DECLARE table_cursor CURSOR FOR SELECT Id, RecordTypeId FROM internal02.crm_Call2_vod__c;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET fetch_done = TRUE; DECLARE CONTINUE HANDLER FOR NOT FOUND SET fetch_done = TRUE;
-- エラー処理 -- エラー処理
@ -39,7 +39,7 @@ START TRANSACTION;
-- UPSERT STATEMENT設定 -- UPSERT STATEMENT設定
SET @upsert_statement_base = SET @upsert_statement_base =
'INSERT INTO $$distribution_schema$$.crm_call2_vod__c 'INSERT INTO $$distribution_schema$$.crm_Call2_vod__c
(Id, OwnerId, IsDeleted, Name, RecordTypeId, CreatedDate, CreatedById, LastModifiedDate, LastModifiedById, (Id, OwnerId, IsDeleted, Name, RecordTypeId, CreatedDate, CreatedById, LastModifiedDate, LastModifiedById,
SystemModstamp, LastActivityDate, MayEdit, IsLocked, LastViewedDate, LastReferencedDate, Call_Comments_vod__c, SystemModstamp, LastActivityDate, MayEdit, IsLocked, LastViewedDate, LastReferencedDate, Call_Comments_vod__c,
Sample_Card_vod__c, Add_Detail_vod__c, Property_vod__c, Account_vod__c, zvod_Product_Discussion_vod__c, Sample_Card_vod__c, Add_Detail_vod__c, Property_vod__c, Account_vod__c, zvod_Product_Discussion_vod__c,
@ -130,9 +130,9 @@ SET @upsert_statement_base =
MSJ_Scientific_Interaction__c, MSJ_Activity_Email_Reply__c, MSJ_Interaction_Duration__c, MSJ_SIPAGL_1A_date__c, MSJ_Scientific_Interaction__c, MSJ_Activity_Email_Reply__c, MSJ_Interaction_Duration__c, MSJ_SIPAGL_1A_date__c,
MSJ_CoPromotion__c, Call_Channel_Formula_vod__c, file_name, file_row_cnt, delete_flg, ins_user, ins_date, upd_user, upd_date MSJ_CoPromotion__c, Call_Channel_Formula_vod__c, file_name, file_row_cnt, delete_flg, ins_user, ins_date, upd_user, upd_date
FROM FROM
internal02.crm_call2_vod__c AS internaltb internal02.crm_Call2_vod__c AS internaltb
WHERE WHERE
Id = ? internaltb.Id = ?
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
OwnerId = internaltb.OwnerId, IsDeleted = internaltb.IsDeleted, Name = internaltb.Name, OwnerId = internaltb.OwnerId, IsDeleted = internaltb.IsDeleted, Name = internaltb.Name,
RecordTypeId = internaltb.RecordTypeId, CreatedDate = internaltb.CreatedDate, CreatedById = internaltb.CreatedById, RecordTypeId = internaltb.RecordTypeId, CreatedDate = internaltb.CreatedDate, CreatedById = internaltb.CreatedById,
@ -257,7 +257,7 @@ TableCursorLoop: LOOP
LEAVE TableCursorLoop; LEAVE TableCursorLoop;
END IF; END IF;
SET @distribution_schema = get_distribution_to_schema('crm_call2_vod__c', 'RecordTypeId', target_column_value); SET @distribution_schema = internal02.get_distribution_to_schema('crm_Call2_vod__c', 'RecordTypeId', target_column_value);
SET @temp_table_id = temp_table_id; SET @temp_table_id = temp_table_id;
SET @upsert_statement = REPLACE(@upsert_statement_base, "$$distribution_schema$$", @distribution_schema); SET @upsert_statement = REPLACE(@upsert_statement_base, "$$distribution_schema$$", @distribution_schema);