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

feat: 例外処理のメッセージオバーフローの対処等

Browse Source
This commit is contained in:
高木要 2023-06-27 14:02:47 +09:00
parent 07d9f37853
commit 6239ef783a
6 changed files with 72 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
rds_mysql/stored_procedure/src05/hco_to_mdb_laundering.sql
View File

@ -14,23 +14,29 @@ BEGIN
BEGIN
GET DIAGNOSTICS CONDITION 1
@error_state = RETURNED_SQLSTATE, @error_msg = MESSAGE_TEXT;
call medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
'hco_to_mdb_launderingでエラーが発生', @error_state, @error_msg);
SET @error_msg = (
CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...')
ELSE @error_msg
END
);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
SET @error_state = NULL, @error_msg = NULL;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】４：メルク施設コードの洗替_A① 開始');
TRUNCATE TABLE internal05.hco_cnv_mdb_t;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】４：メルク施設コードの洗替_A① 終了');
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】４：メルク施設コードの洗替_A② 開始');
INSERT INTO
@ -74,10 +80,10 @@ BEGIN
AND ci.delete_flg = '0'
;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】４：メルク施設コードの洗替_A② 終了');
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】４：メルク施設コードの洗替_A③ 開始');
SET @update_institution = "
@ -96,7 +102,7 @@ BEGIN
PREPARE update_institution_stmt from @update_institution;
EXECUTE update_institution_stmt;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】４：メルク施設コードの洗替_A③ 終了');
END

12
rds_mysql/stored_procedure/src05/inst_merge_laundering.sql
View File

@ -14,15 +14,21 @@ BEGIN
BEGIN
GET DIAGNOSTICS CONDITION 1
@error_state = RETURNED_SQLSTATE, @error_msg = MESSAGE_TEXT;
call medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
'inst_merge_launderingでエラーが発生', @error_state, @error_msg);
SET @error_msg = (
CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...')
ELSE @error_msg
END
);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
SET @error_state = NULL, @error_msg = NULL;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】４：メルク施設コードの洗替_B① 開始');
SET @update_institution = "
@ -53,7 +59,7 @@ BEGIN
PREPARE update_institution_stmt from @update_institution;
EXECUTE update_institution_stmt;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】４：メルク施設コードの洗替_B① 終了');
END

12
rds_mysql/stored_procedure/src05/sales_lau_delete.sql
View File

@ -14,15 +14,21 @@ BEGIN
BEGIN
GET DIAGNOSTICS CONDITION 1
@error_state = RETURNED_SQLSTATE, @error_msg = MESSAGE_TEXT;
call medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
'sales_lau_deleteでエラーが発生', @error_state, @error_msg);
SET @error_msg = (
CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...')
ELSE @error_msg
END
);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
SET @error_state = NULL, @error_msg = NULL;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）過去５年以前のデータ削除① 開始');
SET @delete_data = "
@ -35,7 +41,7 @@ BEGIN
PREPARE delete_data_stmt from @delete_data;
EXECUTE delete_data_stmt USING @laundering_period_year;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）過去５年以前のデータ削除① 終了');
END

32
rds_mysql/stored_procedure/src05/sales_lau_upsert.sql
View File

@ -15,25 +15,31 @@ BEGIN
BEGIN
GET DIAGNOSTICS CONDITION 1
@error_state = RETURNED_SQLSTATE, @error_msg = MESSAGE_TEXT;
call medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
'sales_lau_upsertでエラーが発生', @error_state, @error_msg);
SET @error_msg = (
CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...')
ELSE @error_msg
END
);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
SET @error_state = NULL, @error_msg = NULL;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成① 開始'
);
TRUNCATE TABLE internal05.bu_prd_name_contrast_t;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成① 終了'
);
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成② 開始'
);
@ -65,22 +71,22 @@ BEGIN
ppmv.rec_sts_kbn != '9'
;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成② 終了'
);
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成③ 開始'
);
TRUNCATE TABLE internal05.fcl_mst_v_t;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成③ 終了'
);
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成④ 開始'
);
@ -129,11 +135,11 @@ BEGIN
fmv1.rec_sts_kbn != '9'
;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成④ 終了'
);
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成⑤ 開始'
);
@ -430,11 +436,11 @@ BEGIN
PREPARE upsert_sales_launderning_stmt from @upsert_sales_launderning;
EXECUTE upsert_sales_launderning_stmt USING @extract_from_datetime, @extract_to_datetime;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成⑤ 終了'
);
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成⑥ 開始'
);
@ -466,7 +472,7 @@ BEGIN
PREPARE update_institution_code_stmt from @update_institution_code;
EXECUTE update_institution_code_stmt USING @extract_from_datetime, @extract_to_datetime;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'卸販売実績テーブル（洗替後）作成⑥ 終了'
);

12
rds_mysql/stored_procedure/src05/v_inst_merge_laundering.sql
View File

@ -14,15 +14,21 @@ BEGIN
BEGIN
GET DIAGNOSTICS CONDITION 1
@error_state = RETURNED_SQLSTATE, @error_msg = MESSAGE_TEXT;
call medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
'v_inst_merge_launderingでエラーが発生', @error_state, @error_msg);
SET @error_msg = (
CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...')
ELSE @error_msg
END
);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
SET @error_state = NULL, @error_msg = NULL;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】３：HCO施設コードの洗替① 開始'
);
@ -68,7 +74,7 @@ BEGIN
PREPARE update_institution_stmt from @update_institution;
EXECUTE update_institution_stmt;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】３：HCO施設コードの洗替① 終了'
);

20
rds_mysql/stored_procedure/src05/whs_org_laundering.sql
View File

@ -14,25 +14,31 @@ BEGIN
BEGIN
GET DIAGNOSTICS CONDITION 1
@error_state = RETURNED_SQLSTATE, @error_msg = MESSAGE_TEXT;
call medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_error_log(schema_name, procedure_name, procedure_args,
'whs_org_launderingでエラーが発生', @error_state, @error_msg);
SET @error_msg = (
CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...')
ELSE @error_msg
END
);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
SET @error_state = NULL, @error_msg = NULL;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】１．卸組織洗替① 開始'
);
TRUNCATE TABLE internal05.whs_customer_org_t;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】１．卸組織洗替① 終了'
);
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】１．卸組織洗替② 開始'
);
@ -91,11 +97,11 @@ BEGIN
AND src05.get_syor_date() BETWEEN wcmv.start_date AND wcmv.end_date
;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】１．卸組織洗替② 終了'
);
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】１．卸組織洗替③ 開始'
);
@ -115,7 +121,7 @@ BEGIN
PREPARE update_organization_stmt from @update_organization;
EXECUTE update_organization_stmt;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'【洗替】１．卸組織洗替③ 終了'
);