diff --git a/ecs/Dockerfile/dataimport/main.py b/ecs/Dockerfile/dataimport/main.py index 0ac666ab..730a7be8 100644 --- a/ecs/Dockerfile/dataimport/main.py +++ b/ecs/Dockerfile/dataimport/main.py @@ -124,13 +124,13 @@ def main(bucket_name, target_data_source, target_file_name, settings_key, db_inf sql = f'{sql} upd_date)' # システム項目:更新日時 sql = f'{sql} VALUES (' for i in range(len(line)): - # データ項目に値があるかチェックする - if line[i]: - # データがある場合 + # データ項目値が0桁より大きいかチェックする + if len(line[i]) > 0: + # 0桁より大きい場合 replace_line = line[i].replace('\\', '\\\\') sql = f'{sql} "{replace_line}",' else: - # データがない場合(空文字 / NULL / 数値0) + # 上記以外の場合 sql = f'{sql} NULL,' sql = f'{sql} "{target_file_name}",' # システム項目:取込ファイル名 sql = f'{sql} "{index + 1}",' # システム項目:取込ファイル行番号