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

Merge pull request #225 feature-NEWDWH2021-1129 into develop

Browse Source
This commit is contained in:
朝倉 明日香 2023-07-03 11:40:34 +09:00
commit 9133f2b302
2 changed files with 130 additions and 118 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

118
rds_mysql/stored_procedure/src05/inst_merge_t_create.sql
View File

@ -2,69 +2,75 @@
CREATE PROCEDURE src05.inst_merge_t_create()
SQL SECURITY INVOKER
BEGIN
-- スキーマ名
DECLARE schema_name VARCHAR(50) DEFAULT (SELECT DATABASE());
-- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'inst_merge_t_create';
-- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT();
-- スキーマ名
DECLARE schema_name VARCHAR(50) DEFAULT (SELECT DATABASE());
-- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'inst_merge_t_create';
-- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT();
-- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION
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,
'inst_merge_t_createでエラーが発生', @error_state, @error_msg);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
-- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION
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,
'inst_merge_t_createでエラーが発生', @error_state, @error_msg);
SET @error_msg = (
CASE
WHEN LENGTH(@error_msg) > 128 THEN CONCAT(SUBSTRING(@error_msg, 1, 125), '...')
ELSE @error_msg
END
);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
SET @error_state = NULL, @error_msg = NULL;
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.inst_merge_t;
TRUNCATE TABLE internal05.inst_merge_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,
'アルトマーク施設統合マスタ（洗替処理一時テーブル）作成② 開始'
);
INSERT INTO
internal05.inst_merge_t (
dcf_dsf_inst_cd,
dup_opp_cd,
form_inst_name_kanji,
form_inst_name_kana,
inst_addr,
prefc_cd
)
SELECT
dim.dcf_inst_cd,
dim.dcf_inst_cd_new,
ci.form_inst_name_kanji,
ci.form_inst_name_kana,
ci.inst_addr,
ci.prefc_cd
FROM
src05.dcf_inst_merge dim
LEFT OUTER JOIN src05.com_inst ci
ON dim.dcf_inst_cd_new = ci.dcf_dsf_inst_cd
AND ci.delete_flg = '0'
WHERE
dim.muko_flg = '0'
AND dim.dcf_inst_cd_new IS NOT NULL
AND dim.enabled_flg = 'Y'
AND src05.to_date_yyyymm01(dim.tekiyo_month) <= src05.get_syor_date();
INSERT INTO
internal05.inst_merge_t (
dcf_dsf_inst_cd,
dup_opp_cd,
form_inst_name_kanji,
form_inst_name_kana,
inst_addr,
prefc_cd
)
SELECT
dim.dcf_inst_cd,
dim.dcf_inst_cd_new,
ci.form_inst_name_kanji,
ci.form_inst_name_kana,
ci.inst_addr,
ci.prefc_cd
FROM
src05.dcf_inst_merge AS dim
LEFT OUTER JOIN src05.com_inst AS ci
ON dim.dcf_inst_cd_new = ci.dcf_dsf_inst_cd
AND ci.delete_flg = '0'
WHERE
dim.muko_flg = '0'
AND dim.dcf_inst_cd_new IS NOT NULL
AND dim.enabled_flg = 'Y'
AND src05.to_date_yyyymm01(dim.tekiyo_month) <= src05.get_syor_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,
'アルトマーク施設統合マスタ（洗替処理一時テーブル）作成② 終了'
);
END

130
rds_mysql/stored_procedure/src05/v_inst_merge_t_create.sql
View File

