Commit @12accd86eb72a4918a17dc96ab9f3c4ccf7aafbc

dsjang 2024-08-12

Multi DBMS 설정 추가, 발송 성능 개선, 리포트 수신 개선

@12accd86eb72a4918a17dc96ab9f3c4ccf7aafbc

b517754

12accd8

build.gradle

--- build.gradle

+++ build.gradle


 
 repositories {
     mavenCentral()
+    maven {url 'https://maven.google.com'}
+    maven {url 'https://maven.cubrid.org/'}
+    maven {url 'https://maven.jumpmind.com/repo/'}
 }
 
 dependencies {

     implementation group: 'com.microsoft.sqlserver', name: 'mssql-jdbc', version: '12.8.0.jre11'
     // https://mvnrepository.com/artifact/org.postgresql/postgresql
     implementation group: 'org.postgresql', name: 'postgresql', version: '42.7.3'
+    // https://mvnrepository.com/artifact/cubrid/cubrid-jdbc
+    implementation group: 'cubrid', name: 'cubrid-jdbc', version: '11.2.1.0038'
+    // https://mvnrepository.com/artifact/jdbc.tibero/tibero
+    //implementation files('libs/tibero6-jdbc-14.jar')
+    implementation files('libs/tibero-6.jar')
 
 }
 

12accd8

libs/tibero-6.jar (Binary) (added)

+++ libs/tibero-6.jar

Binary file is not shown

12accd8

libs/tibero6-jdbc-14.jar (Binary) (added)

+++ libs/tibero6-jdbc-14.jar

Binary file is not shown

12accd8

src/main/java/com/munjaon/client/cubrid/mapper/CubridMapper.java (added)

+++ src/main/java/com/munjaon/client/cubrid/mapper/CubridMapper.java

...	...	@@ -0,0 +1,21 @@
	1	+package com.munjaon.client.cubrid.mapper;
	2	+
	3	+import com.munjaon.client.model.MunjaonMsg;
	4	+import org.apache.ibatis.annotations.Mapper;
	5	+
	6	+import java.util.List;
	7	+
	8	+@Mapper
	9	+public interface CubridMapper {
	10	+ String checkTime();
	11	+ int checkTableForMessage();
	12	+ int checkTableForLog();
	13	+ List<MunjaonMsg> selectToDeliver(String msgType);
	14	+ int updateToDeliver(String msgId);
	15	+ int updateDeliverForList(List<String> msgIdList);
	16	+ int updateToReport(MunjaonMsg params);
	17	+ List<MunjaonMsg> selectToMove();
	18	+ List<MunjaonMsg> selectToExpire(String expireTime);
	19	+ int insertToLog(String msgId);
	20	+ int deleteFromDeliver(String msgId);
	21	+}

12accd8

src/main/java/com/munjaon/client/cubrid/service/CubridService.java (added)

+++ src/main/java/com/munjaon/client/cubrid/service/CubridService.java

...	...	@@ -0,0 +1,69 @@
	1	+package com.munjaon.client.cubrid.service;
	2	+
	3	+import com.munjaon.client.cubrid.mapper.CubridMapper;
	4	+import com.munjaon.client.model.MunjaonMsg;
	5	+import lombok.RequiredArgsConstructor;
	6	+import lombok.extern.slf4j.Slf4j;
	7	+import org.springframework.stereotype.Service;
	8	+import org.springframework.transaction.annotation.Transactional;
	9	+
	10	+import java.util.List;
	11	+
	12	+@Slf4j
	13	+@Service
	14	+@RequiredArgsConstructor
	15	+public class CubridService {
	16	+ private final CubridMapper deliverBMapper;
	17	+
	18	+ public boolean checkTableExists() {
	19	+ boolean isExist = false;
	20	+ try {
	21	+ int msgCount = deliverBMapper.checkTableForMessage();
	22	+ int logCount = deliverBMapper.checkTableForLog();
	23	+ if (msgCount >= 0 && logCount >= 0) {
	24	+ isExist = true;
	25	+ }
	26	+ } catch (Exception e) {
	27	+ log.error("Check table exists error : {}", e);
	28	+ }
	29	+
	30	+ return isExist;
	31	+ }
	32	+ public List<MunjaonMsg> selectToDeliver(String msgType) {
	33	+ return deliverBMapper.selectToDeliver(msgType);
	34	+ }
	35	+ public int updateToDeliver(String msgId) {
	36	+ return deliverBMapper.updateToDeliver(msgId);
	37	+ }
	38	+ public int updateDeliverForList(List<String> msgIdList) {
	39	+ return deliverBMapper.updateDeliverForList(msgIdList);
	40	+ }
	41	+ public int updateToReport(MunjaonMsg params) {
	42	+ return deliverBMapper.updateToReport(params);
	43	+ }
	44	+ public List<MunjaonMsg> selectToMove() {
	45	+ return deliverBMapper.selectToMove();
	46	+ }
	47	+ public List<MunjaonMsg> selectToExpire(String expireTime) {
	48	+ return deliverBMapper.selectToExpire(expireTime);
	49	+ }
	50	+ public int insertToLog(String msgId) {
	51	+ return deliverBMapper.insertToLog(msgId);
	52	+ }
	53	+ public int deleteFromDeliver(String msgId) {
	54	+ return deliverBMapper.deleteFromDeliver(msgId);
	55	+ }
	56	+
	57	+ @Transactional
	58	+ public void moveToDeliver() {
	59	+ List<MunjaonMsg> list = selectToMove();
	60	+ if (list == null \|\| list.size() == 0) {
	61	+ return;
	62	+ }
	63	+ log.debug("[CLASS : {} : MOVE_COUNT : {}", this.getClass(), list.size());
	64	+ for (MunjaonMsg msg : list) {
	65	+ insertToLog(msg.getMsgId());
	66	+ deleteFromDeliver(msg.getMsgId());
	67	+ }
	68	+ }
	69	+}

b517754

12accd8

src/main/java/com/munjaon/client/mariadb/mapper/MariaDBMapper.java

--- src/main/java/com/munjaon/client/mariadb/mapper/MariaDBMapper.java

+++ src/main/java/com/munjaon/client/mariadb/mapper/MariaDBMapper.java


     int checkTableForLog();
     List<MunjaonMsg> selectToDeliver(String msgType);
     int updateToDeliver(String msgId);
+    int updateDeliverForList(List<String> msgIdList);
     int updateToReport(MunjaonMsg params);
     List<MunjaonMsg> selectToMove();
     List<MunjaonMsg> selectToExpire(String expireTime);

b517754

12accd8

src/main/java/com/munjaon/client/mariadb/service/MariaDBService.java

--- src/main/java/com/munjaon/client/mariadb/service/MariaDBService.java

+++ src/main/java/com/munjaon/client/mariadb/service/MariaDBService.java


     public int updateToDeliver(String msgId) {
         return deliverBMapper.updateToDeliver(msgId);
     }
+    public int updateDeliverForList(List<String> msgIdList) {
+        return deliverBMapper.updateDeliverForList(msgIdList);
+    }
     public int updateToReport(MunjaonMsg params) {
         return deliverBMapper.updateToReport(params);
     }

b517754

12accd8

src/main/java/com/munjaon/client/mssql/mapper/MssqlMapper.java

--- src/main/java/com/munjaon/client/mssql/mapper/MssqlMapper.java

+++ src/main/java/com/munjaon/client/mssql/mapper/MssqlMapper.java


     int checkTableForLog();
     List<MunjaonMsg> selectToDeliver(String msgType);
     int updateToDeliver(String msgId);
+    int updateDeliverForList(List<String> msgIdList);
     int updateToReport(MunjaonMsg params);
     List<MunjaonMsg> selectToMove();
     List<MunjaonMsg> selectToExpire(String expireTime);

b517754

12accd8

src/main/java/com/munjaon/client/mssql/service/MssqlService.java

--- src/main/java/com/munjaon/client/mssql/service/MssqlService.java

+++ src/main/java/com/munjaon/client/mssql/service/MssqlService.java


     public int updateToDeliver(String msgId) {
         return deliverBMapper.updateToDeliver(msgId);
     }
+    public int updateDeliverForList(List<String> msgIdList) {
+        return deliverBMapper.updateDeliverForList(msgIdList);
+    }
     public int updateToReport(MunjaonMsg params) {
         return deliverBMapper.updateToReport(params);
     }

b517754

12accd8

src/main/java/com/munjaon/client/mysql/mapper/MysqlMapper.java

--- src/main/java/com/munjaon/client/mysql/mapper/MysqlMapper.java

+++ src/main/java/com/munjaon/client/mysql/mapper/MysqlMapper.java


     int checkTableForLog();
     List<MunjaonMsg> selectToDeliver(String msgType);
     int updateToDeliver(String msgId);
+    int updateDeliverForList(List<String> msgIdList);
     int updateToReport(MunjaonMsg params);
     List<MunjaonMsg> selectToMove();
     List<MunjaonMsg> selectToExpire(String expireTime);

b517754

12accd8

src/main/java/com/munjaon/client/mysql/service/MysqlService.java

--- src/main/java/com/munjaon/client/mysql/service/MysqlService.java

+++ src/main/java/com/munjaon/client/mysql/service/MysqlService.java


     public int updateToDeliver(String msgId) {
         return deliverBMapper.updateToDeliver(msgId);
     }
+    public int updateDeliverForList(List<String> msgIdList) {
+        return deliverBMapper.updateDeliverForList(msgIdList);
+    }
     public int updateToReport(MunjaonMsg params) {
         return deliverBMapper.updateToReport(params);
     }

b517754

12accd8

src/main/java/com/munjaon/client/oracle/mapper/OracleMapper.java

--- src/main/java/com/munjaon/client/oracle/mapper/OracleMapper.java

+++ src/main/java/com/munjaon/client/oracle/mapper/OracleMapper.java


     int checkTableForLog();
     List<MunjaonMsg> selectToDeliver(String msgType);
     int updateToDeliver(String msgId);
+    int updateDeliverForList(List<String> msgIdList);
     int updateToReport(MunjaonMsg params);
     List<MunjaonMsg> selectToMove();
     List<MunjaonMsg> selectToExpire(String expireTime);

b517754

12accd8

src/main/java/com/munjaon/client/oracle/service/OracleService.java

--- src/main/java/com/munjaon/client/oracle/service/OracleService.java

+++ src/main/java/com/munjaon/client/oracle/service/OracleService.java


     public int updateToDeliver(String msgId) {
         return deliverBMapper.updateToDeliver(msgId);
     }
+    public int updateDeliverForList(List<String> msgIdList) {
+        return deliverBMapper.updateDeliverForList(msgIdList);
+    }
     public int updateToReport(MunjaonMsg params) {
         return deliverBMapper.updateToReport(params);
     }

b517754

12accd8

src/main/java/com/munjaon/client/postgresql/mapper/PostgresqlMapper.java

--- src/main/java/com/munjaon/client/postgresql/mapper/PostgresqlMapper.java

+++ src/main/java/com/munjaon/client/postgresql/mapper/PostgresqlMapper.java


     int checkTableForLog();
     List<MunjaonMsg> selectToDeliver(String msgType);
     int updateToDeliver(String msgId);
+    int updateDeliverForList(List<String> msgIdList);
     int updateToReport(MunjaonMsg params);
     List<MunjaonMsg> selectToMove();
     List<MunjaonMsg> selectToExpire(String expireTime);

b517754

12accd8

src/main/java/com/munjaon/client/postgresql/service/PostgresqlService.java

