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

feat: V施設統合マスタ（洗替処理一時テーブル）からの洗替処理(ロジック)を変更

Browse Source
This commit is contained in:
高木要 2023-04-24 17:02:39 +09:00
parent 4fc6639eea
commit d34b3bee75
1 changed files with 22 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
ecs/jskult-batch-daily/src/batch/laundering/emp_chg_inst_laundering.py
View File

@ -101,39 +101,29 @@ def _update_emp_chg_inst_lau_from_v_inst_merge_t(db: Database):
logger.info('v_inst_merge_t Table Data is exists!')
# v_inst_merge_t から、emp_chg_inst_lauをUpdateします
result = db.execute_select(
logger.debug("##########################")
logger.debug("#### UPDATE DATA #########")
logger.debug("##########################")
try:
elapsed_time = ElapsedTime()
update_sql = """
UPDATE
src05.emp_chg_inst_lau el, internal05.v_inst_merge_t vimt
SET
el.inst_cd = vimt.v_inst_cd_merge,
el.lua_ope_dt = SYSDATE()
WHERE
el.inst_cd = vimt.v_inst_cd
"""
SELECT
v_inst_cd,
v_inst_cd_merge
FROM
internal05.v_inst_merge_t
"""
)
for row in result:
v_inst_cd = row['v_inst_cd']
v_inst_cd_merge = row['v_inst_cd_merge']
try:
elapsed_time = ElapsedTime()
update_sql = """
UPDATE
src05.emp_chg_inst_lau
SET
inst_cd = :v_inst_cd_merge,
lua_ope_dt = SYSDATE()
WHERE
inst_cd = :v_inst_cd;
"""
update_result = db.execute(
update_sql,
{'v_inst_cd': v_inst_cd, 'v_inst_cd_merge': v_inst_cd_merge}
)
logging_sql(logger, update_sql)
logger.info(f'Query OK, {update_result.rowcount} rows affected ({elapsed_time.of})')
except Exception as e:
logger.debug(f"emp_chg_inst_lau v_inst_cd could not set from {v_inst_cd} to {v_inst_cd_merge}!")
raise e
logger.debug(f"Success! emp_chg_inst_lau v_inst_cd was set from {v_inst_cd} to {v_inst_cd_merge}!")
res = db.execute(update_sql)
logging_sql(logger, update_sql)
logger.info(f'Query OK, {res.rowcount} rows affected ({elapsed_time.of})')
except Exception as e:
logger.debug("emp_chg_inst_lau.v_inst_cd could not set!")
raise e
logger.debug("emp_chg_inst_lau.v_inst_cd was set!")
return