From a86e7735691ce89ae231864120990da8ca296ecc Mon Sep 17 00:00:00 2001 From: *lcOeIaePm0 Date: Wed, 22 Dec 2021 11:02:36 +0900 Subject: [PATCH 1/4] =?UTF-8?q?fix:=E7=A9=BA=E6=96=87=E5=AD=97=E3=81=AE?= =?UTF-8?q?=E3=83=87=E3=83=BC=E3=82=BF=E9=A0=85=E7=9B=AE=E3=81=8C=E6=B8=A1?= =?UTF-8?q?=E3=81=95=E3=82=8C=E3=81=9F=E6=99=82=E3=80=81NULL=E3=81=A8?= =?UTF-8?q?=E7=99=BB=E9=8C=B2=E3=81=99=E3=82=8B=E3=82=88=E3=81=86=E3=81=AB?= =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E3=81=97=E3=81=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/Dockerfile/dataimport/main.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/ecs/Dockerfile/dataimport/main.py b/ecs/Dockerfile/dataimport/main.py index d66e462c..daaca92d 100644 --- a/ecs/Dockerfile/dataimport/main.py +++ b/ecs/Dockerfile/dataimport/main.py @@ -124,8 +124,11 @@ 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)): - replace_line = line[i].replace('\\', '\\\\') - sql = f'{sql} "{replace_line}",' + if line[i]: + replace_line = line[i].replace('\\', '\\\\') + sql = f'{sql} "{replace_line}",' + else: + sql = f'{sql} NULL,' sql = f'{sql} "{target_file_name}",' # システム項目：取込ファイル名 sql = f'{sql} "{index + 1}",' # システム項目：取込ファイル行番号 sql = f'{sql} "0",' # システム項目：論理削除フラグ From a8478e4dc59d08e8c74d6f2a69ee62d3f3379cd6 Mon Sep 17 00:00:00 2001 From: *lcOeIaePm0 Date: Wed, 22 Dec 2021 14:47:35 +0900 Subject: [PATCH 2/4] =?UTF-8?q?style:=E3=82=B3=E3=83=A1=E3=83=B3=E3=83=88?= =?UTF-8?q?=E3=82=92=E8=BF=BD=E5=8A=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/Dockerfile/dataimport/main.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/ecs/Dockerfile/dataimport/main.py b/ecs/Dockerfile/dataimport/main.py index daaca92d..9be848b2 100644 --- a/ecs/Dockerfile/dataimport/main.py +++ b/ecs/Dockerfile/dataimport/main.py @@ -124,10 +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]: + # データがある場合 replace_line = line[i].replace('\\', '\\\\') sql = f'{sql} "{replace_line}",' else: + # データがない場合（空文字 / NULL） sql = f'{sql} NULL,' sql = f'{sql} "{target_file_name}",' # システム項目：取込ファイル名 sql = f'{sql} "{index + 1}",' # システム項目：取込ファイル行番号 From 3a01218715ee2d67df6eb3f5d481bc8b896d9ddd Mon Sep 17 00:00:00 2001 From: *lcOeIaePm0 Date: Fri, 24 Dec 2021 11:25:51 +0900 Subject: [PATCH 3/4] =?UTF-8?q?fix:=E3=82=B3=E3=83=A1=E3=83=B3=E3=83=88?= =?UTF-8?q?=E3=82=92=E4=BF=AE=E6=AD=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/Dockerfile/dataimport/main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ecs/Dockerfile/dataimport/main.py b/ecs/Dockerfile/dataimport/main.py index 9be848b2..0ac666ab 100644 --- a/ecs/Dockerfile/dataimport/main.py +++ b/ecs/Dockerfile/dataimport/main.py @@ -130,7 +130,7 @@ def main(bucket_name, target_data_source, target_file_name, settings_key, db_inf replace_line = line[i].replace('\\', '\\\\') sql = f'{sql} "{replace_line}",' else: - # データがない場合（空文字 / NULL） + # データがない場合（空文字 / NULL / 数値0） sql = f'{sql} NULL,' sql = f'{sql} "{target_file_name}",' # システム項目：取込ファイル名 sql = f'{sql} "{index + 1}",' # システム項目：取込ファイル行番号 From 2457d9691b4ab5351aa02e9a199395430b4c07b2 Mon Sep 17 00:00:00 2001 From: *lcOeIaePm0 Date: Fri, 24 Dec 2021 14:02:45 +0900 Subject: [PATCH 4/4] =?UTF-8?q?fix:=E3=83=AD=E3=82=B8=E3=83=83=E3=82=AF?= =?UTF-8?q?=E3=81=AEIF=E6=96=87=E3=81=A8=E3=82=B3=E3=83=A1=E3=83=B3?= =?UTF-8?q?=E3=83=88=E3=82=92=E4=BF=AE=E6=AD=A3=E3=81=97=E3=81=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ecs/Dockerfile/dataimport/main.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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}",' # システム項目：取込ファイル行番号