@ -2,75 +2,81 @@
CREATE PROCEDURE src05.v_inst_merge_t_create()
SQL SECURITY INVOKER
BEGIN
-- スキーマ名
DECLARE schema_name VARCHAR(50) DEFAULT (SELECT DATABASE());
-- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'v_inst_merge_t_create';
-- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT();
-- スキーマ名
DECLARE schema_name VARCHAR(50) DEFAULT (SELECT DATABASE());
-- プロシージャ名
DECLARE procedure_name VARCHAR(100) DEFAULT 'v_inst_merge_t_create';
-- プロシージャの引数
DECLARE procedure_args JSON DEFAULT JSON_OBJECT();
-- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION
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,
'v_inst_merge_t_createでエラーが発生', @error_state, @error_msg);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
-- 例外処理
DECLARE EXIT HANDLER FOR SQLEXCEPTION
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,
'v_inst_merge_t_createでエラーが発生', @error_state, @error_msg);
SET @error_msg = (
CASE
WHEN LENGTH(@error_msg) > 128 THEN CONCAT(SUBSTRING(@error_msg, 1, 125), '...')
ELSE @error_msg
END
);
SIGNAL SQLSTATE '45000'
SET MYSQL_ERRNO = @error_state, MESSAGE_TEXT = @error_msg;
END;
SET @error_state = NULL, @error_msg = NULL;
SET @error_state = NULL, @error_msg = NULL;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'V施設統合マスタ（洗替処理一時テーブル）作成① 開始');
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'V施設統合マスタ（洗替処理一時テーブル）作成① 開始');
TRUNCATE TABLE internal05.v_inst_merge_t;
TRUNCATE TABLE internal05.v_inst_merge_t;
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'V施設統合マスタ（洗替処理一時テーブル）作成① 終了');
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'V施設統合マスタ（洗替処理一時テーブル）作成① 終了');
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'V施設統合マスタ（洗替処理一時テーブル）作成② 開始');
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'V施設統合マスタ（洗替処理一時テーブル）作成② 開始');
INSERT INTO
internal05.v_inst_merge_t (
v_inst_cd,
v_inst_cd_merge,
fcl_name,
fcl_kn_name,
fmt_addr,
prft_cd,
fcl_type
)
SELECT
vhmv.v_inst_cd,
vhmv.v_inst_cd_merg,
fmv.fcl_name,
fmv.fcl_kn_name,
fmv.fmt_addr,
fmv.prft_cd,
fmv.fcl_type
FROM
src05.vop_hco_merge_v vhmv,
src05.fcl_mst_v fmv
INNER JOIN (
SELECT
v_inst_cd,
MAX(sub_num) AS sno
FROM
src05.fcl_mst_v
GROUP BY
v_inst_cd
) max_sno_fmv
ON fmv.v_inst_cd = max_sno_fmv.v_inst_cd
AND fmv.sub_num = max_sno_fmv.sno
WHERE
vhmv.v_inst_cd_merg = fmv.v_inst_cd
AND STR_TO_DATE(vhmv.apply_dt, '%Y-%m-%d') <= src05.get_syor_date()
AND fmv.rec_sts_kbn != '9';
INSERT INTO
internal05.v_inst_merge_t (
v_inst_cd,
v_inst_cd_merge,
fcl_name,
fcl_kn_name,
fmt_addr,
prft_cd,
fcl_type
)
SELECT
vhmv.v_inst_cd,
vhmv.v_inst_cd_merg,
fmv.fcl_name,
fmv.fcl_kn_name,
fmv.fmt_addr,
fmv.prft_cd,
fmv.fcl_type
FROM
src05.vop_hco_merge_v AS vhmv,
src05.fcl_mst_v AS fmv
INNER JOIN (
SELECT
v_inst_cd,
MAX(sub_num) AS sno
FROM
src05.fcl_mst_v
GROUP BY
v_inst_cd
) AS max_sno_fmv
ON fmv.v_inst_cd = max_sno_fmv.v_inst_cd
AND fmv.sub_num = max_sno_fmv.sno
WHERE
vhmv.v_inst_cd_merg = fmv.v_inst_cd
AND STR_TO_DATE(vhmv.apply_dt, '%Y-%m-%d') <= src05.get_syor_date()
AND fmv.rec_sts_kbn != '9';
call medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'V施設統合マスタ（洗替処理一時テーブル）作成② 終了' );
CALL medaca_common.put_info_log(schema_name, procedure_name, procedure_args,
'V施設統合マスタ（洗替処理一時テーブル）作成② 終了' );
END