--- src/main/java/com/munjaon/client/postgresql/service/PostgresqlService.java

+++ src/main/java/com/munjaon/client/postgresql/service/PostgresqlService.java


     public int updateToDeliver(String msgId) {
         return deliverBMapper.updateToDeliver(msgId);
     }
+    public int updateDeliverForList(List<String> msgIdList) {
+        return deliverBMapper.updateDeliverForList(msgIdList);
+    }
     public int updateToReport(MunjaonMsg params) {
         return deliverBMapper.updateToReport(params);
     }

b517754

12accd8

src/main/java/com/munjaon/client/server/service/CollectClientService.java

--- src/main/java/com/munjaon/client/server/service/CollectClientService.java

+++ src/main/java/com/munjaon/client/server/service/CollectClientService.java


 import java.net.InetSocketAddress;
 import java.nio.ByteBuffer;
 import java.nio.channels.SocketChannel;
+import java.util.ArrayList;
 import java.util.List;
 
 public class CollectClientService extends Service {

     private int port;
     private String id;
     private String pwd;
+
+    private StringBuilder deliverBuilder;
+    private List<String> deliverList = null;
 
     public CollectClientService(String serviceName, String serviceType) {
         super(serviceName);

             return;
         }
 
-        saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
         this.IS_READY_YN = worker.checkTableExists();
+        if (this.IS_READY_YN) {
+            saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
+        } else {
+            saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is not ready]");
+        }
     }
 
     @Override

         return null;
     }
 
+    private void setDeliverMsgId(String msgId) {
+        if (msgId == null) {
+            return;
+        }
+        if (this.deliverList == null) {
+            this.deliverList = new ArrayList<>();
+        }
+        this.deliverList.add(msgId);
+//        if (this.deliverBuilder == null) {
+//            return;
+//        }
+//
+//        if (this.deliverBuilder.isEmpty()) {
+//            this.deliverBuilder.append(msgId);
+//        } else {
+//            this.deliverBuilder.append(",").append(msgId);
+//        }
+    }
+
     private void messageService() {
         List<MunjaonMsg> list = selectToDeliver();
+        this.deliverBuilder = new StringBuilder();
         if (list == null || list.isEmpty()) {
             try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}
             return;

                 case "KFT": kftMessageService(data); break;
                 default:break;
             }
+        }
+        if (this.deliverList != null && this.deliverList.size() > 0) {
+            worker.updateDeliverForList(this.deliverList);
+            this.deliverList = null;    // NULL로 초기화
         }
     }
 

                     saveSystemLog("[MESSAGE SEND] [FAIL] [SOCKET IS CLOSED]");
                     throw new RuntimeException("DELIVER ERROR");
                 } else if (recvCount > 0) {
-                    worker.updateToDeliver(data.getMsgId());
+                    setDeliverMsgId(data.getMsgId());
+//                    worker.updateToDeliver(data.getMsgId());
                     saveSystemLog("[MESSAGE SEND] [SUCCESS]");
                     lastPacketSendTime = System.currentTimeMillis();
                     break;
                 }
             }
         } catch (IOException e) {
-            throw new RuntimeException(e);
+            e.printStackTrace();
+//            throw new RuntimeException(e);
         }
     }
 

b517754

12accd8

src/main/java/com/munjaon/client/server/service/DataMoveService.java

--- src/main/java/com/munjaon/client/server/service/DataMoveService.java

+++ src/main/java/com/munjaon/client/server/service/DataMoveService.java


             return;
         }
 
-        saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
         this.IS_READY_YN = worker.checkTableExists();
+        if (this.IS_READY_YN) {
+            saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
+        } else {
+            saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is not ready]");
+        }
     }
 
     @Override

b517754

12accd8

src/main/java/com/munjaon/client/server/service/ReportClientService.java

--- src/main/java/com/munjaon/client/server/service/ReportClientService.java

+++ src/main/java/com/munjaon/client/server/service/ReportClientService.java


             return;
         }
 
-        saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
         this.IS_READY_YN = worker.checkTableExists();
+        if (this.IS_READY_YN) {
+            saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
+        } else {
+            saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is not ready]");
+        }
     }
 
     @Override

b517754

12accd8

src/main/java/com/munjaon/client/service/DatabaseService.java

--- src/main/java/com/munjaon/client/service/DatabaseService.java

