diff --git a/tests/examples/JDBC/connectionPools/pom.xml b/tests/examples/JDBC/connectionPools/pom.xml
index fc489f7f1d2bfc9eaca4574ef00bd8c576eb222b..82082157a64e626a1659307c8f73dfb8e821dcfe 100644
--- a/tests/examples/JDBC/connectionPools/pom.xml
+++ b/tests/examples/JDBC/connectionPools/pom.xml
@@ -55,13 +55,7 @@
com.taosdata.jdbc
taos-jdbcdriver
- 2.0.13
-
-
-
- org.springframework
- spring-context
- 5.2.8.RELEASE
+ 2.0.12
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 4e29e2642392db2502062b6e0cd07e6e223a5bb7..2e70b4ee40d000e6d7a0e0f477bbfeb1e58df037 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 + "");