dm;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/adam/PlatformDMController.java

@@ -16,6 +16,8 @@ import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import java.sql.Connection;
+import java.sql.SQLException;
 import java.time.LocalDateTime;
 import java.time.temporal.ChronoField;
 import java.util.concurrent.ExecutorService;
@@ -74,20 +76,28 @@ public class PlatformDMController {
                                                     @RequestParam(required = false) String flg,
                                                     @RequestParam(required = false) String flu
     ) {
+        Connection connection = dmUserInformationProcessor.getConnection();
         log.info("===dG:{},incrDt:{},flg:{},flu:{}", dG, incrDt, flg, flu);
-        if (null != dG) {
-            ExecutorService exec = Executors.newFixedThreadPool(dG);
-            for (int i = 0; i < dG; i++) {
-                final int k = i;
-                exec.execute(() -> {
-                    log.info("==================" + k);
-                    dmUserInformationProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
-                });
-                try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+        try {
+            if (null != dG) {
+                ExecutorService exec = Executors.newFixedThreadPool(dG);
+                for (int i = 0; i < dG; i++) {
+                    final int k = i;
+                    exec.execute(() -> {
+                        log.info("==================" + k);
+                        dmUserInformationProcessor.dataProcessing(connection, k, dG, null, null, k == 0 ? "1" : "");
+                    });
+                    try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+                }
+                exec.shutdown();
+            } else {
+                dmUserInformationProcessor.dataProcessing(connection,null, null, incrDt, flg, flu);
+            }
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
             }
-            exec.shutdown();
-        } else {
-            dmUserInformationProcessor.dataProcessing(null, null, incrDt, flg, flu);
         }
         return ResponseDto.success(dG);
     }
@@ -103,19 +113,27 @@ public class PlatformDMController {
                                                    @RequestParam(required = false) String flg,
                                                    @RequestParam(required = false) String flu
     ) {
-        if (null != dG) {
-            ExecutorService exec = Executors.newFixedThreadPool(dG);
-            for (int i = 0; i < dG; i++) {
-                final int k = i;
-                exec.execute(() -> {
-                    log.info("==================" + k);
-                    dmThirdPartsProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
-                });
-                try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+        Connection connection = dmUserInformationProcessor.getConnection();
+        try {
+            if (null != dG) {
+                ExecutorService exec = Executors.newFixedThreadPool(dG);
+                for (int i = 0; i < dG; i++) {
+                    final int k = i;
+                    exec.execute(() -> {
+                        log.info("==================" + k);
+                        dmThirdPartsProcessor.dataProcessing(connection, k, dG, null, null, k == 0 ? "1" : "");
+                    });
+                    try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+                }
+                exec.shutdown();
+            } else {
+                dmThirdPartsProcessor.dataProcessing(connection,null, null, incrDt, flg, flu);
+            }
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
             }
-            exec.shutdown();
-        } else {
-            dmThirdPartsProcessor.dataProcessing(null, null, incrDt, flg, flu);
         }
         return ResponseDto.success(dG);
     }
@@ -131,19 +149,27 @@ public class PlatformDMController {
                                                     @RequestParam(required = false) String flg,
                                                     @RequestParam(required = false) String flu
     ) {
-        if (null != dG) {
-            ExecutorService exec = Executors.newFixedThreadPool(dG);
-            for (int i = 0; i < dG; i++) {
-                final int k = i;
-                exec.execute(() -> {
-                    log.info("==================" + k);
-                    dmRealNameProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
-                });
-                try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+        Connection connection = dmUserInformationProcessor.getConnection();
+        try {
+            if (null != dG) {
+                ExecutorService exec = Executors.newFixedThreadPool(dG);
+                for (int i = 0; i < dG; i++) {
+                    final int k = i;
+                    exec.execute(() -> {
+                        log.info("==================" + k);
+                        dmRealNameProcessor.dataProcessing(connection, k, dG, null, null, k == 0 ? "1" : "");
+                    });
+                    try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+                }
+                exec.shutdown();
+            } else {
+                dmRealNameProcessor.dataProcessing(connection, null, null, incrDt, flg, flu);
+            }
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
             }
-            exec.shutdown();
-        } else {
-            dmRealNameProcessor.dataProcessing(null, null, incrDt, flg, flu);
         }
         return ResponseDto.success(dG);
     }
@@ -159,19 +185,27 @@ public class PlatformDMController {
                                                        @RequestParam(required = false) String flg,
                                                        @RequestParam(required = false) String flu
     ) {
-        if (null != dG) {
-            ExecutorService exec = Executors.newFixedThreadPool(dG);
-            for (int i = 0; i < dG; i++) {
-                final int k = i;
-                exec.execute(() -> {
-                    log.info("==================" + k);
-                    dmCollectionProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
-                });
-                try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+        Connection connection = dmUserInformationProcessor.getConnection();
+        try {
+            if (null != dG) {
+                ExecutorService exec = Executors.newFixedThreadPool(dG);
+                for (int i = 0; i < dG; i++) {
+                    final int k = i;
+                    exec.execute(() -> {
+                        log.info("==================" + k);
+                        dmCollectionProcessor.dataProcessing(connection, k, dG, null, null, k == 0 ? "1" : "");
+                    });
+                    try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+                }
+                exec.shutdown();
+            } else {
+                dmCollectionProcessor.dataProcessing(connection, null, null, incrDt, flg, flu);
+            }
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
             }
-            exec.shutdown();
-        } else {
-            dmCollectionProcessor.dataProcessing(null, null, incrDt, flg, flu);
         }
         return ResponseDto.success(dG);
     }
@@ -187,19 +221,27 @@ public class PlatformDMController {
                                                       @RequestParam(required = false) String flg,
                                                       @RequestParam(required = false) String flu
     ) {
-        if (null != dG) {
-            ExecutorService exec = Executors.newFixedThreadPool(dG);
-            for (int i = 0; i < dG; i++) {
-                final int k = i;
-                exec.execute(() -> {
-                    log.info("==================" + k);
-                    dmEntersProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
-                });
-                try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+        Connection connection = dmUserInformationProcessor.getConnection();
+        try {
+            if (null != dG) {
+                ExecutorService exec = Executors.newFixedThreadPool(dG);
+                for (int i = 0; i < dG; i++) {
+                    final int k = i;
+                    exec.execute(() -> {
+                        log.info("==================" + k);
+                        dmEntersProcessor.dataProcessing(connection, k, dG, null, null, k == 0 ? "1" : "");
+                    });
+                    try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+                }
+                exec.shutdown();
+            } else {
+                dmEntersProcessor.dataProcessing(connection, null, null, incrDt, flg, flu);
+            }
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
             }
-            exec.shutdown();
-        } else {
-            dmEntersProcessor.dataProcessing(null, null, incrDt, flg, flu);
         }
         return ResponseDto.success(dG);
     }
@@ -215,19 +257,27 @@ public class PlatformDMController {
                                                     @RequestParam(required = false) String flg,
                                                     @RequestParam(required = false) String flu
     ) {
-        if (null != dG) {
-            ExecutorService exec = Executors.newFixedThreadPool(dG);
-            for (int i = 0; i < dG; i++) {
-                final int k = i;
-                exec.execute(() -> {
-                    log.info("==================" + k);
-                    dmAddressesProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
-                });
-                try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+        Connection connection = dmUserInformationProcessor.getConnection();
+        try {
+            if (null != dG) {
+                ExecutorService exec = Executors.newFixedThreadPool(dG);
+                for (int i = 0; i < dG; i++) {
+                    final int k = i;
+                    exec.execute(() -> {
+                        log.info("==================" + k);
+                        dmAddressesProcessor.dataProcessing(connection, k, dG, null, null, k == 0 ? "1" : "");
+                    });
+                    try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+                }
+                exec.shutdown();
+            } else {
+                dmAddressesProcessor.dataProcessing(connection, null, null, incrDt, flg, flu);
+            }
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
             }
-            exec.shutdown();
-        } else {
-            dmAddressesProcessor.dataProcessing(null, null, incrDt, flg, flu);
         }
         return ResponseDto.success(dG);
     }
@@ -243,19 +293,27 @@ public class PlatformDMController {
                                                    @RequestParam(required = false) String flg,
                                                    @RequestParam(required = false) String flu
     ) {
-        if (null != dG) {
-            ExecutorService exec = Executors.newFixedThreadPool(dG);
-            for (int i = 0; i < dG; i++) {
-                final int k = i;
-                exec.execute(() -> {
-                    log.info("==================" + k);
-                    dmUserMemberProcessor.dataProcessing(k, dG, null, null, k == 0 ? "1" : "");
-                });
-                try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+        Connection connection = dmUserInformationProcessor.getConnection();
+        try {
+            if (null != dG) {
+                ExecutorService exec = Executors.newFixedThreadPool(dG);
+                for (int i = 0; i < dG; i++) {
+                    final int k = i;
+                    exec.execute(() -> {
+                        log.info("==================" + k);
+                        dmUserMemberProcessor.dataProcessing(connection, k, dG, null, null, k == 0 ? "1" : "");
+                    });
+                    try { Thread.sleep(100L); } catch (InterruptedException ignored) {}
+                }
+                exec.shutdown();
+            } else {
+                dmUserMemberProcessor.dataProcessing(connection, null, null, incrDt, flg, flu);
+            }
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
             }
-            exec.shutdown();
-        } else {
-            dmUserMemberProcessor.dataProcessing(null, null, incrDt, flg, flu);
         }
         return ResponseDto.success(dG);
     }
@@ -268,7 +326,15 @@ public class PlatformDMController {
                                                       @RequestParam(required = false) String flg,
                                                       @RequestParam(required = false) String flu
     ) {
-        dmMemberOrderProcessor.dataProcessing(null, null, incrDt, flg, flu);
+        Connection connection = dmUserInformationProcessor.getConnection();
+        try {
+            dmMemberOrderProcessor.dataProcessing(connection, null, null, incrDt, flg, flu);
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
+            }
+        }
         return ResponseDto.success(dG);
     }
 
@@ -280,7 +346,15 @@ public class PlatformDMController {
                                                      @RequestParam(required = false) String flg,
                                                      @RequestParam(required = false) String flu
     ) {
-        dmMemberCodeProcessor.dataProcessing(null, null, incrDt, flg, flu);
+        Connection connection = dmUserInformationProcessor.getConnection();
+        try {
+            dmMemberCodeProcessor.dataProcessing(connection, null, null, incrDt, flg, flu);
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
+            }
+        }
         return ResponseDto.success(dG);
     }
 
@@ -292,7 +366,15 @@ public class PlatformDMController {
                                                       @RequestParam(required = false) String flg,
                                                       @RequestParam(required = false) String flu
     ) {
-        dmTracesInfoProcessor.dataProcessing(null, null, incrDt, flg, flu);
+        Connection connection = dmUserInformationProcessor.getConnection();
+        try {
+            dmTracesInfoProcessor.dataProcessing(connection, null, null, incrDt, flg, flu);
+        } finally {
+            try {
+                if (null != connection) connection.close();
+            } catch (SQLException ignored) {
+            }
+        }
         return ResponseDto.success(dG);
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/DataMigrationProcessorService.java

 package com.liquidnet.service.platform.service.impl.adam.dm;
 
 import com.liquidnet.service.adam.mapper.AdamUserMapper;
+import lombok.SneakyThrows;
 import org.springframework.beans.factory.annotation.Autowired;
 
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
@@ -36,5 +40,11 @@ public abstract class DataMigrationProcessorService {
     @Autowired
     public AdamUserMapper userMapper;
 
-    protected abstract void dataProcessing(Integer dg, Integer lS, String incrDt, String flg, String flu);
+    @SneakyThrows
+    public Connection getConnection() {
+        Class.forName(DB_DRIVER);
+        return DriverManager.getConnection(DB_URL + DB_NAME_MALL, DB_USER, DB_PWD);
+    }
+
+    protected abstract void dataProcessing(Connection connection, Integer dg, Integer lS, String incrDt, String flg, String flu);
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMAddressesProcessor.java

@@ -28,7 +28,7 @@ public class DMAddressesProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.addresses:{}", userMapper.executeForDM("adam_addresses"));
 //            log.info("DM.flush.AdamAddressesVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamAddressesVo.class.getSimpleName()).getDeletedCount());
@@ -48,12 +48,12 @@ public class DMAddressesProcessor extends DataMigrationProcessorService {
         }
         sql += " order by id limit ?,?";
 
-        Connection connection = null;
+//        Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
         try {
-            Class.forName(DB_DRIVER);
-            connection = DriverManager.getConnection(DB_URL + DB_NAME_MALL, DB_USER, DB_PWD);
+//            Class.forName(DB_DRIVER);
+//            connection = DriverManager.getConnection(DB_URL + DB_NAME_MALL, DB_USER, DB_PWD);
             statement = connection.prepareStatement(sqlCount);
             row = (ResultSetImpl) statement.executeQuery();
             row.first();
@@ -128,9 +128,9 @@ public class DMAddressesProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMCollectionProcessor.java

@@ -28,7 +28,7 @@ public class DMCollectionProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.collection:{}", userMapper.executeForDM("adam_collection"));
 
@@ -49,12 +49,12 @@ public class DMCollectionProcessor extends DataMigrationProcessorService {
         }
         sql += " order by id limit ?,?";
 
-        Connection connection = null;
+//        Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
         try {
-            Class.forName(DB_DRIVER);
-            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
+//            Class.forName(DB_DRIVER);
+//            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
             statement = connection.prepareStatement(sqlCount);
             row = (ResultSetImpl) statement.executeQuery();
             row.first();
@@ -119,9 +119,9 @@ public class DMCollectionProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMEntersProcessor.java

@@ -28,7 +28,7 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.enters:{}", userMapper.executeForDM("adam_enters"));
 
@@ -51,12 +51,12 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
         }
         sql += " order by id limit ?,?";
 
-        Connection connection = null;
+//        Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
         try {
-            Class.forName(DB_DRIVER);
-            connection = DriverManager.getConnection(DB_URL + DB_NAME_MALL, DB_USER, DB_PWD);
+//            Class.forName(DB_DRIVER);
+//            connection = DriverManager.getConnection(DB_URL + DB_NAME_MALL, DB_USER, DB_PWD);
             statement = connection.prepareStatement(sqlCount);
             row = (ResultSetImpl) statement.executeQuery();
             row.first();
@@ -132,9 +132,9 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMMemberCodeProcessor.java

@@ -182,7 +182,7 @@ public class DMMemberCodeProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.member_code:{}", userMapper.executeForDM("adam_member_code"));
 
@@ -199,12 +199,12 @@ public class DMMemberCodeProcessor extends DataMigrationProcessorService {
         String sql = sqlCount.replace("count(1)", field);
         sql += " order by id limit ?,?";
 
-        Connection connection = null;
+//        Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
         try {
-            Class.forName(DB_DRIVER);
-            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
+//            Class.forName(DB_DRIVER);
+//            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
             statement = connection.prepareStatement(sqlCount);
             row = (ResultSetImpl) statement.executeQuery();
             row.first();
@@ -283,9 +283,9 @@ public class DMMemberCodeProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMMemberOrderProcessor.java

@@ -52,7 +52,7 @@ public class DMMemberOrderProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.member_order:{}", userMapper.executeForDM("adam_member_order"));
 
@@ -74,12 +74,12 @@ public class DMMemberOrderProcessor extends DataMigrationProcessorService {
         }
         sql += " order by id limit ?,?";
 
-        Connection connection = null;
+//        Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
         try {
-            Class.forName(DB_DRIVER);
-            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
+//            Class.forName(DB_DRIVER);
+//            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
             statement = connection.prepareStatement(sqlCount);
             row = (ResultSetImpl) statement.executeQuery();
             row.first();
@@ -164,9 +164,9 @@ public class DMMemberOrderProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMRealNameProcessor.java

@@ -28,7 +28,7 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.real_name:{}", userMapper.executeForDM("adam_real_name"));
 
@@ -49,12 +49,12 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
         }
         sql += " order by id limit ?,?";
 
-        Connection connection = null;
+//        Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
         try {
-            Class.forName(DB_DRIVER);
-            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
+//            Class.forName(DB_DRIVER);
+//            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
             statement = connection.prepareStatement(sqlCount);
             row = (ResultSetImpl) statement.executeQuery();
             row.first();
@@ -131,9 +131,9 @@ public class DMRealNameProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMThirdPartsProcessor.java

@@ -30,7 +30,7 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.third_party:{}", userMapper.executeForDM("adam_third_party"));
 
@@ -54,12 +54,12 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
         sql += " order by id limit ?,?";
 
         LocalDateTime currentYear = DateUtil.Formatter.yyyyMMddHHmmss.parse("2021-01-01 00:00:00");
-        Connection connection = null;
+//        Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
         try {
-            Class.forName(DB_DRIVER);
-            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
+//            Class.forName(DB_DRIVER);
+//            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
             statement = connection.prepareStatement(sqlCount);
             row = (ResultSetImpl) statement.executeQuery();
             row.first();
@@ -140,9 +140,9 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMTracesInfoProcessor.java

@@ -32,7 +32,7 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
     AdamMemberPriceMapper memberPriceMapper;
 
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.member:{}", userMapper.executeForDM("adam_member"));
             log.info("DM.flush.member_price:{}", userMapper.executeForDM("adam_member_price"));
@@ -106,10 +106,10 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 
     @SneakyThrows
@@ -165,10 +165,10 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 
     @SneakyThrows
@@ -207,10 +207,10 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 
     private void setRdsCache() {

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMUserInformationProcessor.java

@@ -47,7 +47,7 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.user:{}", userMapper.executeForDM("adam_user"));
             log.info("DM.flush.user_info:{}", userMapper.executeForDM("adam_user_info"));
@@ -71,12 +71,12 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
         sql += " order by uid limit ?,?";
 
         LocalDateTime currentYear = DateUtil.Formatter.yyyyMMddHHmmss.parse("2021-01-01 00:00:00");
-        Connection connection = null;
+//        Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
         try {
             Class.forName(DB_DRIVER);
-            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
+//            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
             statement = connection.prepareStatement(sqlCount);
             row = (ResultSetImpl) statement.executeQuery();
             row.first();
@@ -180,9 +180,9 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMUserMemberProcessor.java

@@ -28,7 +28,7 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
 
     @SneakyThrows
     @Override
-    public void dataProcessing(Integer dg, Integer dG, String incrDt, String flg, String flu) {
+    public void dataProcessing(Connection connection, Integer dg, Integer dG, String incrDt, String flg, String flu) {
         if (StringUtils.isNotEmpty(flu)) {
             log.info("DM.flush.user_member:{}", userMapper.executeForDM("adam_user_member"));
 
@@ -49,12 +49,12 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
         }
         sql += " order by id limit ?,?";
 
-        Connection connection = null;
+//        Connection connection = null;
         PreparedStatement statement = null;
         ResultSetImpl row = null;
         try {
-            Class.forName(DB_DRIVER);
-            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
+//            Class.forName(DB_DRIVER);
+//            connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
             statement = connection.prepareStatement(sqlCount);
             row = (ResultSetImpl) statement.executeQuery();
             row.first();
@@ -137,9 +137,9 @@ public class DMUserMemberProcessor extends DataMigrationProcessorService {
             if (null != statement) statement.close();
         } catch (SQLException ignored) {
         }
-        try {
-            if (null != connection) connection.close();
-        } catch (SQLException ignored) {
-        }
+//        try {
+//            if (null != connection) connection.close();
+//        } catch (SQLException ignored) {
+//        }
     }
 }