+++ src/main/java/com/munjaon/client/service/DatabaseService.java


 
 @Getter
 public enum DatabaseService {
+    CUBRID_SERVICE,
     MARIADB_SERVICE,
     MSSQL_SERVICE,
     ORACLE_SERVICE,
     POSTGRESQL_SERVICE,
-    MYSQL_SERVICE;
+    MYSQL_SERVICE,
+    TIBERO_SERVICE;
 
     private Object service;
 

b517754

12accd8

src/main/java/com/munjaon/client/service/DatabaseServiceInjector.java

--- src/main/java/com/munjaon/client/service/DatabaseServiceInjector.java

+++ src/main/java/com/munjaon/client/service/DatabaseServiceInjector.java


 package com.munjaon.client.service;
 
+import com.munjaon.client.cubrid.service.CubridService;
 import com.munjaon.client.mariadb.service.MariaDBService;
 import com.munjaon.client.mssql.service.MssqlService;
 import com.munjaon.client.mysql.service.MysqlService;
 import com.munjaon.client.oracle.service.OracleService;
 import com.munjaon.client.postgresql.service.PostgresqlService;
+import com.munjaon.client.tibero.service.TiberoService;
 import jakarta.annotation.PostConstruct;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;

 
 @Component
 public class DatabaseServiceInjector {
+    @Autowired
+    private CubridService cubridService;
     @Autowired
     private MariaDBService mariaDBService;
     @Autowired

     private OracleService oracleService;
     @Autowired
     private PostgresqlService postgresqlService;
+    @Autowired
+    private TiberoService tiberoService;
 
     @PostConstruct
     public void postConstruct() {
         for (DatabaseService svc : EnumSet.allOf(DatabaseService.class)) {
             switch (svc) {
+                case CUBRID_SERVICE:        svc.setService(cubridService);
+                    break;
                 case MARIADB_SERVICE:       svc.setService(mariaDBService);
                     break;
                 case MSSQL_SERVICE:         svc.setService(mssqlService);

                     break;
                 case POSTGRESQL_SERVICE : svc.setService(postgresqlService);
                     break;
+                case TIBERO_SERVICE:        svc.setService(tiberoService);
+                    break;
                 default:                    break;
             }
         }

b517754

12accd8

src/main/java/com/munjaon/client/service/DatabaseTypeWorker.java

--- src/main/java/com/munjaon/client/service/DatabaseTypeWorker.java

+++ src/main/java/com/munjaon/client/service/DatabaseTypeWorker.java


 package com.munjaon.client.service;
 
+import com.munjaon.client.cubrid.service.CubridService;
 import com.munjaon.client.mariadb.service.MariaDBService;
 import com.munjaon.client.model.MunjaonMsg;
 import com.munjaon.client.mssql.service.MssqlService;
 import com.munjaon.client.mysql.service.MysqlService;
 import com.munjaon.client.oracle.service.OracleService;
 import com.munjaon.client.postgresql.service.PostgresqlService;
+import com.munjaon.client.tibero.service.TiberoService;
 import lombok.Getter;
 
 import java.util.EnumSet;

 
 @Getter
 public enum DatabaseTypeWorker {
+    TYPE_OF_CUBRID("CUBRID") {
+        @Override
+        public boolean checkTableExists() {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            return cubridService.checkTableExists();
+        }
+
+        @Override
+        public List<MunjaonMsg> selectToDeliver(String msgType) {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            return cubridService.selectToDeliver(msgType);
+        }
+
+        @Override
+        public int updateToDeliver(String msgId) {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            return cubridService.updateToDeliver(msgId);
+        }
+
+        @Override
+        public int updateDeliverForList(List<String> msgIdList) {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            return cubridService.updateDeliverForList(msgIdList);
+        }
+
+        @Override
+        public int updateToReport(MunjaonMsg params) {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            return cubridService.updateToReport(params);
+        }
+
+        @Override
+        public List<MunjaonMsg> selectToMove() {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            return cubridService.selectToMove();
+        }
+
+        @Override
+        public List<MunjaonMsg> selectToExpire(String expireTime) {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            return cubridService.selectToExpire(expireTime);
+        }
+
+        @Override
+        public int insertToLog(String msgId) {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            return cubridService.insertToLog(msgId);
+        }
+
+        @Override
+        public int deleteFromDeliver(String msgId) {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            return cubridService.deleteFromDeliver(msgId);
+        }
+
+        @Override
+        public void moveToDeliver() {
+            CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
+            cubridService.moveToDeliver();
+        }
+    },
     TYPE_OF_MARIADB("MARIADB") {
         @Override
         public boolean checkTableExists() {

         public int updateToDeliver(String msgId) {
             MariaDBService mariaDBService = (MariaDBService) DatabaseService.MARIADB_SERVICE.getService();
             return mariaDBService.updateToDeliver(msgId);
+        }
+
+        @Override
+        public int updateDeliverForList(List<String> msgIdList) {
+            MariaDBService mariaDBService = (MariaDBService) DatabaseService.MARIADB_SERVICE.getService();
+            return mariaDBService.updateDeliverForList(msgIdList);
         }
 
         @Override

         }
 
         @Override
+        public int updateDeliverForList(List<String> msgIdList) {
+            OracleService oracleService = (OracleService) DatabaseService.ORACLE_SERVICE.getService();
+            return oracleService.updateDeliverForList(msgIdList);
+        }
+
+        @Override
         public int updateToReport(MunjaonMsg params) {
             OracleService oracleService = (OracleService) DatabaseService.ORACLE_SERVICE.getService();
             return oracleService.updateToReport(params);

         public int updateToDeliver(String msgId) {
             MssqlService mssqlService = (MssqlService) DatabaseService.MSSQL_SERVICE.getService();
             return mssqlService.updateToDeliver(msgId);
+        }
+
+        @Override
+        public int updateDeliverForList(List<String> msgIdList) {
+            MssqlService mssqlService = (MssqlService) DatabaseService.MSSQL_SERVICE.getService();
+            return mssqlService.updateDeliverForList(msgIdList);
         }
 
         @Override

         }
 
         @Override
+        public int updateDeliverForList(List<String> msgIdList) {
+            PostgresqlService postgresqlService = (PostgresqlService) DatabaseService.POSTGRESQL_SERVICE.getService();
+            return postgresqlService.updateDeliverForList(msgIdList);
+        }
+
+        @Override
         public int updateToReport(MunjaonMsg params) {
             PostgresqlService postgresqlService = (PostgresqlService) DatabaseService.POSTGRESQL_SERVICE.getService();
             return postgresqlService.updateToReport(params);

         }
 
         @Override
+        public int updateDeliverForList(List<String> msgIdList) {
+            MysqlService mysqlService = (MysqlService) DatabaseService.MYSQL_SERVICE.getService();
+            return mysqlService.updateDeliverForList(msgIdList);
+        }
+
+        @Override
         public int updateToReport(MunjaonMsg params) {
             MysqlService mysqlService = (MysqlService) DatabaseService.MYSQL_SERVICE.getService();
             return mysqlService.updateToReport(params);

             MysqlService mysqlService = (MysqlService) DatabaseService.MYSQL_SERVICE.getService();
             mysqlService.moveToDeliver();
         }
+    },
+    TYPE_OF_TIBERO("TIBERO") {
+        @Override
+        public boolean checkTableExists() {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            return tiberoService.checkTableExists();
+        }
+
+        @Override
+        public List<MunjaonMsg> selectToDeliver(String msgType) {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            return tiberoService.selectToDeliver(msgType);
+        }
+
+        @Override
+        public int updateToDeliver(String msgId) {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            return tiberoService.updateToDeliver(msgId);
+        }
+
+        @Override
+        public int updateDeliverForList(List<String> msgIdList) {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            return tiberoService.updateDeliverForList(msgIdList);
+        }
+
+        @Override
+        public int updateToReport(MunjaonMsg params) {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            return tiberoService.updateToReport(params);
+        }
+
+        @Override
+        public List<MunjaonMsg> selectToMove() {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            return tiberoService.selectToMove();
+        }
+
+        @Override
+        public List<MunjaonMsg> selectToExpire(String expireTime) {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            return tiberoService.selectToExpire(expireTime);
+        }
+
+        @Override
+        public int insertToLog(String msgId) {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            return tiberoService.insertToLog(msgId);
+        }
+
+        @Override
+        public int deleteFromDeliver(String msgId) {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            return tiberoService.deleteFromDeliver(msgId);
+        }
+
+        @Override
+        public void moveToDeliver() {
+            TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
+            tiberoService.moveToDeliver();
+        }
     };
 
     DatabaseTypeWorker(final String name) {

     public abstract boolean checkTableExists();
     public abstract List<MunjaonMsg> selectToDeliver(String msgType);
     public abstract int updateToDeliver(String msgId);
+    public abstract int updateDeliverForList(List<String> msgIdList);;
     public abstract int updateToReport(MunjaonMsg params);
     public abstract List<MunjaonMsg> selectToMove();
     public abstract List<MunjaonMsg> selectToExpire(String expireTime);

12accd8

src/main/java/com/munjaon/client/tibero/mapper/TiberoMapper.java (added)

+++ src/main/java/com/munjaon/client/tibero/mapper/TiberoMapper.java

...	...	@@ -0,0 +1,21 @@
	1	+package com.munjaon.client.tibero.mapper;
	2	+
	3	+import com.munjaon.client.model.MunjaonMsg;
	4	+import org.apache.ibatis.annotations.Mapper;
	5	+
	6	+import java.util.List;
	7	+
	8	+@Mapper
	9	+public interface TiberoMapper {
	10	+ String checkTime();
	11	+ int checkTableForMessage();
	12	+ int checkTableForLog();
	13	+ List<MunjaonMsg> selectToDeliver(String msgType);
	14	+ int updateToDeliver(String msgId);
	15	+ int updateDeliverForList(List<String> msgIdList);
	16	+ int updateToReport(MunjaonMsg params);
	17	+ List<MunjaonMsg> selectToMove();
	18	+ List<MunjaonMsg> selectToExpire(String expireTime);
	19	+ int insertToLog(String msgId);
	20	+ int deleteFromDeliver(String msgId);
	21	+}

12accd8

src/main/java/com/munjaon/client/tibero/service/TiberoService.java (added)

+++ src/main/java/com/munjaon/client/tibero/service/TiberoService.java

...	...	@@ -0,0 +1,69 @@
	1	+package com.munjaon.client.tibero.service;
	2	+
	3	+import com.munjaon.client.model.MunjaonMsg;
	4	+import com.munjaon.client.tibero.mapper.TiberoMapper;
	5	+import lombok.RequiredArgsConstructor;
	6	+import lombok.extern.slf4j.Slf4j;
	7	+import org.springframework.stereotype.Service;
	8	+import org.springframework.transaction.annotation.Transactional;
	9	+
	10	+import java.util.List;
	11	+
	12	+@Slf4j
	13	+@Service
	14	+@RequiredArgsConstructor
	15	+public class TiberoService {
	16	+ private final TiberoMapper deliverBMapper;
	17	+
	18	+ public boolean checkTableExists() {
	19	+ boolean isExist = false;
	20	+ try {
	21	+ int msgCount = deliverBMapper.checkTableForMessage();
	22	+ int logCount = deliverBMapper.checkTableForLog();
	23	+ if (msgCount >= 0 && logCount >= 0) {
	24	+ isExist = true;
	25	+ }
	26	+ } catch (Exception e) {
	27	+ log.error("Check table exists error : {}", e);
	28	+ }
	29	+
	30	+ return isExist;
	31	+ }
	32	+ public List<MunjaonMsg> selectToDeliver(String msgType) {
	33	+ return deliverBMapper.selectToDeliver(msgType);
	34	+ }
	35	+ public int updateToDeliver(String msgId) {
	36	+ return deliverBMapper.updateToDeliver(msgId);
	37	+ }
	38	+ public int updateDeliverForList(List<String> msgIdList) {
	39	+ return deliverBMapper.updateDeliverForList(msgIdList);
	40	+ }
	41	+ public int updateToReport(MunjaonMsg params) {
	42	+ return deliverBMapper.updateToReport(params);
	43	+ }
	44	+ public List<MunjaonMsg> selectToMove() {
	45	+ return deliverBMapper.selectToMove();
	46	+ }
	47	+ public List<MunjaonMsg> selectToExpire(String expireTime) {
	48	+ return deliverBMapper.selectToExpire(expireTime);
	49	+ }
	50	+ public int insertToLog(String msgId) {
	51	+ return deliverBMapper.insertToLog(msgId);
	52	+ }
	53	+ public int deleteFromDeliver(String msgId) {
	54	+ return deliverBMapper.deleteFromDeliver(msgId);
	55	+ }
	56	+
	57	+ @Transactional
	58	+ public void moveToDeliver() {
	59	+ List<MunjaonMsg> list = selectToMove();
	60	+ if (list == null \|\| list.size() == 0) {
	61	+ return;
	62	+ }
	63	+ log.debug("[CLASS : {} : MOVE_COUNT : {}", this.getClass(), list.size());
	64	+ for (MunjaonMsg msg : list) {
	65	+ insertToLog(msg.getMsgId());
	66	+ deleteFromDeliver(msg.getMsgId());
	67	+ }
	68	+ }
	69	+}

12accd8

src/main/resources/sqlmap/cubrid/cubrid_sql.xml (added)

+++ src/main/resources/sqlmap/cubrid/cubrid_sql.xml

...	...	@@ -0,0 +1,103 @@
	1	+<?xml version="1.0" encoding="UTF-8"?>
	2	+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
	3	+<mapper namespace="com.munjaon.client.cubrid.mapper.CubridMapper">
	4	+ <select id="checkTime" resultType="String">
	5	+ /* CubridMapper.checkTime */
	6	+ SELECT DATE_FORMAT(NOW(), '%Y%m%d%H%i%s')
	7	+ </select>
	8	+ <select id="checkTableForMessage" resultType="int">
	9	+ /* CubridMapper.checkTableForMessage */
	10	+ SELECT COUNT(MSG_ID) FROM MUNJAON_MSG WHERE 1=1 LIMIT 1
	11	+ </select>
	12	+ <select id="checkTableForLog" resultType="int">
	13	+ /* CubridMapper.checkTableForLog */
	14	+ SELECT COUNT(MSG_ID) FROM MUNJAON_MSG_LOG WHERE 1=1 LIMIT 1
	15	+ </select>
	16	+ <select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
	17	+ /* CubridMapper.selectToDeliver */
	18	+ SELECT
	19	+ MSG_ID
	20	+ , MSG_TYPE
	21	+ , to_char(REQUEST_DATE, 'YYYYMMDDHH24MISS') RESERVE_DATE
	22	+ , to_char(SYSDATETIME, 'YYYYMMDDHH24MISS') REQUEST_DATE
	23	+ , RECV_PHONE
	24	+ , SEND_PHONE
	25	+ , SUBJECT
	26	+ , MESSAGE
	27	+ , FILENAME01
	28	+ , FILENAME02
	29	+ , FILENAME03
	30	+ , KAKAO_SENDER_KEY
	31	+ , KAKAO_TEMPLATE_CODE
	32	+ , KAKAO_JSON_FILE
	33	+ FROM MUNJAON_MSG
	34	+ WHERE SEND_STATUS = '0'
	35	+ AND MSG_TYPE = #{msgType}
	36	+ AND REQUEST_DATE <![CDATA[<=]]> SYSDATETIME
	37	+ ORDER BY REQUEST_DATE ASC
	38	+ LIMIT 100
	39	+ </select>
	40	+ <update id="updateToDeliver">
	41	+ /* CubridMapper.updateToDeliver */
	42	+ UPDATE MUNJAON_MSG SET
	43	+ SEND_STATUS = '1'
	44	+ , DELIVER_DATE = SYSDATETIME
	45	+ WHERE MSG_ID = #{msgId}
	46	+ </update>
	47	+ <update id="updateDeliverForList">
	48	+ /* CubridMapper.updateDeliverForList */
	49	+ UPDATE MUNJAON_MSG SET
	50	+ SEND_STATUS = '1'
	51	+ , DELIVER_DATE = SYSDATETIME
	52	+ WHERE SEND_STATUS = '0'
	53	+ AND (
	54	+ <foreach separator="OR" item="item" collection="list">
	55	+ MSG_ID = #{item}
	56	+ </foreach>
	57	+ )
	58	+ </update>
	59	+ <update id="updateToReport">
	60	+ /* CubridMapper.updateToReport */
	61	+ UPDATE MUNJAON_MSG SET
	62	+ SEND_STATUS = #{sendStatus}
	63	+ , SENT_DATE = FROM_UNIXTIME(UNIX_TIMESTAMP(#{sendDate}))
	64	+ , REPORT_DATE = NOW()
	65	+ , TELECOM = #{telecom}
	66	+ WHERE MSG_ID = #{msgId}
	67	+ </update>
	68	+ <select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
	69	+ /* CubridMapper.selectToMove */
	70	+ SELECT MSG_ID, to_date(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
	71	+ FROM MUNJAON_MSG
	72	+ WHERE SEND_STATUS NOT IN ('0', '1')
	73	+ LIMIT 100
	74	+ </select>
	75	+ <select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
	76	+ /* CubridMapper.selectToExpire */
	77	+ SELECT MSG_ID, to_date(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
	78	+ FROM MUNJAON_MSG
	79	+ WHERE REQUEST_DATE <![CDATA[<]]> FROM_UNIXTIME(UNIX_TIMESTAMP(#{expireTime}))
	80	+ AND SEND_STATUS = '1'
	81	+ LIMIT 100
	82	+ </select>
	83	+ <insert id="insertToLog">
	84	+ /* CubridMapper.insertToLog */
	85	+ INSERT INTO MUNJAON_MSG_LOG
	86	+ (
	87	+ MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,
	88	+ RECV_PHONE, SEND_PHONE, SUBJECT, MESSAGE, TELECOM,
	89	+ FILENAME01, FILENAME02, FILENAME03, DELIVER_DATE, SENT_DATE, REPORT_DATE
	90	+ )
	91	+ SELECT
	92	+ MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,
	93	+ RECV_PHONE, SEND_PHONE, SUBJECT, MESSAGE, TELECOM,
	94	+ FILENAME01, FILENAME02, FILENAME03, DELIVER_DATE, SENT_DATE, REPORT_DATE
	95	+ FROM MUNJAON_MSG
	96	+ WHERE MSG_ID = #{msgId}
	97	+ </insert>
	98	+ <delete id="deleteFromDeliver">
	99	+ /* CubridMapper.deleteFromDeliver */
	100	+ DELETE FROM MUNJAON_MSG
	101	+ WHERE MSG_ID = #{msgId}
	102	+ </delete>
	103	+</mapper>(No newline at end of file)

b517754

12accd8

src/main/resources/sqlmap/mariadb/mariadb_sql.xml

--- src/main/resources/sqlmap/mariadb/mariadb_sql.xml

+++ src/main/resources/sqlmap/mariadb/mariadb_sql.xml


             , DELIVER_DATE = NOW()
         WHERE MSG_ID = #{msgId}
     </update>
+    <update id="updateDeliverForList" parameterType="java.util.List">
+        /* MariaDBMapper.updateDeliverForList */
+        UPDATE MUNJAON_MSG SET
+        SEND_STATUS = '1'
+        , DELIVER_DATE = NOW()
+        WHERE SEND_STATUS = '0'
+        AND (
+        <foreach separator="OR" item="item" collection="list">
+            MSG_ID = #{item}
+        </foreach>
+        )
+    </update>
     <update id="updateToReport">
         /* MariaDBMapper.updateToReport */
         UPDATE MUNJAON_MSG SET

b517754

12accd8

src/main/resources/sqlmap/mssql/mssql_sql.xml

--- src/main/resources/sqlmap/mssql/mssql_sql.xml

+++ src/main/resources/sqlmap/mssql/mssql_sql.xml


 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.munjaon.client.mssql.mapper.MssqlMapper">
     <select id="checkTime" resultType="String">
-        /* MariaDBMapper.checkTime */
+        /* MssqlMapper.checkTime */
         SELECT GETDATE()
     </select>
     <select id="checkTableForMessage" resultType="int">
-        /* MariaDBMapper.checkTableForMessage */
+        /* MssqlMapper.checkTableForMessage */
 --         SELECT 1 FROM MUNJAON_MSG WHERE 1=1 LIMIT 1
         <![CDATA[
         SELECT TOP 1 COUNT(MSG_ID) FROM MUNJAON_MSG WHERE 1=1
         ]]>
     </select>
     <select id="checkTableForLog" resultType="int">
-        /* MariaDBMapper.checkTableForLog */
+        /* MssqlMapper.checkTableForLog */
         <![CDATA[
         SELECT TOP 1 COUNT(MSG_ID) FROM MUNJAON_MSG_LOG WHERE 1=1
         ]]>
     </select>
     <select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToDeliver */
+        /* MssqlMapper.selectToDeliver */
         <![CDATA[
         SELECT
             TOP 100

         ]]>
     </select>
     <update id="updateToDeliver">
-        /* MariaDBMapper.updateToDeliver */
+        /* MssqlMapper.updateToDeliver */
         UPDATE MUNJAON_MSG SET
             SEND_STATUS = '1'
             , DELIVER_DATE = GETDATE()
         WHERE MSG_ID = #{msgId}
     </update>
+    <update id="updateDeliverForList">
+        /* MssqlMapper.updateDeliverForList */
+        UPDATE MUNJAON_MSG SET
+            SEND_STATUS = '1'
+            , DELIVER_DATE = GETDATE()
+        WHERE SEND_STATUS = '0'
+        AND (
+        <foreach separator="OR" item="item" collection="list">
+            MSG_ID = #{item}
+        </foreach>
+        )
+    </update>
     <update id="updateToReport">
-        /* MariaDBMapper.updateToReport */
+        /* MssqlMapper.updateToReport */
         UPDATE MUNJAON_MSG SET
             SEND_STATUS = #{sendStatus}
             , SENT_DATE = CAST(#{sendDate} AS DATETIME)

         WHERE MSG_ID = #{msgId}
     </update>
     <select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToMove */
+        /* MssqlMapper.selectToMove */
         <![CDATA[
         SELECT TOP 100
             MSG_ID, CONVERT(VARCHAR(6),REQUEST_DATE,112) REQUEST_DATE

         ]]>
     </select>
     <select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToExpire */
+        /* MssqlMapper.selectToExpire */
         <![CDATA[
             SELECT TOP 100
                 MSG_ID, CONVERT(VARCHAR(6),REQUEST_DATE,112) REQUEST_DATE

         ]]>
     </select>
     <insert id="insertToLog">
-        /* MariaDBMapper.insertToLog */
+        /* MssqlMapper.insertToLog */
         INSERT INTO MUNJAON_MSG_LOG
         (
             MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,

         WHERE MSG_ID = #{msgId}
     </insert>
     <delete id="deleteFromDeliver">
-        /* MariaDBMapper.deleteFromDeliver */
+        /* MssqlMapper.deleteFromDeliver */
         DELETE FROM MUNJAON_MSG
         WHERE MSG_ID = #{msgId}
     </delete>

b517754

12accd8

src/main/resources/sqlmap/mysql/mysql_sql.xml

--- src/main/resources/sqlmap/mysql/mysql_sql.xml

+++ src/main/resources/sqlmap/mysql/mysql_sql.xml


 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.munjaon.client.mysql.mapper.MysqlMapper">
     <select id="checkTime" resultType="String">
-        /* MariaDBMapper.checkTime */
+        /* MysqlMapper.checkTime */
         SELECT DATE_FORMAT(NOW(), '%Y%m%d%H%i%s')
     </select>
     <select id="checkTableForMessage" resultType="int">
-        /* MariaDBMapper.checkTableForMessage */
---         SELECT 1 FROM MUNJAON_MSG WHERE 1=1 LIMIT 1
+        /* MysqlMapper.checkTableForMessage */
         SELECT COUNT(*)
         FROM   information_schema.tables
         WHERE TABLE_NAME = 'MUNJAON_MSG'
     </select>
     <select id="checkTableForLog" resultType="int">
-        /* MariaDBMapper.checkTableForLog */
+        /* MysqlMapper.checkTableForLog */
         SELECT COUNT(*)
         FROM   information_schema.tables
         WHERE TABLE_NAME = 'MUNJAON_MSG_LOG'
 --                 SELECT 1 FROM MUNJAON_MSG_LOG WHERE 1=1 LIMIT 1
     </select>
     <select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToDeliver */
+        /* MysqlMapper.selectToDeliver */
         SELECT
             MSG_ID
             , MSG_TYPE

         LIMIT 100
     </select>
     <update id="updateToDeliver">
-        /* MariaDBMapper.updateToDeliver */
+        /* MysqlMapper.updateToDeliver */
         UPDATE MUNJAON_MSG SET
             SEND_STATUS = '1'
             , DELIVER_DATE = NOW()
         WHERE MSG_ID = #{msgId}
     </update>
+    <update id="updateDeliverForList">
+        /* MysqlMapper.updateToDeliver */
+        UPDATE MUNJAON_MSG SET
+            SEND_STATUS = '1'
+            , DELIVER_DATE = NOW()
+        WHERE SEND_STATUS = '0'
+        AND (
+        <foreach separator="OR" item="item" collection="list">
+            MSG_ID = #{item}
+        </foreach>
+        )
+    </update>
     <update id="updateToReport">
-        /* MariaDBMapper.updateToReport */
+        /* MysqlMapper.updateToReport */
         UPDATE MUNJAON_MSG SET
             SEND_STATUS = #{sendStatus}
             , SENT_DATE = FROM_UNIXTIME(UNIX_TIMESTAMP(#{sendDate}))

         WHERE MSG_ID = #{msgId}
     </update>
     <select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToMove */
+        /* MysqlMapper.selectToMove */
         SELECT MSG_ID, DATE_FORMAT(REQUEST_DATE, '%Y%m') REQUEST_DATE
         FROM MUNJAON_MSG
         WHERE SEND_STATUS NOT IN ('0', '1')
             LIMIT 100
     </select>
     <select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToExpire */
+        /* MysqlMapper.selectToExpire */
         SELECT MSG_ID, DATE_FORMAT(REQUEST_DATE, '%Y%m') REQUEST_DATE
         FROM MUNJAON_MSG
         WHERE REQUEST_DATE <![CDATA[<]]> FROM_UNIXTIME(UNIX_TIMESTAMP(#{expireTime}))

         LIMIT 100
     </select>
     <insert id="insertToLog">
-        /* MariaDBMapper.insertToLog */
+        /* MysqlMapper.insertToLog */
         INSERT INTO MUNJAON_MSG_LOG
         (
             MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,

         WHERE MSG_ID = #{msgId}
     </insert>
     <delete id="deleteFromDeliver">
-        /* MariaDBMapper.deleteFromDeliver */
+        /* MysqlMapper.deleteFromDeliver */
         DELETE FROM MUNJAON_MSG
         WHERE MSG_ID = #{msgId}
     </delete>

b517754

12accd8

src/main/resources/sqlmap/oracle/oracle_sql.xml

--- src/main/resources/sqlmap/oracle/oracle_sql.xml

+++ src/main/resources/sqlmap/oracle/oracle_sql.xml


 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.munjaon.client.oracle.mapper.OracleMapper">
     <select id="checkTime" resultType="String">
-        /* MariaDBMapper.checkTime */
+        /* OracleMapper.checkTime */
         SELECT TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') FROM DUAL
     </select>
     <select id="checkTableForMessage" resultType="int">
-        /* MariaDBMapper.checkTableForMessage */
---         SELECT 1 FROM MUNJAON_MSG WHERE 1=1 LIMIT 1
+        /* OracleMapper.checkTableForMessage */
         <![CDATA[
         SELECT COUNT(MSG_ID) FROM MUNJAON_MSG WHERE 1=1 AND rownum <= 1
         ]]>
     </select>
     <select id="checkTableForLog" resultType="int">
-        /* MariaDBMapper.checkTableForLog */
+        /* OracleMapper.checkTableForLog */
         <![CDATA[
         SELECT COUNT(MSG_ID) FROM MUNJAON_MSG_LOG WHERE 1=1 AND rownum <= 1
         ]]>
     </select>
     <select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToDeliver */
+        /* OracleMapper.selectToDeliver */
         <![CDATA[
         SELECT
             MSG_ID

         ]]>
     </select>
     <update id="updateToDeliver">
-        /* MariaDBMapper.updateToDeliver */
+        /* OracleMapper.updateToDeliver */
         UPDATE MUNJAON_MSG SET
             SEND_STATUS = '1'
             , DELIVER_DATE = SYSDATE
         WHERE MSG_ID = #{msgId}
     </update>
+    <update id="updateDeliverForList">
+        /* OracleMapper.updateToDeliver */
+        UPDATE MUNJAON_MSG SET
+            SEND_STATUS = '1'
+            , DELIVER_DATE = SYSDATE
+        WHERE SEND_STATUS = '0'
+        AND (
+        <foreach separator="OR" item="item" collection="list">
+            MSG_ID = #{item}
+        </foreach>
+        )
+    </update>
     <update id="updateToReport">
-        /* MariaDBMapper.updateToReport */
+        /* OracleMapper.updateToReport */
         UPDATE MUNJAON_MSG SET
             SEND_STATUS = #{sendStatus}
             , SENT_DATE = TO_DATE(#{sendDate}, 'YYYYMMDDHH24MISS')

         WHERE MSG_ID = #{msgId}
     </update>
     <select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToMove */
+        /* OracleMapper.selectToMove */
         <![CDATA[
         SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
         FROM MUNJAON_MSG

         ]]>
     </select>
     <select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToExpire */
+        /* OracleMapper.selectToExpire */
         <![CDATA[
             SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
             FROM MUNJAON_MSG

         ]]>
     </select>
     <insert id="insertToLog">
-        /* MariaDBMapper.insertToLog */
+        /* OracleMapper.insertToLog */
         INSERT INTO MUNJAON_MSG_LOG
         (
             MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,

         WHERE MSG_ID = #{msgId}
     </insert>
     <delete id="deleteFromDeliver">
-        /* MariaDBMapper.deleteFromDeliver */
+        /* OracleMapper.deleteFromDeliver */
         DELETE FROM MUNJAON_MSG
         WHERE MSG_ID = #{msgId}
     </delete>

b517754

12accd8

src/main/resources/sqlmap/postgresql/postresql_sql.xml

--- src/main/resources/sqlmap/postgresql/postresql_sql.xml

+++ src/main/resources/sqlmap/postgresql/postresql_sql.xml


 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.munjaon.client.postgresql.mapper.PostgresqlMapper">
     <select id="checkTime" resultType="String">
-        /* MariaDBMapper.checkTime */
+        /* PostgresqlMapper.checkTime */
         SELECT TO_CHAR(NOW(), 'YYYYMMDDHH24MISS') FROM DUAL
     </select>
     <select id="checkTableForMessage" resultType="int">
-        /* MariaDBMapper.checkTableForMessage */
+        /* PostgresqlMapper.checkTableForMessage */
         SELECT COUNT(MSG_ID) FROM MUNJAON_MSG WHERE 1=1 LIMIT 1
     </select>
     <select id="checkTableForLog" resultType="int">
-        /* MariaDBMapper.checkTableForLog */
+        /* PostgresqlMapper.checkTableForLog */
         SELECT COUNT(MSG_ID) FROM MUNJAON_MSG_LOG WHERE 1=1 LIMIT 1
     </select>
     <select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToDeliver */
+        /* PostgresqlMapper.selectToDeliver */
         <![CDATA[
         SELECT
             MSG_ID

         ]]>
     </select>
     <update id="updateToDeliver">
-        /* MariaDBMapper.updateToDeliver */
+        /* PostgresqlMapper.updateToDeliver */
         UPDATE MUNJAON_MSG SET
             SEND_STATUS = '1'
             , DELIVER_DATE = NOW()
         WHERE MSG_ID = #{msgId}
     </update>
+    <update id="updateDeliverForList">
+        /* PostgresqlMapper.updateDeliverForList */
+        UPDATE MUNJAON_MSG SET
+            SEND_STATUS = '1'
+            , DELIVER_DATE = NOW()
+        WHERE SEND_STATUS = '0'
+        AND (
+        <foreach separator="OR" item="item" collection="list">
+            MSG_ID = #{item}
+        </foreach>
+        )
+    </update>
     <update id="updateToReport">
-        /* MariaDBMapper.updateToReport */
+        /* PostgresqlMapper.updateToReport */
         UPDATE MUNJAON_MSG SET
             SEND_STATUS = #{sendStatus}
             , SENT_DATE = TO_DATE(#{sendDate}, 'YYYYMMDDHH24MISS')

         WHERE MSG_ID = #{msgId}
     </update>
     <select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToMove */
+        /* PostgresqlMapper.selectToMove */
         <![CDATA[
         SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
         FROM MUNJAON_MSG

         ]]>
     </select>
     <select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
-        /* MariaDBMapper.selectToExpire */
+        /* PostgresqlMapper.selectToExpire */
         <![CDATA[
             SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
             FROM MUNJAON_MSG

         ]]>
     </select>
     <insert id="insertToLog">
-        /* MariaDBMapper.insertToLog */
+        /* PostgresqlMapper.insertToLog */
         INSERT INTO MUNJAON_MSG_LOG
         (
             MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,

         WHERE MSG_ID = #{msgId}
     </insert>
     <delete id="deleteFromDeliver">
-        /* MariaDBMapper.deleteFromDeliver */
+        /* PostgresqlMapper.deleteFromDeliver */
         DELETE FROM MUNJAON_MSG
         WHERE MSG_ID = #{msgId}
     </delete>

12accd8

src/main/resources/sqlmap/tibero/tibero_sql.xml (added)

+++ src/main/resources/sqlmap/tibero/tibero_sql.xml

...	...	@@ -0,0 +1,113 @@
	1	+<?xml version="1.0" encoding="UTF-8"?>
	2	+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
	3	+<mapper namespace="com.munjaon.client.tibero.mapper.TiberoMapper">
	4	+ <select id="checkTime" resultType="String">
	5	+ /* OracleMapper.checkTime */
	6	+ SELECT TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') FROM DUAL
	7	+ </select>
	8	+ <select id="checkTableForMessage" resultType="int">
	9	+ /* OracleMapper.checkTableForMessage */
	10	+ <![CDATA[
	11	+ SELECT COUNT(MSG_ID) FROM MUNJAON_MSG WHERE 1=1 AND rownum <= 1
	12	+ ]]>
	13	+ </select>
	14	+ <select id="checkTableForLog" resultType="int">
	15	+ /* OracleMapper.checkTableForLog */
	16	+ <![CDATA[
	17	+ SELECT COUNT(MSG_ID) FROM MUNJAON_MSG_LOG WHERE 1=1 AND rownum <= 1
	18	+ ]]>
	19	+ </select>
	20	+ <select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
	21	+ /* OracleMapper.selectToDeliver */
	22	+ <![CDATA[
	23	+ SELECT
	24	+ MSG_ID
	25	+ , MSG_TYPE
	26	+ , TO_CHAR(REQUEST_DATE,'YYYYMMDDHH24MISS') RESERVE_DATE
	27	+ , TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS') REQUEST_DATE
	28	+ , RECV_PHONE
	29	+ , SEND_PHONE
	30	+ , SUBJECT
	31	+ , MESSAGE
	32	+ , FILENAME01
	33	+ , FILENAME02
	34	+ , FILENAME03
	35	+ , KAKAO_SENDER_KEY
	36	+ , KAKAO_TEMPLATE_CODE
	37	+ , KAKAO_JSON_FILE
	38	+ FROM MUNJAON_MSG
	39	+ WHERE SEND_STATUS = '0'
	40	+ AND MSG_TYPE = #{msgType}
	41	+ AND REQUEST_DATE <= SYSDATE
	42	+ AND ROWNUM <= 100
	43	+ ORDER BY REQUEST_DATE ASC
	44	+ ]]>
	45	+ </select>
	46	+ <update id="updateToDeliver">
	47	+ /* OracleMapper.updateToDeliver */
	48	+ UPDATE MUNJAON_MSG SET
	49	+ SEND_STATUS = '1'
	50	+ , DELIVER_DATE = SYSDATE
	51	+ WHERE MSG_ID = #{msgId}
	52	+ </update>
	53	+ <update id="updateDeliverForList">
	54	+ /* OracleMapper.updateDeliverForList */
	55	+ UPDATE MUNJAON_MSG SET
	56	+ SEND_STATUS = '1'
	57	+ , DELIVER_DATE = SYSDATE
	58	+ WHERE SEND_STATUS = '0'
	59	+ AND (
	60	+ <foreach separator="OR" item="item" collection="list">
	61	+ MSG_ID = #{item}
	62	+ </foreach>
	63	+ )
	64	+ </update>
	65	+ <update id="updateToReport">
	66	+ /* OracleMapper.updateToReport */
	67	+ UPDATE MUNJAON_MSG SET
	68	+ SEND_STATUS = #{sendStatus}
	69	+ , SENT_DATE = TO_DATE(#{sendDate}, 'YYYYMMDDHH24MISS')
	70	+ , REPORT_DATE = SYSDATE
	71	+ , TELECOM = #{telecom}
	72	+ WHERE MSG_ID = #{msgId}
	73	+ </update>
	74	+ <select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
	75	+ /* OracleMapper.selectToMove */
	76	+ <![CDATA[
	77	+ SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
	78	+ FROM MUNJAON_MSG
	79	+ WHERE SEND_STATUS NOT IN ('0', '1')
	80	+ AND ROWNUM <= 100
	81	+ ]]>
	82	+ </select>
	83	+ <select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
	84	+ /* OracleMapper.selectToExpire */
	85	+ <![CDATA[
	86	+ SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
	87	+ FROM MUNJAON_MSG
	88	+ WHERE REQUEST_DATE < TO_DATE(#{expireTime}, 'YYYYMMDDHH24MISS')
	89	+ AND SEND_STATUS = '1'
	90	+ AND ROWNUM <= 100
	91	+ ]]>
	92	+ </select>
	93	+ <insert id="insertToLog">
	94	+ /* OracleMapper.insertToLog */
	95	+ INSERT INTO MUNJAON_MSG_LOG
	96	+ (
	97	+ MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,
	98	+ RECV_PHONE, SEND_PHONE, SUBJECT, MESSAGE, TELECOM,
	99	+ FILENAME01, FILENAME02, FILENAME03, DELIVER_DATE, SENT_DATE, REPORT_DATE
	100	+ )
	101	+ SELECT
	102	+ MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,
	103	+ RECV_PHONE, SEND_PHONE, SUBJECT, MESSAGE, TELECOM,
	104	+ FILENAME01, FILENAME02, FILENAME03, DELIVER_DATE, SENT_DATE, REPORT_DATE
	105	+ FROM MUNJAON_MSG
	106	+ WHERE MSG_ID = #{msgId}
	107	+ </insert>
	108	+ <delete id="deleteFromDeliver">
	109	+ /* OracleMapper.deleteFromDeliver */
	110	+ DELETE FROM MUNJAON_MSG
	111	+ WHERE MSG_ID = #{msgId}
	112	+ </delete>
	113	+</mapper>(No newline at end of file)

Add a comment

Open 0
Closed 0

List

...	...	@@ -21,6 +21,9 @@
21	21
22	22	repositories {
23	23	mavenCentral()
	24	+ maven {url 'https://maven.google.com'}
	25	+ maven {url 'https://maven.cubrid.org/'}
	26	+ maven {url 'https://maven.jumpmind.com/repo/'}
24	27	}
25	28
26	29	dependencies {
...	...	@@ -49,6 +52,11 @@
49	52	implementation group: 'com.microsoft.sqlserver', name: 'mssql-jdbc', version: '12.8.0.jre11'
50	53	// https://mvnrepository.com/artifact/org.postgresql/postgresql
51	54	implementation group: 'org.postgresql', name: 'postgresql', version: '42.7.3'
	55	+ // https://mvnrepository.com/artifact/cubrid/cubrid-jdbc
	56	+ implementation group: 'cubrid', name: 'cubrid-jdbc', version: '11.2.1.0038'
	57	+ // https://mvnrepository.com/artifact/jdbc.tibero/tibero
	58	+ //implementation files('libs/tibero6-jdbc-14.jar')
	59	+ implementation files('libs/tibero-6.jar')
52	60
53	61	}
54	62

...	...	@@ -12,6 +12,7 @@
12	12	int checkTableForLog();
13	13	List<MunjaonMsg> selectToDeliver(String msgType);
14	14	int updateToDeliver(String msgId);
	15	+ int updateDeliverForList(List<String> msgIdList);
15	16	int updateToReport(MunjaonMsg params);
16	17	List<MunjaonMsg> selectToMove();
17	18	List<MunjaonMsg> selectToExpire(String expireTime);

...	...	@@ -35,6 +35,9 @@
35	35	public int updateToDeliver(String msgId) {
36	36	return deliverBMapper.updateToDeliver(msgId);
37	37	}
	38	+ public int updateDeliverForList(List<String> msgIdList) {
	39	+ return deliverBMapper.updateDeliverForList(msgIdList);
	40	+ }
38	41	public int updateToReport(MunjaonMsg params) {
39	42	return deliverBMapper.updateToReport(params);
40	43	}

...	...	@@ -13,6 +13,7 @@
13	13	import java.net.InetSocketAddress;
14	14	import java.nio.ByteBuffer;
15	15	import java.nio.channels.SocketChannel;
	16	+import java.util.ArrayList;
16	17	import java.util.List;
17	18
18	19	public class CollectClientService extends Service {
...	...	@@ -24,6 +25,9 @@
24	25	private int port;
25	26	private String id;
26	27	private String pwd;
	28	+
	29	+ private StringBuilder deliverBuilder;
	30	+ private List<String> deliverList = null;
27	31
28	32	public CollectClientService(String serviceName, String serviceType) {
29	33	super(serviceName);
...	...	@@ -38,8 +42,12 @@
38	42	return;
39	43	}
40	44
41		- saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
42	45	this.IS_READY_YN = worker.checkTableExists();
	46	+ if (this.IS_READY_YN) {
	47	+ saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
	48	+ } else {
	49	+ saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is not ready]");
	50	+ }
43	51	}
44	52
45	53	@Override
...	...	@@ -137,8 +145,28 @@
137	145	return null;
138	146	}
139	147
	148	+ private void setDeliverMsgId(String msgId) {
	149	+ if (msgId == null) {
	150	+ return;
	151	+ }
	152	+ if (this.deliverList == null) {
	153	+ this.deliverList = new ArrayList<>();
	154	+ }
	155	+ this.deliverList.add(msgId);
	156	+// if (this.deliverBuilder == null) {
	157	+// return;
	158	+// }
	159	+//
	160	+// if (this.deliverBuilder.isEmpty()) {
	161	+// this.deliverBuilder.append(msgId);
	162	+// } else {
	163	+// this.deliverBuilder.append(",").append(msgId);
	164	+// }
	165	+ }
	166	+
140	167	private void messageService() {
141	168	List<MunjaonMsg> list = selectToDeliver();
	169	+ this.deliverBuilder = new StringBuilder();
142	170	if (list == null \|\| list.isEmpty()) {
143	171	try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}
144	172	return;
...	...	@@ -153,6 +181,10 @@
153	181	case "KFT": kftMessageService(data); break;
154	182	default:break;
155	183	}
	184	+ }
	185	+ if (this.deliverList != null && this.deliverList.size() > 0) {
	186	+ worker.updateDeliverForList(this.deliverList);
	187	+ this.deliverList = null; // NULL로 초기화
156	188	}
157	189	}
158	190
...	...	@@ -192,14 +224,16 @@
192	224	saveSystemLog("[MESSAGE SEND] [FAIL] [SOCKET IS CLOSED]");
193	225	throw new RuntimeException("DELIVER ERROR");
194	226	} else if (recvCount > 0) {
195		- worker.updateToDeliver(data.getMsgId());
	227	+ setDeliverMsgId(data.getMsgId());
	228	+// worker.updateToDeliver(data.getMsgId());
196	229	saveSystemLog("[MESSAGE SEND] [SUCCESS]");
197	230	lastPacketSendTime = System.currentTimeMillis();
198	231	break;
199	232	}
200	233	}
201	234	} catch (IOException e) {
202		- throw new RuntimeException(e);
	235	+ e.printStackTrace();
	236	+// throw new RuntimeException(e);
203	237	}
204	238	}
205	239

...	...	@@ -18,8 +18,12 @@
18	18	return;
19	19	}
20	20
21		- saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
22	21	this.IS_READY_YN = worker.checkTableExists();
	22	+ if (this.IS_READY_YN) {
	23	+ saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
	24	+ } else {
	25	+ saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is not ready]");
	26	+ }
23	27	}
24	28
25	29	@Override

...	...	@@ -37,8 +37,12 @@
37	37	return;
38	38	}
39	39
40		- saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
41	40	this.IS_READY_YN = worker.checkTableExists();
	41	+ if (this.IS_READY_YN) {
	42	+ saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is ready]");
	43	+ } else {
	44	+ saveSystemLog("[checkReady][DBMS : " + System.getProperty("DBMS") + " is not ready]");
	45	+ }
42	46	}
43	47
44	48	@Override

...	...	@@ -4,11 +4,13 @@
4	4
5	5	@Getter
6	6	public enum DatabaseService {
	7	+ CUBRID_SERVICE,
7	8	MARIADB_SERVICE,
8	9	MSSQL_SERVICE,
9	10	ORACLE_SERVICE,
10	11	POSTGRESQL_SERVICE,
11		- MYSQL_SERVICE;
	12	+ MYSQL_SERVICE,
	13	+ TIBERO_SERVICE;
12	14
13	15	private Object service;
14	16

...	...	@@ -1,10 +1,12 @@
1	1	package com.munjaon.client.service;
2	2
	3	+import com.munjaon.client.cubrid.service.CubridService;
3	4	import com.munjaon.client.mariadb.service.MariaDBService;
4	5	import com.munjaon.client.mssql.service.MssqlService;
5	6	import com.munjaon.client.mysql.service.MysqlService;
6	7	import com.munjaon.client.oracle.service.OracleService;
7	8	import com.munjaon.client.postgresql.service.PostgresqlService;
	9	+import com.munjaon.client.tibero.service.TiberoService;
8	10	import jakarta.annotation.PostConstruct;
9	11	import org.springframework.beans.factory.annotation.Autowired;
10	12	import org.springframework.stereotype.Component;
...	...	@@ -13,6 +15,8 @@
13	15
14	16	@Component
15	17	public class DatabaseServiceInjector {
	18	+ @Autowired
	19	+ private CubridService cubridService;
16	20	@Autowired
17	21	private MariaDBService mariaDBService;
18	22	@Autowired
...	...	@@ -23,11 +27,15 @@
23	27	private OracleService oracleService;
24	28	@Autowired
25	29	private PostgresqlService postgresqlService;
	30	+ @Autowired
	31	+ private TiberoService tiberoService;
26	32
27	33	@PostConstruct
28	34	public void postConstruct() {
29	35	for (DatabaseService svc : EnumSet.allOf(DatabaseService.class)) {
30	36	switch (svc) {
	37	+ case CUBRID_SERVICE: svc.setService(cubridService);
	38	+ break;
31	39	case MARIADB_SERVICE: svc.setService(mariaDBService);
32	40	break;
33	41	case MSSQL_SERVICE: svc.setService(mssqlService);
...	...	@@ -38,6 +46,8 @@
38	46	break;
39	47	case POSTGRESQL_SERVICE : svc.setService(postgresqlService);
40	48	break;
	49	+ case TIBERO_SERVICE: svc.setService(tiberoService);
	50	+ break;
41	51	default: break;
42	52	}
43	53	}

...	...	@@ -1,11 +1,13 @@
1	1	package com.munjaon.client.service;
2	2
	3	+import com.munjaon.client.cubrid.service.CubridService;
3	4	import com.munjaon.client.mariadb.service.MariaDBService;
4	5	import com.munjaon.client.model.MunjaonMsg;
5	6	import com.munjaon.client.mssql.service.MssqlService;
6	7	import com.munjaon.client.mysql.service.MysqlService;
7	8	import com.munjaon.client.oracle.service.OracleService;
8	9	import com.munjaon.client.postgresql.service.PostgresqlService;
	10	+import com.munjaon.client.tibero.service.TiberoService;
9	11	import lombok.Getter;
10	12
11	13	import java.util.EnumSet;
...	...	@@ -13,6 +15,67 @@
13	15
14	16	@Getter
15	17	public enum DatabaseTypeWorker {
	18	+ TYPE_OF_CUBRID("CUBRID") {
	19	+ @Override
	20	+ public boolean checkTableExists() {
	21	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	22	+ return cubridService.checkTableExists();
	23	+ }
	24	+
	25	+ @Override
	26	+ public List<MunjaonMsg> selectToDeliver(String msgType) {
	27	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	28	+ return cubridService.selectToDeliver(msgType);
	29	+ }
	30	+
	31	+ @Override
	32	+ public int updateToDeliver(String msgId) {
	33	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	34	+ return cubridService.updateToDeliver(msgId);
	35	+ }
	36	+
	37	+ @Override
	38	+ public int updateDeliverForList(List<String> msgIdList) {
	39	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	40	+ return cubridService.updateDeliverForList(msgIdList);
	41	+ }
	42	+
	43	+ @Override
	44	+ public int updateToReport(MunjaonMsg params) {
	45	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	46	+ return cubridService.updateToReport(params);
	47	+ }
	48	+
	49	+ @Override
	50	+ public List<MunjaonMsg> selectToMove() {
	51	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	52	+ return cubridService.selectToMove();
	53	+ }
	54	+
	55	+ @Override
	56	+ public List<MunjaonMsg> selectToExpire(String expireTime) {
	57	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	58	+ return cubridService.selectToExpire(expireTime);
	59	+ }
	60	+
	61	+ @Override
	62	+ public int insertToLog(String msgId) {
	63	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	64	+ return cubridService.insertToLog(msgId);
	65	+ }
	66	+
	67	+ @Override
	68	+ public int deleteFromDeliver(String msgId) {
	69	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	70	+ return cubridService.deleteFromDeliver(msgId);
	71	+ }
	72	+
	73	+ @Override
	74	+ public void moveToDeliver() {
	75	+ CubridService cubridService = (CubridService) DatabaseService.CUBRID_SERVICE.getService();
	76	+ cubridService.moveToDeliver();
	77	+ }
	78	+ },
16	79	TYPE_OF_MARIADB("MARIADB") {
17	80	@Override
18	81	public boolean checkTableExists() {
...	...	@@ -30,6 +93,12 @@
30	93	public int updateToDeliver(String msgId) {
31	94	MariaDBService mariaDBService = (MariaDBService) DatabaseService.MARIADB_SERVICE.getService();
32	95	return mariaDBService.updateToDeliver(msgId);
	96	+ }
	97	+
	98	+ @Override
	99	+ public int updateDeliverForList(List<String> msgIdList) {
	100	+ MariaDBService mariaDBService = (MariaDBService) DatabaseService.MARIADB_SERVICE.getService();
	101	+ return mariaDBService.updateDeliverForList(msgIdList);
33	102	}
34	103
35	104	@Override
...	...	@@ -88,6 +157,12 @@
88	157	}
89	158
90	159	@Override
	160	+ public int updateDeliverForList(List<String> msgIdList) {
	161	+ OracleService oracleService = (OracleService) DatabaseService.ORACLE_SERVICE.getService();
	162	+ return oracleService.updateDeliverForList(msgIdList);
	163	+ }
	164	+
	165	+ @Override
91	166	public int updateToReport(MunjaonMsg params) {
92	167	OracleService oracleService = (OracleService) DatabaseService.ORACLE_SERVICE.getService();
93	168	return oracleService.updateToReport(params);
...	...	@@ -140,6 +215,12 @@
140	215	public int updateToDeliver(String msgId) {
141	216	MssqlService mssqlService = (MssqlService) DatabaseService.MSSQL_SERVICE.getService();
142	217	return mssqlService.updateToDeliver(msgId);
	218	+ }
	219	+
	220	+ @Override
	221	+ public int updateDeliverForList(List<String> msgIdList) {
	222	+ MssqlService mssqlService = (MssqlService) DatabaseService.MSSQL_SERVICE.getService();
	223	+ return mssqlService.updateDeliverForList(msgIdList);
143	224	}
144	225
145	226	@Override
...	...	@@ -198,6 +279,12 @@
198	279	}
199	280
200	281	@Override
	282	+ public int updateDeliverForList(List<String> msgIdList) {
	283	+ PostgresqlService postgresqlService = (PostgresqlService) DatabaseService.POSTGRESQL_SERVICE.getService();
	284	+ return postgresqlService.updateDeliverForList(msgIdList);
	285	+ }
	286	+
	287	+ @Override
201	288	public int updateToReport(MunjaonMsg params) {
202	289	PostgresqlService postgresqlService = (PostgresqlService) DatabaseService.POSTGRESQL_SERVICE.getService();
203	290	return postgresqlService.updateToReport(params);
...	...	@@ -253,6 +340,12 @@
253	340	}
254	341
255	342	@Override
	343	+ public int updateDeliverForList(List<String> msgIdList) {
	344	+ MysqlService mysqlService = (MysqlService) DatabaseService.MYSQL_SERVICE.getService();
	345	+ return mysqlService.updateDeliverForList(msgIdList);
	346	+ }
	347	+
	348	+ @Override
256	349	public int updateToReport(MunjaonMsg params) {
257	350	MysqlService mysqlService = (MysqlService) DatabaseService.MYSQL_SERVICE.getService();
258	351	return mysqlService.updateToReport(params);
...	...	@@ -287,6 +380,67 @@
287	380	MysqlService mysqlService = (MysqlService) DatabaseService.MYSQL_SERVICE.getService();
288	381	mysqlService.moveToDeliver();
289	382	}
	383	+ },
	384	+ TYPE_OF_TIBERO("TIBERO") {
	385	+ @Override
	386	+ public boolean checkTableExists() {
	387	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	388	+ return tiberoService.checkTableExists();
	389	+ }
	390	+
	391	+ @Override
	392	+ public List<MunjaonMsg> selectToDeliver(String msgType) {
	393	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	394	+ return tiberoService.selectToDeliver(msgType);
	395	+ }
	396	+
	397	+ @Override
	398	+ public int updateToDeliver(String msgId) {
	399	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	400	+ return tiberoService.updateToDeliver(msgId);
	401	+ }
	402	+
	403	+ @Override
	404	+ public int updateDeliverForList(List<String> msgIdList) {
	405	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	406	+ return tiberoService.updateDeliverForList(msgIdList);
	407	+ }
	408	+
	409	+ @Override
	410	+ public int updateToReport(MunjaonMsg params) {
	411	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	412	+ return tiberoService.updateToReport(params);
	413	+ }
	414	+
	415	+ @Override
	416	+ public List<MunjaonMsg> selectToMove() {
	417	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	418	+ return tiberoService.selectToMove();
	419	+ }
	420	+
	421	+ @Override
	422	+ public List<MunjaonMsg> selectToExpire(String expireTime) {
	423	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	424	+ return tiberoService.selectToExpire(expireTime);
	425	+ }
	426	+
	427	+ @Override
	428	+ public int insertToLog(String msgId) {
	429	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	430	+ return tiberoService.insertToLog(msgId);
	431	+ }
	432	+
	433	+ @Override
	434	+ public int deleteFromDeliver(String msgId) {
	435	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	436	+ return tiberoService.deleteFromDeliver(msgId);
	437	+ }
	438	+
	439	+ @Override
	440	+ public void moveToDeliver() {
	441	+ TiberoService tiberoService = (TiberoService) DatabaseService.TIBERO_SERVICE.getService();
	442	+ tiberoService.moveToDeliver();
	443	+ }
290	444	};
291	445
292	446	DatabaseTypeWorker(final String name) {
...	...	@@ -306,6 +460,7 @@
306	460	public abstract boolean checkTableExists();
307	461	public abstract List<MunjaonMsg> selectToDeliver(String msgType);
308	462	public abstract int updateToDeliver(String msgId);
	463	+ public abstract int updateDeliverForList(List<String> msgIdList);;
309	464	public abstract int updateToReport(MunjaonMsg params);
310	465	public abstract List<MunjaonMsg> selectToMove();
311	466	public abstract List<MunjaonMsg> selectToExpire(String expireTime);

...	...	@@ -50,6 +50,18 @@
50	50	, DELIVER_DATE = NOW()
51	51	WHERE MSG_ID = #{msgId}
52	52	</update>
	53	+ <update id="updateDeliverForList" parameterType="java.util.List">
	54	+ /* MariaDBMapper.updateDeliverForList */
	55	+ UPDATE MUNJAON_MSG SET
	56	+ SEND_STATUS = '1'
	57	+ , DELIVER_DATE = NOW()
	58	+ WHERE SEND_STATUS = '0'
	59	+ AND (
	60	+ <foreach separator="OR" item="item" collection="list">
	61	+ MSG_ID = #{item}
	62	+ </foreach>
	63	+ )
	64	+ </update>
53	65	<update id="updateToReport">
54	66	/* MariaDBMapper.updateToReport */
55	67	UPDATE MUNJAON_MSG SET

...	...	@@ -2,24 +2,24 @@
2	2	<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3	3	<mapper namespace="com.munjaon.client.mssql.mapper.MssqlMapper">
4	4	<select id="checkTime" resultType="String">
5		- /* MariaDBMapper.checkTime */
	5	+ /* MssqlMapper.checkTime */
6	6	SELECT GETDATE()
7	7	</select>
8	8	<select id="checkTableForMessage" resultType="int">
9		- /* MariaDBMapper.checkTableForMessage */
	9	+ /* MssqlMapper.checkTableForMessage */
10	10	-- SELECT 1 FROM MUNJAON_MSG WHERE 1=1 LIMIT 1
11	11	<![CDATA[
12	12	SELECT TOP 1 COUNT(MSG_ID) FROM MUNJAON_MSG WHERE 1=1
13	13	]]>
14	14	</select>
15	15	<select id="checkTableForLog" resultType="int">
16		- /* MariaDBMapper.checkTableForLog */
	16	+ /* MssqlMapper.checkTableForLog */
17	17	<![CDATA[
18	18	SELECT TOP 1 COUNT(MSG_ID) FROM MUNJAON_MSG_LOG WHERE 1=1
19	19	]]>
20	20	</select>
21	21	<select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
22		- /* MariaDBMapper.selectToDeliver */
	22	+ /* MssqlMapper.selectToDeliver */
23	23	<![CDATA[
24	24	SELECT
25	25	TOP 100
...	...	@@ -45,14 +45,26 @@
45	45	]]>
46	46	</select>
47	47	<update id="updateToDeliver">
48		- /* MariaDBMapper.updateToDeliver */
	48	+ /* MssqlMapper.updateToDeliver */
49	49	UPDATE MUNJAON_MSG SET
50	50	SEND_STATUS = '1'
51	51	, DELIVER_DATE = GETDATE()
52	52	WHERE MSG_ID = #{msgId}
53	53	</update>
	54	+ <update id="updateDeliverForList">
	55	+ /* MssqlMapper.updateDeliverForList */
	56	+ UPDATE MUNJAON_MSG SET
	57	+ SEND_STATUS = '1'
	58	+ , DELIVER_DATE = GETDATE()
	59	+ WHERE SEND_STATUS = '0'
	60	+ AND (
	61	+ <foreach separator="OR" item="item" collection="list">
	62	+ MSG_ID = #{item}
	63	+ </foreach>
	64	+ )
	65	+ </update>
54	66	<update id="updateToReport">
55		- /* MariaDBMapper.updateToReport */
	67	+ /* MssqlMapper.updateToReport */
56	68	UPDATE MUNJAON_MSG SET
57	69	SEND_STATUS = #{sendStatus}
58	70	, SENT_DATE = CAST(#{sendDate} AS DATETIME)
...	...	@@ -61,7 +73,7 @@
61	73	WHERE MSG_ID = #{msgId}
62	74	</update>
63	75	<select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
64		- /* MariaDBMapper.selectToMove */
	76	+ /* MssqlMapper.selectToMove */
65	77	<![CDATA[
66	78	SELECT TOP 100
67	79	MSG_ID, CONVERT(VARCHAR(6),REQUEST_DATE,112) REQUEST_DATE
...	...	@@ -70,7 +82,7 @@
70	82	]]>
71	83	</select>
72	84	<select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
73		- /* MariaDBMapper.selectToExpire */
	85	+ /* MssqlMapper.selectToExpire */
74	86	<![CDATA[
75	87	SELECT TOP 100
76	88	MSG_ID, CONVERT(VARCHAR(6),REQUEST_DATE,112) REQUEST_DATE
...	...	@@ -80,7 +92,7 @@
80	92	]]>
81	93	</select>
82	94	<insert id="insertToLog">
83		- /* MariaDBMapper.insertToLog */
	95	+ /* MssqlMapper.insertToLog */
84	96	INSERT INTO MUNJAON_MSG_LOG
85	97	(
86	98	MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,
...	...	@@ -95,7 +107,7 @@
95	107	WHERE MSG_ID = #{msgId}
96	108	</insert>
97	109	<delete id="deleteFromDeliver">
98		- /* MariaDBMapper.deleteFromDeliver */
	110	+ /* MssqlMapper.deleteFromDeliver */
99	111	DELETE FROM MUNJAON_MSG
100	112	WHERE MSG_ID = #{msgId}
101	113	</delete>

...	...	@@ -2,25 +2,24 @@
2	2	<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3	3	<mapper namespace="com.munjaon.client.mysql.mapper.MysqlMapper">
4	4	<select id="checkTime" resultType="String">
5		- /* MariaDBMapper.checkTime */
	5	+ /* MysqlMapper.checkTime */
6	6	SELECT DATE_FORMAT(NOW(), '%Y%m%d%H%i%s')
7	7	</select>
8	8	<select id="checkTableForMessage" resultType="int">
9		- /* MariaDBMapper.checkTableForMessage */
10		--- SELECT 1 FROM MUNJAON_MSG WHERE 1=1 LIMIT 1
	9	+ /* MysqlMapper.checkTableForMessage */
11	10	SELECT COUNT(*)
12	11	FROM information_schema.tables
13	12	WHERE TABLE_NAME = 'MUNJAON_MSG'
14	13	</select>
15	14	<select id="checkTableForLog" resultType="int">
16		- /* MariaDBMapper.checkTableForLog */
	15	+ /* MysqlMapper.checkTableForLog */
17	16	SELECT COUNT(*)
18	17	FROM information_schema.tables
19	18	WHERE TABLE_NAME = 'MUNJAON_MSG_LOG'
20	19	-- SELECT 1 FROM MUNJAON_MSG_LOG WHERE 1=1 LIMIT 1
21	20	</select>
22	21	<select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
23		- /* MariaDBMapper.selectToDeliver */
	22	+ /* MysqlMapper.selectToDeliver */
24	23	SELECT
25	24	MSG_ID
26	25	, MSG_TYPE
...	...	@@ -44,14 +43,26 @@
44	43	LIMIT 100
45	44	</select>
46	45	<update id="updateToDeliver">
47		- /* MariaDBMapper.updateToDeliver */
	46	+ /* MysqlMapper.updateToDeliver */
48	47	UPDATE MUNJAON_MSG SET
49	48	SEND_STATUS = '1'
50	49	, DELIVER_DATE = NOW()
51	50	WHERE MSG_ID = #{msgId}
52	51	</update>
	52	+ <update id="updateDeliverForList">
	53	+ /* MysqlMapper.updateToDeliver */
	54	+ UPDATE MUNJAON_MSG SET
	55	+ SEND_STATUS = '1'
	56	+ , DELIVER_DATE = NOW()
	57	+ WHERE SEND_STATUS = '0'
	58	+ AND (
	59	+ <foreach separator="OR" item="item" collection="list">
	60	+ MSG_ID = #{item}
	61	+ </foreach>
	62	+ )
	63	+ </update>
53	64	<update id="updateToReport">
54		- /* MariaDBMapper.updateToReport */
	65	+ /* MysqlMapper.updateToReport */
55	66	UPDATE MUNJAON_MSG SET
56	67	SEND_STATUS = #{sendStatus}
57	68	, SENT_DATE = FROM_UNIXTIME(UNIX_TIMESTAMP(#{sendDate}))
...	...	@@ -60,14 +71,14 @@
60	71	WHERE MSG_ID = #{msgId}
61	72	</update>
62	73	<select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
63		- /* MariaDBMapper.selectToMove */
	74	+ /* MysqlMapper.selectToMove */
64	75	SELECT MSG_ID, DATE_FORMAT(REQUEST_DATE, '%Y%m') REQUEST_DATE
65	76	FROM MUNJAON_MSG
66	77	WHERE SEND_STATUS NOT IN ('0', '1')
67	78	LIMIT 100
68	79	</select>
69	80	<select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
70		- /* MariaDBMapper.selectToExpire */
	81	+ /* MysqlMapper.selectToExpire */
71	82	SELECT MSG_ID, DATE_FORMAT(REQUEST_DATE, '%Y%m') REQUEST_DATE
72	83	FROM MUNJAON_MSG
73	84	WHERE REQUEST_DATE <![CDATA[<]]> FROM_UNIXTIME(UNIX_TIMESTAMP(#{expireTime}))
...	...	@@ -75,7 +86,7 @@
75	86	LIMIT 100
76	87	</select>
77	88	<insert id="insertToLog">
78		- /* MariaDBMapper.insertToLog */
	89	+ /* MysqlMapper.insertToLog */
79	90	INSERT INTO MUNJAON_MSG_LOG
80	91	(
81	92	MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,
...	...	@@ -90,7 +101,7 @@
90	101	WHERE MSG_ID = #{msgId}
91	102	</insert>
92	103	<delete id="deleteFromDeliver">
93		- /* MariaDBMapper.deleteFromDeliver */
	104	+ /* MysqlMapper.deleteFromDeliver */
94	105	DELETE FROM MUNJAON_MSG
95	106	WHERE MSG_ID = #{msgId}
96	107	</delete>

...	...	@@ -2,24 +2,23 @@
2	2	<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3	3	<mapper namespace="com.munjaon.client.oracle.mapper.OracleMapper">
4	4	<select id="checkTime" resultType="String">
5		- /* MariaDBMapper.checkTime */
	5	+ /* OracleMapper.checkTime */
6	6	SELECT TO_CHAR(SYSDATE, 'YYYYMMDDHH24MISS') FROM DUAL
7	7	</select>
8	8	<select id="checkTableForMessage" resultType="int">
9		- /* MariaDBMapper.checkTableForMessage */
10		--- SELECT 1 FROM MUNJAON_MSG WHERE 1=1 LIMIT 1
	9	+ /* OracleMapper.checkTableForMessage */
11	10	<![CDATA[
12	11	SELECT COUNT(MSG_ID) FROM MUNJAON_MSG WHERE 1=1 AND rownum <= 1
13	12	]]>
14	13	</select>
15	14	<select id="checkTableForLog" resultType="int">
16		- /* MariaDBMapper.checkTableForLog */
	15	+ /* OracleMapper.checkTableForLog */
17	16	<![CDATA[
18	17	SELECT COUNT(MSG_ID) FROM MUNJAON_MSG_LOG WHERE 1=1 AND rownum <= 1
19	18	]]>
20	19	</select>
21	20	<select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
22		- /* MariaDBMapper.selectToDeliver */
	21	+ /* OracleMapper.selectToDeliver */
23	22	<![CDATA[
24	23	SELECT
25	24	MSG_ID
...	...	@@ -45,14 +44,26 @@
45	44	]]>
46	45	</select>
47	46	<update id="updateToDeliver">
48		- /* MariaDBMapper.updateToDeliver */
	47	+ /* OracleMapper.updateToDeliver */
49	48	UPDATE MUNJAON_MSG SET
50	49	SEND_STATUS = '1'
51	50	, DELIVER_DATE = SYSDATE
52	51	WHERE MSG_ID = #{msgId}
53	52	</update>
	53	+ <update id="updateDeliverForList">
	54	+ /* OracleMapper.updateToDeliver */
	55	+ UPDATE MUNJAON_MSG SET
	56	+ SEND_STATUS = '1'
	57	+ , DELIVER_DATE = SYSDATE
	58	+ WHERE SEND_STATUS = '0'
	59	+ AND (
	60	+ <foreach separator="OR" item="item" collection="list">
	61	+ MSG_ID = #{item}
	62	+ </foreach>
	63	+ )
	64	+ </update>
54	65	<update id="updateToReport">
55		- /* MariaDBMapper.updateToReport */
	66	+ /* OracleMapper.updateToReport */
56	67	UPDATE MUNJAON_MSG SET
57	68	SEND_STATUS = #{sendStatus}
58	69	, SENT_DATE = TO_DATE(#{sendDate}, 'YYYYMMDDHH24MISS')
...	...	@@ -61,7 +72,7 @@
61	72	WHERE MSG_ID = #{msgId}
62	73	</update>
63	74	<select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
64		- /* MariaDBMapper.selectToMove */
	75	+ /* OracleMapper.selectToMove */
65	76	<![CDATA[
66	77	SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
67	78	FROM MUNJAON_MSG
...	...	@@ -70,7 +81,7 @@
70	81	]]>
71	82	</select>
72	83	<select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
73		- /* MariaDBMapper.selectToExpire */
	84	+ /* OracleMapper.selectToExpire */
74	85	<![CDATA[
75	86	SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
76	87	FROM MUNJAON_MSG
...	...	@@ -80,7 +91,7 @@
80	91	]]>
81	92	</select>
82	93	<insert id="insertToLog">
83		- /* MariaDBMapper.insertToLog */
	94	+ /* OracleMapper.insertToLog */
84	95	INSERT INTO MUNJAON_MSG_LOG
85	96	(
86	97	MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,
...	...	@@ -95,7 +106,7 @@
95	106	WHERE MSG_ID = #{msgId}
96	107	</insert>
97	108	<delete id="deleteFromDeliver">
98		- /* MariaDBMapper.deleteFromDeliver */
	109	+ /* OracleMapper.deleteFromDeliver */
99	110	DELETE FROM MUNJAON_MSG
100	111	WHERE MSG_ID = #{msgId}
101	112	</delete>

...	...	@@ -2,19 +2,19 @@
2	2	<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3	3	<mapper namespace="com.munjaon.client.postgresql.mapper.PostgresqlMapper">
4	4	<select id="checkTime" resultType="String">
5		- /* MariaDBMapper.checkTime */
	5	+ /* PostgresqlMapper.checkTime */
6	6	SELECT TO_CHAR(NOW(), 'YYYYMMDDHH24MISS') FROM DUAL
7	7	</select>
8	8	<select id="checkTableForMessage" resultType="int">
9		- /* MariaDBMapper.checkTableForMessage */
	9	+ /* PostgresqlMapper.checkTableForMessage */
10	10	SELECT COUNT(MSG_ID) FROM MUNJAON_MSG WHERE 1=1 LIMIT 1
11	11	</select>
12	12	<select id="checkTableForLog" resultType="int">
13		- /* MariaDBMapper.checkTableForLog */
	13	+ /* PostgresqlMapper.checkTableForLog */
14	14	SELECT COUNT(MSG_ID) FROM MUNJAON_MSG_LOG WHERE 1=1 LIMIT 1
15	15	</select>
16	16	<select id="selectToDeliver" resultType="com.munjaon.client.model.MunjaonMsg">
17		- /* MariaDBMapper.selectToDeliver */
	17	+ /* PostgresqlMapper.selectToDeliver */
18	18	<![CDATA[
19	19	SELECT
20	20	MSG_ID
...	...	@@ -40,14 +40,26 @@
40	40	]]>
41	41	</select>
42	42	<update id="updateToDeliver">
43		- /* MariaDBMapper.updateToDeliver */
	43	+ /* PostgresqlMapper.updateToDeliver */
44	44	UPDATE MUNJAON_MSG SET
45	45	SEND_STATUS = '1'
46	46	, DELIVER_DATE = NOW()
47	47	WHERE MSG_ID = #{msgId}
48	48	</update>
	49	+ <update id="updateDeliverForList">
	50	+ /* PostgresqlMapper.updateDeliverForList */
	51	+ UPDATE MUNJAON_MSG SET
	52	+ SEND_STATUS = '1'
	53	+ , DELIVER_DATE = NOW()
	54	+ WHERE SEND_STATUS = '0'
	55	+ AND (
	56	+ <foreach separator="OR" item="item" collection="list">
	57	+ MSG_ID = #{item}
	58	+ </foreach>
	59	+ )
	60	+ </update>
49	61	<update id="updateToReport">
50		- /* MariaDBMapper.updateToReport */
	62	+ /* PostgresqlMapper.updateToReport */
51	63	UPDATE MUNJAON_MSG SET
52	64	SEND_STATUS = #{sendStatus}
53	65	, SENT_DATE = TO_DATE(#{sendDate}, 'YYYYMMDDHH24MISS')
...	...	@@ -56,7 +68,7 @@
56	68	WHERE MSG_ID = #{msgId}
57	69	</update>
58	70	<select id="selectToMove" resultType="com.munjaon.client.model.MunjaonMsg">
59		- /* MariaDBMapper.selectToMove */
	71	+ /* PostgresqlMapper.selectToMove */
60	72	<![CDATA[
61	73	SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
62	74	FROM MUNJAON_MSG
...	...	@@ -65,7 +77,7 @@
65	77	]]>
66	78	</select>
67	79	<select id="selectToExpire" resultType="com.munjaon.client.model.MunjaonMsg">
68		- /* MariaDBMapper.selectToExpire */
	80	+ /* PostgresqlMapper.selectToExpire */
69	81	<![CDATA[
70	82	SELECT MSG_ID, TO_CHAR(REQUEST_DATE, 'YYYYMM') REQUEST_DATE
71	83	FROM MUNJAON_MSG
...	...	@@ -75,7 +87,7 @@
75	87	]]>
76	88	</select>
77	89	<insert id="insertToLog">
78		- /* MariaDBMapper.insertToLog */
	90	+ /* PostgresqlMapper.insertToLog */
79	91	INSERT INTO MUNJAON_MSG_LOG
80	92	(
81	93	MSG_ID, MSG_TYPE, SEND_STATUS, REQUEST_DATE,
...	...	@@ -90,7 +102,7 @@
90	102	WHERE MSG_ID = #{msgId}
91	103	</insert>
92	104	<delete id="deleteFromDeliver">
93		- /* MariaDBMapper.deleteFromDeliver */
	105	+ /* PostgresqlMapper.deleteFromDeliver */
94	106	DELETE FROM MUNJAON_MSG
95	107	WHERE MSG_ID = #{msgId}
96	108	</delete>

Delete comment