From d34b3bee7581901bb9eb00a3c99c433c77f97a89 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=AB=98=E6=9C=A8=E8=A6=81?= <x.takagi.k@nds-tyo.co.jp>
Date: Mon, 24 Apr 2023 17:02:39 +0900
Subject: [PATCH] =?UTF-8?q?feat:=20V=E6=96=BD=E8=A8=AD=E7=B5=B1=E5=90=88?=
 =?UTF-8?q?=E3=83=9E=E3=82=B9=E3=82=BF=EF=BC=88=E6=B4=97=E6=9B=BF=E5=87=A6?=
 =?UTF-8?q?=E7=90=86=E4=B8=80=E6=99=82=E3=83=86=E3=83=BC=E3=83=96=E3=83=AB?=
 =?UTF-8?q?=EF=BC=89=E3=81=8B=E3=82=89=E3=81=AE=E6=B4=97=E6=9B=BF=E5=87=A6?=
 =?UTF-8?q?=E7=90=86(=E3=83=AD=E3=82=B8=E3=83=83=E3=82=AF)=E3=82=92?=
 =?UTF-8?q?=E5=A4=89=E6=9B=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../laundering/emp_chg_inst_laundering.py     | 54 ++++++++-----------
 1 file changed, 22 insertions(+), 32 deletions(-)

diff --git a/ecs/jskult-batch-daily/src/batch/laundering/emp_chg_inst_laundering.py b/ecs/jskult-batch-daily/src/batch/laundering/emp_chg_inst_laundering.py
index a9d5f1f3..f78ece9b 100644
--- a/ecs/jskult-batch-daily/src/batch/laundering/emp_chg_inst_laundering.py
+++ b/ecs/jskult-batch-daily/src/batch/laundering/emp_chg_inst_laundering.py
@@ -101,39 +101,29 @@ def _update_emp_chg_inst_lau_from_v_inst_merge_t(db: Database):
 
     logger.info('v_inst_merge_t Table Data is exists!')
     # v_inst_merge_t から、emp_chg_inst_lauをUpdateします
-    result = db.execute_select(
+    logger.debug("##########################")
+    logger.debug("#### UPDATE DATA #########")
+    logger.debug("##########################")
+    try:
+        elapsed_time = ElapsedTime()
+        update_sql = """
+            UPDATE
+                src05.emp_chg_inst_lau el, internal05.v_inst_merge_t vimt
+            SET
+                el.inst_cd = vimt.v_inst_cd_merge,
+                el.lua_ope_dt = SYSDATE()
+            WHERE
+                el.inst_cd = vimt.v_inst_cd
         """
-        SELECT
-            v_inst_cd,
-            v_inst_cd_merge
-        FROM
-            internal05.v_inst_merge_t
-        """
-    )
-    for row in result:
-        v_inst_cd = row['v_inst_cd']
-        v_inst_cd_merge = row['v_inst_cd_merge']
-        try:
-            elapsed_time = ElapsedTime()
-            update_sql = """
-                UPDATE
-                    src05.emp_chg_inst_lau
-                SET
-                    inst_cd = :v_inst_cd_merge,
-                    lua_ope_dt = SYSDATE()
-                WHERE
-                    inst_cd = :v_inst_cd;
-            """
-            update_result = db.execute(
-                update_sql,
-                {'v_inst_cd': v_inst_cd, 'v_inst_cd_merge': v_inst_cd_merge}
-            )
-            logging_sql(logger, update_sql)
-            logger.info(f'Query OK, {update_result.rowcount} rows affected ({elapsed_time.of})')
-        except Exception as e:
-            logger.debug(f"emp_chg_inst_lau v_inst_cd could not set from {v_inst_cd} to {v_inst_cd_merge}!")
-            raise e
-        logger.debug(f"Success! emp_chg_inst_lau v_inst_cd was set from {v_inst_cd} to {v_inst_cd_merge}!")
+        res = db.execute(update_sql)
+        logging_sql(logger, update_sql)
+        logger.info(f'Query OK, {res.rowcount} rows affected ({elapsed_time.of})')
+    except Exception as e:
+        logger.debug("emp_chg_inst_lau.v_inst_cd could not set!")
+        raise e
+
+    logger.debug("emp_chg_inst_lau.v_inst_cd was set!")
+
     return