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

fix: 日付テーブルのスキーマをsrc07に変更

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2025-05-19 15:04:40 +09:00
parent d48bcea8a6
commit cad2c94ff7
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -19,7 +19,7 @@ def get_batch_statuses() -> tuple[str, str]:
tuple[str, str]: [0]バッチ処理中フラグ，[1]dump取得状況区分
"""
db = Database.get_instance()
sql = 'SELECT bch_actf, dump_sts_kbn FROM src05.hdke_tbl'
sql = 'SELECT bch_actf, dump_sts_kbn FROM src07.hdke_tbl'
try:
db.connect()
hdke_tbl_result = db.execute_select(sql)
@ -47,7 +47,7 @@ def update_dump_status_kbn_in_processing() -> None:
"""
db = Database.get_instance()
sql = """\
UPDATE src05.hdke_tbl
UPDATE src07.hdke_tbl
SET
dump_sts_kbn = :in_processing,
updater = CURRENT_USER(),
@ -73,7 +73,7 @@ def update_dump_status_kbn_error() -> None:
"""
db = Database.get_instance()
sql = """\
UPDATE src05.hdke_tbl
UPDATE src07.hdke_tbl
SET
dump_sts_kbn = :dump_unprocessed,
updater = CURRENT_USER(),
@ -101,7 +101,7 @@ def update_dump_status_kbn_complete() -> None:
"""
db = Database.get_instance()
sql = """\
UPDATE src05.hdke_tbl
UPDATE src07.hdke_tbl
SET
dump_sts_kbn = :dump_unprocessed,
updater = CURRENT_USER(),