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

Merge pull request #100 feature-NEWDWH2021-678 into develop-6crm

Browse Source
This commit is contained in:
朝倉 明日香 2022-09-16 11:29:24 +09:00
commit 9e785c53ed
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
ecs/dataimport/dataimport/main.py
View File

@ -129,6 +129,7 @@ def main(bucket_name, target_data_source, target_file_name, settings_key, db_inf
process_count += 1
# SQL文生成
query_parameter_list = []
sql = f'INSERT INTO {settings_list[SETTINGS_ITEM["loadSchemaName"]]} ('
for i in range(len(settings_db_columu_list)):
sql = f'{sql} {settings_db_columu_list[i]},'
@ -144,9 +145,9 @@ def main(bucket_name, target_data_source, target_file_name, settings_key, db_inf
# データ項目値が0桁より大きいかチェックする
if len(line[i]) > 0:
# 0桁より大きい場合
replace_line = line[i].replace('\\', '\\\\')
replace_line = line[i].replace('"', '\\"')
sql = f'{sql} "{replace_line}",'
# INSERT文のパラメータとそれに対応するプレースホルダーを設定する
query_parameter_list.append(line[i])
sql = f'{sql} %s,'
else:
# 上記以外の場合
sql = f'{sql} NULL,'
@ -164,7 +165,7 @@ def main(bucket_name, target_data_source, target_file_name, settings_key, db_inf
# ロードスキーマのトランザクション開始
with conn.cursor() as cur:
cur.execute(sql)
cur.execute(sql, query_parameter_list)
conn.commit()
normal_count += 1
except Exception as e: