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

style: 洗替期間変更に伴い、ログとコメントも修正。

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2023-09-25 14:18:16 +09:00
parent f3f24f0fd9
commit 44d067027c
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ecs/jskult-batch-daily/src/batch/laundering/sales_results_laundering.py
View File

@ -13,7 +13,7 @@ def exec():
db.connect() db.connect()
db.to_jst() db.to_jst()
logger.debug('処理開始') logger.debug('処理開始')
# 卸販売実績テーブル（洗替後）過去５年以前のデータ削除 # 卸販売実績テーブル（洗替後）過去データ削除
_call_sales_lau_delete(db) _call_sales_lau_delete(db)
# 卸販売実績テーブル（洗替後）作成 # 卸販売実績テーブル（洗替後）作成
_call_sales_lau_upsert(db) _call_sales_lau_upsert(db)
@ -31,7 +31,7 @@ def exec():
def _call_sales_lau_delete(db: Database): def _call_sales_lau_delete(db: Database):
# 卸販売実績テーブル（洗替後）過去５年以前のデータ削除 # 卸販売実績テーブル（洗替後）過去データ削除
logger.info('sales_lau_delete(プロシージャ―) 開始') logger.info('sales_lau_delete(プロシージャ―) 開始')
db.execute(f""" db.execute(f"""
CALL src05.sales_lau_delete( CALL src05.sales_lau_delete(

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

@ -30,7 +30,7 @@ BEGIN
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,
'卸販売実績テーブル（洗替後）過去５年以前のデータ削除① 開始'); '卸販売実績テーブル（洗替後）過去データ削除① 開始');
SET @delete_data = " SET @delete_data = "
DELETE FROM DELETE FROM
@ -44,6 +44,6 @@ BEGIN
EXECUTE delete_data_stmt USING @interval_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,
'卸販売実績テーブル（洗替後）過去５年以前のデータ削除① 終了'); '卸販売実績テーブル（洗替後）過去データ削除① 終了');
END END