添加TimerService

src/main/java/com/vcarecity/cvs/module/SQLModule.java

 
         Class<? extends ResultHandlerService> resultClass;
         if (isMysql) {
-            // resultClass = MySQLResultStatHandlerServiceImpl.class;
-            resultClass = MySQLResultHandlerServiceImpl.class;
+             resultClass = MySQLResultStatHandlerServiceImpl.class;
+            //resultClass = MySQLResultHandlerServiceImpl.class;
         } else {
             resultClass = CSVResultHandlerServiceImpl.class;
         }

src/main/java/com/vcarecity/cvs/service/TimerService.java

+package com.vcarecity.cvs.service;
+
+/**
+ * @author Kerry on 19/12/03
+ */
+
+public interface TimerService {
+
+    /**
+     * 获取时间
+     *
+     * @return
+     */
+    long getUsageTime();
+
+}

src/main/java/com/vcarecity/cvs/service/impl/AbstractSQLQueryService.java

 
 import com.vcarecity.cvs.core.AutoMapper;
 import com.vcarecity.cvs.service.SQLQueryService;
+import com.vcarecity.cvs.service.TimerService;
 import com.zaxxer.hikari.HikariDataSource;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Set;
+import java.util.concurrent.atomic.AtomicLong;
 import java.util.stream.Collectors;
 
 import static com.vcarecity.cvs.FileExporterApp.TABLE_COLUMN;
  */
 
 @Slf4j
-public abstract class AbstractSQLQueryService implements SQLQueryService {
+public abstract class AbstractSQLQueryService implements SQLQueryService, TimerService {
 
     private boolean isFirst = true;
 
+    private AtomicLong readTime = new AtomicLong(0L);
 
     protected final HikariDataSource dataSource;
 
 
         List<T> list = resultMapper(table, resultSet, clazz);
 
-        logger.info("QUERY SUCCESS. size = {}. usageTime = {} /ms", list.size(), (System.currentTimeMillis() - startTime));
-
         resultSet.close();
         preparedStatement.close();
         connection.close();
 
+        final long curReadTime = System.currentTimeMillis() - startTime;
+
+        readTime.addAndGet(curReadTime);
+
+        logger.info("QUERY SUCCESS. size = {}. usageTime = {} /ms", list.size(), curReadTime);
+
         return list;
     }
 
         return list;
     }
 
+    @Override
+    public long getUsageTime() {
+        return this.readTime.longValue();
+    }
 }

src/main/java/com/vcarecity/cvs/service/impl/MySQLResultHandlerServiceImpl.java

 import com.vcarecity.cvs.core.ColumnUpdateMapper;
 import com.vcarecity.cvs.properties.AppProperties;
 import com.vcarecity.cvs.service.ResultHandlerService;
