From 1d2629082fec6eb818851ea3901547da00a2d43b Mon Sep 17 00:00:00 2001
From: zyyang <zyyang@taosdata.com>
Date: Mon, 30 Nov 2020 13:38:31 +0800
Subject: [PATCH] change

---
 tests/examples/JDBC/connectionPools/pom.xml          |  8 +-------
 .../java/com/taosdata/demo/ConnectionPoolDemo.java   | 12 +++---------
 2 files changed, 4 insertions(+), 16 deletions(-)

diff --git a/tests/examples/JDBC/connectionPools/pom.xml b/tests/examples/JDBC/connectionPools/pom.xml
index fc489f7f1d..82082157a6 100644
--- a/tests/examples/JDBC/connectionPools/pom.xml
+++ b/tests/examples/JDBC/connectionPools/pom.xml
@@ -55,13 +55,7 @@
         <dependency>
             <groupId>com.taosdata.jdbc</groupId>
             <artifactId>taos-jdbcdriver</artifactId>
-            <version>2.0.13</version>
-        </dependency>
-
-        <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-context</artifactId>
-            <version>5.2.8.RELEASE</version>
+            <version>2.0.12</version>
         </dependency>
 
     </dependencies>
diff --git a/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java b/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java
index 4e29e26423..2e70b4ee40 100644
--- a/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java
+++ b/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java
@@ -6,13 +6,11 @@ import com.taosdata.demo.pool.DbcpBuilder;
 import com.taosdata.demo.pool.DruidPoolBuilder;
 import com.taosdata.demo.pool.HikariCpBuilder;
 import org.apache.log4j.Logger;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 import javax.sql.DataSource;
 import java.sql.Connection;
 import java.sql.SQLException;
 import java.sql.Statement;
-import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
@@ -88,12 +86,9 @@ public class ConnectionPoolDemo {
         init(dataSource);
 
 
-        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(20);
-        executor.setMaxPoolSize(100);
-        executor.setQueueCapacity(100);
-        executor.setKeepAliveSeconds(300);
-//        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(threadPoolSize);
+//        ExecutorService executor = Executors.newFixedThreadPool(tableSize);
+
+        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(threadPoolSize);
         while (true) {
             executor.execute(new InsertTask(dataSource, dbName, tableSize, batchSize));
             logger.info("thread pool size : " + executor.getPoolSize() + ", active pool size: " + executor.getActiveCount());
@@ -103,7 +98,6 @@ public class ConnectionPoolDemo {
     }
 
     private static void init(DataSource dataSource) {
-
         try (Connection conn = dataSource.getConnection()) {
             execute(conn, "drop database if exists " + dbName + "");
             execute(conn, "create database if not exists " + dbName + "");
-- 
GitLab