[TD-2597]<fix>: fix Druid and HikariCP configurations

This commit is contained in:
zyyang 2021-01-26 17:34:34 +08:00
parent bc99b24e0b
commit c5b69e7109
2 changed files with 14 additions and 11 deletions

View File

@ -10,20 +10,18 @@ public class DruidPoolBuilder {
final String url = "jdbc:TAOS://" + host + ":6030"; final String url = "jdbc:TAOS://" + host + ":6030";
DruidDataSource dataSource = new DruidDataSource(); DruidDataSource dataSource = new DruidDataSource();
// jdbc properties
dataSource.setUrl(url); dataSource.setUrl(url);
dataSource.setDriverClassName("com.taosdata.jdbc.TSDBDriver"); dataSource.setDriverClassName("com.taosdata.jdbc.TSDBDriver");
dataSource.setUsername("root"); dataSource.setUsername("root");
dataSource.setPassword("taosdata"); dataSource.setPassword("taosdata");
//初始连接数默认0 // pool configurations
dataSource.setInitialSize(poolSize); dataSource.setInitialSize(poolSize);//初始连接数默认0
//最大连接数默认8 dataSource.setMinIdle(poolSize);//最小闲置数
dataSource.setMaxActive(poolSize); dataSource.setMaxActive(poolSize);//最大连接数默认8
//最小闲置数 dataSource.setMaxWait(30000);//获取连接的最大等待时间单位毫秒
dataSource.setMinIdle(poolSize); dataSource.setValidationQuery("select server_status()");
//获取连接的最大等待时间单位毫秒
dataSource.setMaxWait(2000);
return dataSource; return dataSource;
} }

View File

@ -9,13 +9,18 @@ public class HikariCpBuilder {
public static DataSource getDataSource(String host, int poolSize) { public static DataSource getDataSource(String host, int poolSize) {
HikariConfig config = new HikariConfig(); HikariConfig config = new HikariConfig();
// jdbc properties
config.setDriverClassName("com.taosdata.jdbc.TSDBDriver"); config.setDriverClassName("com.taosdata.jdbc.TSDBDriver");
config.setJdbcUrl("jdbc:TAOS://" + host + ":6030"); config.setJdbcUrl("jdbc:TAOS://" + host + ":6030");
config.setUsername("root"); config.setUsername("root");
config.setPassword("taosdata"); config.setPassword("taosdata");
// pool configurations
config.setMinimumIdle(3); //minimum number of idle connection
config.setMaximumPoolSize(10); //maximum number of connection in the pool
config.setConnectionTimeout(30000); //maximum wait milliseconds for get connection from pool
config.setIdleTimeout(0); // max idle time for recycle idle connection
config.setConnectionTestQuery("select server_status()"); //validation query
config.setMaximumPoolSize(poolSize);
config.setMinimumIdle(poolSize);
HikariDataSource ds = new HikariDataSource(config); HikariDataSource ds = new HikariDataSource(config);
return ds; return ds;
} }