BeeCP is a small JDBC connection pool: high performance, lightweight code and good stability.
- Support main popular database drivers
- Support XAConnection/JTA
- Pool features:CAS,single connection cache, queue reuse, non move waiting self spin, asynchronous add , safe close,web monitor and so on
- Good robustness and quick response to unexpected situations (such as network disconnection and database service crash)
- Good interface extensibility
Java7+
<dependency>
<groupId>com.github.chris2018998</groupId>
<artifactId>beecp</artifactId>
<version>4.1.2</version>
</dependency>
Java6
<dependency>
<groupId>com.github.chris2018998</groupId>
<artifactId>beecp</artifactId>
<version>1.6.10</version>
</dependency>
BeeDataSourceConfig config = new BeeDataSourceConfig();
config.setDriverClassName("com.mysql.jdbc.Driver");
config.setJdbcUrl("jdbc:mysql://localhost/test");
config.setUsername("root");
config.setPassword("root");
BeeDataSource ds=new BeeDataSource(config);
Connection con=ds.getConnection();
....
application.properties
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.url=jdbc:mysql://localhost/test
spring.datasource.driverClassName=com.mysql.jdbc.Driver
DataSourceConfig.java
@Configuration
public class DataSourceConfig {
@Value("${spring.datasource.username}")
private String user;
@Value("${spring.datasource.password}")
private String password;
@Value("${spring.datasource.url}")
private String url;
@Value("${spring.datasource.driverClassName}")
private String driver;
@Bean
@Primary
@ConfigurationProperties(prefix="spring.datasource")
public DataSource primaryDataSource() {
return DataSourceBuilder.create().type(cn.beecp.BeeDataSource.class).build();
}
@Bean
public DataSource secondDataSource() {
return new BeeDataSource(new BeeDataSourceConfig(driver,url,user,password));
}
}
Two ways are provided in pool
- Jmx mbean
- Pool Vo(get it by call datasource method:getPoolMonitorVo)
☀️ If your project is using beecp and base on springboot, we recommend our datasource management tool:BeeCP-Starter (web ui, no code development ,just some configuration)
Compare Item | BeeCP | HikariCP |
---|---|---|
key technology | ThreadLocal,Semaphore,ConcurrentLinkedQueue,Thread | FastList,ConcurrentBag,ThreadPoolExecutor |
Similarities | CAS,pre-generate proxy,driver statement cache | |
Difference | fair mode,supprt XA,recycle hold-timeout connection,single connection cache,queue reuse,non move waiting spin | pool pause |
Files | 37 files,95KB Jar | 44 files,158KB Jar |
Performance | 40 percent faster (HikariCP bench) |
Two interfaces,which are using to create raw connection or raw XAConnection for self-implement and its subclass name need set to 'connectionFactoryClassName' in Bee DataSourceConfig object.
Example
Item Name | Desc | Default |
---|---|---|
username | a username link to db | null |
password | password of a db user | null |
jdbcUrl | url link to db | null |
driverClassName | jdbc driver class name | null |
poolName | a generation name assgin to it if not set | null |
fairMode | pool work mode | false |
initialSize | connection number of creation on pool initizization | 0 |
asyncCreateInitConnection | creation mode for initial connections | false(synchronization mode) |
maxActive | max reachable count of connections in pool | 10 |
borrowSemaphoreSize | max permit size of pool semaphore | min(maxActive/2,CPU size) |
defaultAutoCommit | initial value of autoCommit prop on created connections | null,read prop value from first connection as initial value for other connections |
defaultTransactionIsolationCode | initial value of transactionIsolation prop on created connections | null,read prop value from first connection as initial value for other connections |
enableThreadLocal | thread local cache enable indicator | true,set false to support virtual threads |
defaultCatalog | initial value of catalog prop on created connections | null,read prop value from first connection as initial value for other connections |
defaultSchema | initial value of schema prop on created connections | null,read prop value from first connection as initial value for other connections |
defaultReadOnly | initial value of readOnly prop on created connections | null,read prop value from first connection as initial value for other connections |
maxWait | max wait time in pool for borrowers to get connection,time unit:milliseconds | 8000 |
idleTimeout | idle time out for connections in pool,time unit:milliseconds | 18000 |
holdTimeout | max inactive time of borrowed connections,time unit:milliseconds | 0(never timeout) |
aliveTestSql | alive test sql on borrowed connections,pool remove dead connections | SELECT 1 |
aliveTestTimeout | max wait time to get validation result on test connectionstime unit:seconds | 3 |
aliveAssumeTime | a gap time value from last activity time to borrowed time point,if less,not test,time unit:milliseconds | 500 |
forceCloseUsingOnClear | indicator on direct closing borrowed connections while pool clears | false |
timerCheckInterval | an interval time to scan idle connections,time unit:milliseconds | 18000 |
connectionFactoryClassName | connection factory class name | null |
sqlExceptionCodeList | store sql exception codes for connection eviction check | null,related methods:addSqlExceptionCode,removeSqlExceptionCode |
sqlExceptionStateList | store sql exception state for connection eviction check | null,related methods:addSqlExceptionCode,removeSqlExceptionCode |
evictPredicateClassName | eviction predicate class name | null,pool only it to check exception if set |
jdbcLinkInfoDecoderClassName | short lifecycle object and used to decode jdbc link info | null |
forceDirtyOnSchemaAfterSet | dirty force indicator on schema property under PG driver | false |
forceDirtyOnCatalogAfterSet | dirty force indicator on schema property under PG driver | false |
enableJmx | enable indicator to register configuration and pool to Jmx | false |
printConfigInfo | boolean indicator,true:print config item info on pool starting | false |
printRuntimeLog | boolean indicator,true:print runtime log | false |