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

NEWDWH2021-1130 LOAD文のWarningはもう見ない

Browse Source
This commit is contained in:
x.azuma.m@nds-tyo.co.jp 2023-06-30 18:27:11 +09:00
parent a767457749
commit b77eab5e7c
1 changed files with 1 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
ecs/jskult-batch-daily/src/batch/vjsk/vjsk_data_load_manager.py
View File

@ -23,6 +23,7 @@ class VjskDataLoadManager:
try:
db.connect()
db.execute("SET SESSION sql_mode = 'TRADITIONAL';")
# orgをtruncate
db.execute(f"TRUNCATE TABLE {table_name_org};")
@ -37,18 +38,6 @@ class VjskDataLoadManager:
"""
db.begin()
result = db.execute(sql, {"src_file_name": src_file_name})
logger.debug(sql)
result_w = db.execute("SHOW WARNINGS;")
has_mysql_warnings = False
for row in result_w.fetchall():
# 例外スロー対象から除外 : Warning(1261) Row {ROW NUMBER} doesn't contain data for all columns
if len(row) >= 2 and row[0] == "Warning" and row[1] == 1261:
logger.info(f"SHOW WARNINGS (SKIP) : {row}")
continue
has_mysql_warnings = True
logger.info(f"SHOW WARNINGS : {row}")
if has_mysql_warnings:
raise Exception("LOAD文実行時にWARNINGが発生しました。")
logger.info(f'{data_name}tsvファイルを{table_name_org}にLOAD : 件数({result.rowcount})')
db.commit()