druid:java代码创建连接池


PropertiesDB 是一个读取配置文件的类,也可以不用,每个参数直接用String代替。

public DataSource dataSource(PropertiesDB propertiesDB) {
    DruidDataSource dataSource = new DruidDataSource();
    dataSource.setUrl(propertiesDB.getUrl());
    dataSource.setDriverClassName(propertiesDB.getDriverClassName());
    dataSource.setUsername(propertiesDB.getUsername());
    dataSource.setPassword(propertiesDB.getPassword());
    if (StringUtils.isNotBlank(propertiesDB.getConnectionProperties())) {
      dataSource.setConnectionProperties(propertiesDB.getConnectionProperties());
    }
    dataSource.setInitialSize(propertiesDB.getInitialSize());
    dataSource.setMinIdle(propertiesDB.getMinIdle());
    dataSource.setMaxWait(propertiesDB.getMaxActive());
    dataSource.setMaxActive(propertiesDB.getMaxActive());
    dataSource.setTimeBetweenEvictionRunsMillis(propertiesDB.getTimeBetweenEvictionRunsMillis());
    dataSource.setMinEvictableIdleTimeMillis(propertiesDB.getMinEvictableIdleTimeMillis());
    dataSource.setTestWhileIdle(propertiesDB.getTestWhileIdle());
    if (StringUtils.isNotBlank(propertiesDB.getValidationQuery())) {
      dataSource.setValidationQuery(propertiesDB.getValidationQuery());
    }
    dataSource.setTestOnBorrow(propertiesDB.getTestOnBorrow());
    dataSource.setTestOnReturn(propertiesDB.getTestOnReturn());
    dataSource.setPoolPreparedStatements(propertiesDB.getPoolPreparedStatements());
    dataSource.setMaxPoolPreparedStatementPerConnectionSize(
        propertiesDB.getMaxPoolPreparedStatementPerConnectionSize());
    if (StringUtils.isNotBlank(propertiesDB.getFilters())) {
      try {
        dataSource.setFilters(propertiesDB.getFilters());
      } catch (SQLException e) {
        logger.error("初始化数据库连接池发生异常:{}", e.toString());
      }
    }
    return dataSource;
  }


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM