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

fix: 日付テーブル更新時に、更新者と更新日時を上書きしていなかったのを修正。

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2023-07-31 13:48:36 +09:00
parent 4fc66bf48d
commit 39907c1ede
2 changed files with 23 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ecs/jskult-batch-daily/src/batch/batch_functions.py
View File

@ -51,7 +51,13 @@ def update_batch_processing_flag_in_processing() -> None:
BatchOperationException: DB操作の何らかのエラー
"""
db = Database.get_instance()
sql = 'UPDATE src05.hdke_tbl SET bch_actf = :in_processing'
sql = """\
UPDATE src05.hdke_tbl
SET
bch_actf = :in_processing,
updater = CURRENT_USER(),
update_date = NOW()
"""
try:
db.connect()
db.execute(sql, {'in_processing': constants.BATCH_ACTF_BATCH_IN_PROCESSING})
@ -75,7 +81,9 @@ def update_batch_process_complete() -> None:
SET
bch_actf = :batch_complete,
dump_sts_kbn = :dump_unprocessed,
syor_date = DATE_FORMAT((src05.get_syor_date() + interval 1 day), '%Y%m%d') -- +1日
syor_date = DATE_FORMAT((src05.get_syor_date() + interval 1 day), '%Y%m%d'), -- +1日
updater = CURRENT_USER(),
update_date = NOW()
"""
try:
db.connect()

16
ecs/jskult-dbdump/src/batch/batch_functions.py
View File

@ -46,7 +46,13 @@ def update_dump_status_kbn_in_processing() -> None:
BatchOperationException: DB操作の何らかのエラー
"""
db = Database.get_instance()
sql = 'UPDATE src05.hdke_tbl SET dump_sts_kbn = :in_processing'
sql = """\
UPDATE src05.hdke_tbl
SET
dump_sts_kbn = :in_processing,
updater = CURRENT_USER(),
update_date = NOW()
"""
try:
db.connect()
db.execute(sql, {'in_processing': constants.BATCH_ACTF_BATCH_IN_PROCESSING})
@ -68,7 +74,9 @@ def update_dump_status_kbn_error() -> None:
sql = """\
UPDATE src05.hdke_tbl
SET
dump_sts_kbn = :dump_unprocessed
dump_sts_kbn = :dump_unprocessed,
updater = CURRENT_USER(),
update_date = NOW()
"""
try:
db.connect()
@ -93,7 +101,9 @@ def update_dump_status_kbn_complete() -> None:
sql = """\
UPDATE src05.hdke_tbl
SET
dump_sts_kbn = :dump_unprocessed
dump_sts_kbn = :dump_unprocessed,
updater = CURRENT_USER(),
update_date = NOW()
"""
try:
db.connect()