+import com.vcarecity.cvs.service.TimerService;
 import com.vcarecity.cvs.util.CreateDatasource;
 import com.zaxxer.hikari.HikariDataSource;
 import lombok.extern.slf4j.Slf4j;
 import java.sql.PreparedStatement;
 import java.util.Arrays;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicLong;
 
 /**
  * @author Kerry on 19/11/21
 
 
 @Slf4j
-public class MySQLResultHandlerServiceImpl implements ResultHandlerService {
+public class MySQLResultHandlerServiceImpl implements ResultHandlerService, TimerService {
 
-    private final String sql;
     private final HikariDataSource dataSource;
 
+    private AtomicLong writeTime = new AtomicLong(0L);
+
     @Inject
     public MySQLResultHandlerServiceImpl(AppProperties properties, @Assisted Object sql) {
-        this.sql = (String) sql;
         this.dataSource = CreateDatasource.createDataSource(properties.getToDb());
     }
 
 
         final String sql = getSql(table, header);
 
-
         long startTime = System.currentTimeMillis();
 
         logger.debug("{},{}", dataList.size(), sql);
         } finally {
             connection.close();
         }
-        logger.info("WRITE SUCCESS to mysql usage time {} /ms, size = {}", System.currentTimeMillis() - startTime, dataList.size());
+
+        final long curUseTime = System.currentTimeMillis() - startTime;
+
+        writeTime.addAndGet(curUseTime);
+
+        logger.info("WRITE SUCCESS to mysql usage time {} /ms, size = {}", curUseTime, dataList.size());
     }
 
 
         return "INSERT INTO " + table + "(" + column + ") VALUES(" + join + ")";
 
     }
+
+    @Override
+    public long getUsageTime() {
+        return this.writeTime.longValue();
+    }
 }

src/main/java/com/vcarecity/cvs/service/impl/MySQLResultStatHandlerServiceImpl.java

 import com.vcarecity.cvs.core.ColumnUpdateMapper;
 import com.vcarecity.cvs.properties.AppProperties;
 import com.vcarecity.cvs.service.ResultHandlerService;
+import com.vcarecity.cvs.service.TimerService;
 import com.vcarecity.cvs.util.CreateDatasource;
 import com.zaxxer.hikari.HikariDataSource;
 import lombok.extern.slf4j.Slf4j;
 import java.sql.Statement;
 import java.sql.Timestamp;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicLong;
 
 /**
  * @author Kerry on 19/11/21
 
 
 @Slf4j
-public class MySQLResultStatHandlerServiceImpl implements ResultHandlerService {
+public class MySQLResultStatHandlerServiceImpl implements ResultHandlerService, TimerService {
 
-
-    private final String sql;
     private final HikariDataSource dataSource;
 
+    private AtomicLong writeTime = new AtomicLong(0L);
+
     @Inject
     public MySQLResultStatHandlerServiceImpl(AppProperties properties, @Assisted Object sql) {
-        this.sql = (String) sql;
         this.dataSource = CreateDatasource.createDataSource(properties.getToDb());
     }
 
-
     @Override
     public <T> void resultHandler(String table, String[] header, List<T> dataList) throws Exception {
 
-
+        if (dataList == null || dataList.isEmpty()) {
+            return;
+        }
         long startTime = System.currentTimeMillis();
 
-        StringBuffer sb = new StringBuffer();
+        StringBuilder sb = new StringBuilder();
 
         final String[] newHeaders = ColumnUpdateMapper.updateColumnName(table, header);
         final String column = String.join(",", newHeaders);
                 sb.append("),");
             }
         }
-        final StringBuffer stringBuffer = sb.deleteCharAt(sb.length() - 1);
+        String execSql = sb.deleteCharAt(sb.length() - 1).toString();
 
-        // logger.debug("{}", stringBuffer.toString());
+        // logger.debug("{}", execSql);
 
         final Connection connection = dataSource.getConnection();
 
         final Statement statement = connection.createStatement();
-        statement.execute(stringBuffer.toString());
+        statement.execute(execSql);
         statement.close();
         connection.close();
 
-        logger.info("WRITE SUCCESS to mysql usage time {} /ms, size = {}", System.currentTimeMillis() - startTime, dataList.size());
+        final long curUseTime = System.currentTimeMillis() - startTime;
+
+        writeTime.addAndGet(curUseTime);
+
+        logger.info("WRITE SUCCESS to mysql usage time {} /ms, size = {}", curUseTime, dataList.size());
     }
 
 
+    @Override
+    public long getUsageTime() {
+        return this.writeTime.longValue();
+    }
 }

src/main/java/com/vcarecity/cvs/starter/SQLStarter.java

 import com.vcarecity.cvs.factory.ResultHandlerFactory;
 import com.vcarecity.cvs.service.ResultHandlerService;
 import com.vcarecity.cvs.service.SQLQueryService;
+import com.vcarecity.cvs.service.TimerService;
 import com.vcarecity.cvs.service.impl.CSVResultHandlerServiceImpl;
 import lombok.extern.slf4j.Slf4j;
 
             ((CSVResultHandlerServiceImpl) resultHandler).close();
         }
 
-
         final String[] headers = TABLE_COLUMN.get(table);
         final String[] mysqlHeader = ColumnUpdateMapper.updateColumnName(table, headers);
 
         logger.info("mysql header: {}", String.join(",", mysqlHeader));
-
-        logger.info("stop query database...{} /ms.", (System.currentTimeMillis() - startTime));
+        logger.info("query sql usage time {} /ms", ((TimerService) queryService).getUsageTime());
+        logger.info("write sql usage time {} /ms", ((TimerService) resultHandler).getUsageTime());
+        logger.info("all usage time {} /ms.", (System.currentTimeMillis() - startTime));
     }
 
 }