From ff69684ff69c4656bfb8ac9a5cfe2ca1649c28a0 Mon Sep 17 00:00:00 2001 From: *lcOeIaePm0 Date: Tue, 2 Nov 2021 00:06:51 +0900 Subject: [PATCH] =?UTF-8?q?fix:=E8=93=84=E7=A9=8D=E3=82=B9=E3=82=AD?= =?UTF-8?q?=E3=83=BC=E3=83=9EUPSERT=E6=99=82=E3=81=AESQL=E3=81=8C=E6=9B=B4?= =?UTF-8?q?=E6=96=B0=E3=81=97=E3=81=AA=E3=81=84=E9=A0=85=E7=9B=AE=E3=81=BE?= =?UTF-8?q?=E3=81=A7=E6=9B=B4=E6=96=B0=E3=81=97=E3=81=A6=E3=81=84=E3=81=9F?= =?UTF-8?q?=E3=81=9F=E3=82=81=E3=80=81=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 | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/ecs/Dockerfile/dataimport/main.py b/ecs/Dockerfile/dataimport/main.py index dd0a17d0..fd5053f1 100644 --- a/ecs/Dockerfile/dataimport/main.py +++ b/ecs/Dockerfile/dataimport/main.py @@ -9,6 +9,9 @@ from common import debug_log # 定数 DIRECTORY_WORK = '/work/' +DELETE_FLG = 'delete_flg' +UPDATE_USER = 'upd_user' +UPDATE_DATE = 'upd_date' LOG_LEVEL = {"i": 'Info', "e": 'Error', "w": 'Warning'} SETTINGS_ITEM = { 'dataSource': 0, @@ -150,11 +153,14 @@ def main(bucket_name, target_data_source, target_file_name, settings_key, db_inf sql = f'{sql} ON DUPLICATE KEY UPDATE' settings_db_columu_list = settings_list[SETTINGS_ITEM["dbColumuName"]].rstrip().split(',') for i in range(len(settings_db_columu_list)): - sql = f'{sql} {settings_db_columu_list[i]}=t.{settings_db_columu_list[i]},' - sql = f'{sql} file_name=t.file_name,' # システム項目：取込ファイル名 - sql = f'{sql} file_row_cnt=t.file_row_cnt,' # システム項目：取込ファイル行番号 - sql = f'{sql} ins_user=t.ins_user,' # システム項目：登録者 - sql = f'{sql} ins_date=t.ins_date' # システム項目：登録日時 + if settings_db_columu_list[i] == DELETE_FLG: + sql = f'{sql} {settings_db_columu_list[i]}={settings_list[SETTINGS_ITEM["storageSchemaName"]]}.{settings_db_columu_list[i]},' # システム項目：論理削除フラグ + elif settings_db_columu_list[i] == UPDATE_USER: + sql = f'{sql} {settings_db_columu_list[i]}={settings_list[SETTINGS_ITEM["storageSchemaName"]]}.{settings_db_columu_list[i]},' # システム項目：更新者 + elif settings_db_columu_list[i] == UPDATE_DATE: + sql = f'{sql} {settings_db_columu_list[i]}={settings_list[SETTINGS_ITEM["storageSchemaName"]]}.{settings_db_columu_list[i]}' # システム項目：更新日時 + else: + sql = f'{sql} {settings_db_columu_list[i]}=t.{settings_db_columu_list[i]},' # トランザクション開始 print(f'{datetime.now():%Y-%m-%d %H:%M:%S} {log_info} {LOG_LEVEL["i"]} I-MAIN-09 - 標準SQL：{settings_list[SETTINGS_ITEM["storageSchemaName"]]} のトランザクションを開始します')