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-29 10:53:04 +09:00
parent 6239ef783a
commit 2d56d82420
6 changed files with 18 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -7,7 +7,7 @@ BEGIN
-- プロシージャ名 -- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'hco_to_mdb_laundering'; DECLARE procedure_name VARCHAR(100) DEFAULT 'hco_to_mdb_laundering';
-- プロシージャの引数 -- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT(); DECLARE procedure_args JSON DEFAULT JSON_OBJECT('target_table', target_table);
-- 例外処理 -- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION DECLARE EXIT HANDLER FOR SQLEXCEPTION
@ -18,7 +18,7 @@ BEGIN
'hco_to_mdb_launderingでエラーが発生', @error_state, @error_msg); 'hco_to_mdb_launderingでエラーが発生', @error_state, @error_msg);
SET @error_msg = ( SET @error_msg = (
CASE CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...') WHEN LENGTH(@error_msg) > 128 THEN CONCAT(SUBSTRING(@error_msg, 1, 125), '...')
ELSE @error_msg ELSE @error_msg
END END
); );

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

@ -7,7 +7,7 @@ BEGIN
-- プロシージャ名 -- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'inst_merge_laundering'; DECLARE procedure_name VARCHAR(100) DEFAULT 'inst_merge_laundering';
-- プロシージャの引数 -- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT(); DECLARE procedure_args JSON DEFAULT JSON_OBJECT('target_table', target_table);
-- 例外処理 -- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION DECLARE EXIT HANDLER FOR SQLEXCEPTION
@ -18,7 +18,7 @@ BEGIN
'inst_merge_launderingでエラーが発生', @error_state, @error_msg); 'inst_merge_launderingでエラーが発生', @error_state, @error_msg);
SET @error_msg = ( SET @error_msg = (
CASE CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...') WHEN LENGTH(@error_msg) > 128 THEN CONCAT(SUBSTRING(@error_msg, 1, 125), '...')
ELSE @error_msg ELSE @error_msg
END END
); );

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

@ -7,7 +7,8 @@ BEGIN
-- プロシージャ名 -- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'sales_lau_delete'; DECLARE procedure_name VARCHAR(100) DEFAULT 'sales_lau_delete';
-- プロシージャの引数 -- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT(); DECLARE procedure_args JSON DEFAULT JSON_OBJECT('target_table', target_table,
'laundering_period_year', laundering_period_year);
-- 例外処理 -- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION DECLARE EXIT HANDLER FOR SQLEXCEPTION
@ -18,7 +19,7 @@ BEGIN
'sales_lau_deleteでエラーが発生', @error_state, @error_msg); 'sales_lau_deleteでエラーが発生', @error_state, @error_msg);
SET @error_msg = ( SET @error_msg = (
CASE CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...') WHEN LENGTH(@error_msg) > 128 THEN CONCAT(SUBSTRING(@error_msg, 1, 125), '...')
ELSE @error_msg ELSE @error_msg
END END
); );
@ -39,7 +40,8 @@ BEGIN
"; ";
SET @delete_data = REPLACE(@delete_data, "$$target_table$$", target_table); SET @delete_data = REPLACE(@delete_data, "$$target_table$$", target_table);
PREPARE delete_data_stmt from @delete_data; PREPARE delete_data_stmt from @delete_data;
EXECUTE delete_data_stmt USING @laundering_period_year; SET @interval_year = laundering_period_year;
EXECUTE delete_data_stmt USING @interval_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,
'卸販売実績テーブル（洗替後）過去５年以前のデータ削除① 終了'); '卸販売実績テーブル（洗替後）過去５年以前のデータ削除① 終了');

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

@ -1,6 +1,6 @@
-- A5M2で実行時に[SQL] - [スラッシュ(/)のみの行でSQLを区切る]に変えてから実行する -- A5M2で実行時に[SQL] - [スラッシュ(/)のみの行でSQLを区切る]に変えてから実行する
CREATE PROCEDURE src05.sales_lau_upsert(target_table VARCHAR(255), extract_from_date date, CREATE PROCEDURE src05.sales_lau_upsert(target_table VARCHAR(255), extract_from_date DATE,
extract_to_date date) extract_to_date DATE)
SQL SECURITY INVOKER SQL SECURITY INVOKER
BEGIN BEGIN
-- スキーマ名 -- スキーマ名
@ -8,7 +8,8 @@ BEGIN
-- プロシージャ名 -- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'sales_lau_upsert'; DECLARE procedure_name VARCHAR(100) DEFAULT 'sales_lau_upsert';
-- プロシージャの引数 -- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT(); DECLARE procedure_args JSON DEFAULT JSON_OBJECT('target_table', target_table, 'extract_from_date',
extract_from_date, 'extract_to_date', extract_to_date);
-- 例外処理 -- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION DECLARE EXIT HANDLER FOR SQLEXCEPTION
@ -19,7 +20,7 @@ BEGIN
'sales_lau_upsertでエラーが発生', @error_state, @error_msg); 'sales_lau_upsertでエラーが発生', @error_state, @error_msg);
SET @error_msg = ( SET @error_msg = (
CASE CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...') WHEN LENGTH(@error_msg) > 128 THEN CONCAT(SUBSTRING(@error_msg, 1, 125), '...')
ELSE @error_msg ELSE @error_msg
END END
); );

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

@ -7,7 +7,7 @@ BEGIN
-- プロシージャ名 -- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'v_inst_merge_laundering'; DECLARE procedure_name VARCHAR(100) DEFAULT 'v_inst_merge_laundering';
-- プロシージャの引数 -- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT(); DECLARE procedure_args JSON DEFAULT JSON_OBJECT('target_table', target_table);
-- 例外処理 -- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION DECLARE EXIT HANDLER FOR SQLEXCEPTION
@ -18,7 +18,7 @@ BEGIN
'v_inst_merge_launderingでエラーが発生', @error_state, @error_msg); 'v_inst_merge_launderingでエラーが発生', @error_state, @error_msg);
SET @error_msg = ( SET @error_msg = (
CASE CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...') WHEN LENGTH(@error_msg) > 128 THEN CONCAT(SUBSTRING(@error_msg, 1, 125), '...')
ELSE @error_msg ELSE @error_msg
END END
); );
@ -43,8 +43,6 @@ BEGIN
prft_cd prft_cd
FROM FROM
internal05.v_inst_merge_t internal05.v_inst_merge_t
WHERE
(fcl_type IN ('A1', 'A0')) OR fcl_type BETWEEN '20' AND '29'
) AS vimt, ) AS vimt,
$$target_table$$ AS tt $$target_table$$ AS tt
SET SET

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

@ -7,7 +7,7 @@ BEGIN
-- プロシージャ名 -- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'whs_org_laundering'; DECLARE procedure_name VARCHAR(100) DEFAULT 'whs_org_laundering';
-- プロシージャの引数 -- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT(); DECLARE procedure_args JSON DEFAULT JSON_OBJECT('target_table', target_table);
-- 例外処理 -- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION DECLARE EXIT HANDLER FOR SQLEXCEPTION
@ -18,7 +18,7 @@ BEGIN
'whs_org_launderingでエラーが発生', @error_state, @error_msg); 'whs_org_launderingでエラーが発生', @error_state, @error_msg);
SET @error_msg = ( SET @error_msg = (
CASE CASE
WHEN LENGTH(@error_msg) > 127 THEN CONCAT(SUBSTRING(@error_msg, 1, 124), '...') WHEN LENGTH(@error_msg) > 128 THEN CONCAT(SUBSTRING(@error_msg, 1, 125), '...')
ELSE @error_msg ELSE @error_msg
END END
); );