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