From 88f07794cd38bc74967099fa5a0ba0c381b1c217 Mon Sep 17 00:00:00 2001 From: huoyo <1729913829@qq.com> Date: Sat, 28 May 2022 19:51:57 +0800 Subject: [PATCH] optimize the saver of database --- src/main/java/cn/langpy/kotime/data/DataBase.java | 5 ----- src/main/java/cn/langpy/kotime/service/InvokedQueue.java | 6 ------ src/main/java/cn/langpy/kotime/util/DataBaseUtil.java | 4 ++-- 3 files changed, 2 insertions(+), 13 deletions(-) diff --git a/src/main/java/cn/langpy/kotime/data/DataBase.java b/src/main/java/cn/langpy/kotime/data/DataBase.java index 52a9cc1..bd7641e 100644 --- a/src/main/java/cn/langpy/kotime/data/DataBase.java +++ b/src/main/java/cn/langpy/kotime/data/DataBase.java @@ -11,13 +11,11 @@ import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Component; import org.springframework.util.StringUtils; -import javax.sql.DataSource; import java.lang.reflect.Parameter; import java.math.BigDecimal; import java.sql.Connection; import java.sql.SQLException; import java.util.*; -import java.util.concurrent.locks.ReentrantLock; import java.util.logging.Logger; import java.util.stream.Collectors; @@ -71,10 +69,7 @@ public class DataBase implements GraphService { methodNode.getRouteName(), methodNode.getMethodType().name() }; - long start1 = System.currentTimeMillis(); DataBaseUtil.insert(getWriteConnection(),KoSqlConstant.addMethod, params); - long end1 = System.currentTimeMillis(); - log.info("插入耗时" + (end1 - start1) / 1000.0); } else { if (methodNode.getMethodType() == MethodType.Controller && !StringUtils.isEmpty(methodNode.getRouteName())) { Object[] params = new Object[]{ diff --git a/src/main/java/cn/langpy/kotime/service/InvokedQueue.java b/src/main/java/cn/langpy/kotime/service/InvokedQueue.java index 7baff86..c73e344 100644 --- a/src/main/java/cn/langpy/kotime/service/InvokedQueue.java +++ b/src/main/java/cn/langpy/kotime/service/InvokedQueue.java @@ -39,10 +39,4 @@ public class InvokedQueue { } } - public static void main(String[] args) { - InvokedQueue.add(new InvokedInfo()); - System.out.println(InvokedQueue.linkedList.size()); - InvokedQueue.linkedList.poll(); - System.out.println(InvokedQueue.linkedList.size()); - } } diff --git a/src/main/java/cn/langpy/kotime/util/DataBaseUtil.java b/src/main/java/cn/langpy/kotime/util/DataBaseUtil.java index b2fc223..612f993 100644 --- a/src/main/java/cn/langpy/kotime/util/DataBaseUtil.java +++ b/src/main/java/cn/langpy/kotime/util/DataBaseUtil.java @@ -15,12 +15,12 @@ import java.util.logging.Logger; public class DataBaseUtil { public static Logger log = Logger.getLogger(DataBaseUtil.class.toString()); + static Map tableInfoMap = new ConcurrentHashMap<>(); public static DataSource getDataSource() { return Context.getDataSource(); } - public static int insert(String sql, Object[] values) { try { Connection connection = getDataSource().getConnection(); @@ -41,7 +41,7 @@ public class DataBaseUtil { int n = statement.executeUpdate(); return n; } catch (SQLIntegrityConstraintViolationException e) { - log.warning("Duplicate id:" + values[0]); + log.info("Duplicate Method id:" + values[0]); } catch (SQLException throwables) { throwables.printStackTrace(); } finally {