import org.apache.commons.dbcp2.BasicDataSourceFactory; //导入依赖的package包/类
public JdbcModule() {

		Properties props = new Properties();
		try (InputStream istream = Thread.currentThread().getContextClassLoader().getResourceAsStream("jdbc.properties")) {
			if (istream == null)
				throw new FileNotFoundException("Could not find JDBC properties");
			props.load(istream);
			dataSource = BasicDataSourceFactory.createDataSource(props);
		} catch (Exception e) {
			throw new RuntimeException("Unable to initialize DataSource", e);
		}

		this.connectionProvider = new TxConnectionProvider(dataSource);
		this.transactionInterceptor = new TransactionInterceptor(connectionProvider);

	}
 

import org.apache.commons.dbcp2.BasicDataSourceFactory; //导入依赖的package包/类
public MysqlCrawlProcessor(MysqlCrawlProcessorConfig config) throws Exception{
    
    super(Math.max(config.tableList.size() + 1, config.concurrentCrawlCount), 
            new ThreadPoolExecutor(
                    config.concurrentCrawlCount, 
                    config.concurrentCrawlCount, 
                    10, 
                    TimeUnit.MINUTES, 
                    new LinkedBlockingQueue<>()));
    
    config.checkValidation();
    this.config = config;
    
    Set<String> dbNameSet = new HashSet<>();
    for(String tableName : config.tableList){
        dbNameSet.add(tableName.split("\\.")[0]);
    }
    this.serverInfo = new MysqlServerInfo(config.host, config.port, config.user, config.password, new ArrayList<>(dbNameSet));
    
    // data source
    final String url = "jdbc:mysql://" + config.host + ":" + config.port + "/?" + config.jdbcConnParam;
    this.dataSource = BasicDataSourceFactory.createDataSource(config.dbcp2Properties);
    this.dataSource.setUrl(url);
    this.dataSource.setUsername(config.user);
    this.dataSource.setPassword(config.password);
    
    // init handler
    @SuppressWarnings("unchecked")
    final Class<? extends MysqlCrawlProcessorHandler> handlerClass = 
            (Class<? extends MysqlCrawlProcessorHandler>) Class.forName(config.handlerClassName);
    handler = handlerClass.newInstance();
    if(!(handler instanceof MysqlCrawlProcessorHandler)){
        throw new IllegalArgumentException("Class [" + config.handlerClassName + "] is invalid.");
    }
    
}
 

import org.apache.commons.dbcp2.BasicDataSourceFactory; //导入依赖的package包/类
private void example3() throws Exception {
/**/DebugTrace.enter();

	DataSource dataSource = BasicDataSourceFactory.createDataSource(new Properties());
/**/DebugTrace.print("dataSource", dataSource);

/**/DebugTrace.leave();
}
 

import org.apache.commons.dbcp2.BasicDataSourceFactory; //导入依赖的package包/类
@Bean(value = "cityInfoDS", destroyMethod = "") //Disable destroy method here to avoid warning for duplicated shutdown
@Primary
public DataSource primaryDataSource() throws Exception {
    return BasicDataSourceFactory.createDataSource(primaryDataSourceProperties());
}
 

import org.apache.commons.dbcp2.BasicDataSourceFactory; //导入依赖的package包/类
@Bean(destroyMethod = "")
public DataSource anotherDataSource() throws Exception {
    return BasicDataSourceFactory.createDataSource(anotherDataSourceProperties());
}
 

import org.apache.commons.dbcp2.BasicDataSourceFactory; //导入依赖的package包/类
@Override
public DataSource build(DataSourceConfigProperties configurationProperties) throws ConfigurationException {

	final String dataContextId = configurationProperties.getDataContextId().orElse(null);

	final String url = configurationProperties.getConfigPropertyValue(DataSourceConfigProperties.URL, null);
	if (url == null) {
		throw new ConfigurationException(DefaultDataSourceBuilderConfiguration
				.buildMissingJdbcUrlMessage(getDataSourceType(), dataContextId));
	}

	final String driverClass = configurationProperties.getConfigPropertyValue(
			DataSourceConfigProperties.DRIVER_CLASS_NAME,
			configurationProperties.getDriverClassName()
					.orElseThrow(() -> new ConfigurationException(DefaultDataSourceBuilderConfiguration
							.buildMissingDriverClassMessage(getDataSourceType(), dataContextId))));

	try {
		// specific properties
		Map<String, String> dbcpProperties = configurationProperties.getSubPropertiesUsingPrefix("dbcp");
		Properties poolProperties = new Properties();
		poolProperties.putAll(dbcpProperties);

		BasicDataSource ds = BasicDataSourceFactory.createDataSource(poolProperties);

		ds.setDriverClassName(driverClass);
		ds.setUrl(url);

		// validation query
		configurationProperties.getConnectionValidationQuery().ifPresent(vq -> {
			ds.setTestOnBorrow(true);
			ds.setValidationQuery(vq);
		});

		// credentials
		ds.setUsername(configurationProperties.getConfigPropertyValue(DataSourceConfigProperties.USERNAME, null));
		ds.setPassword(configurationProperties.getConfigPropertyValue(DataSourceConfigProperties.PASSWORD, null));

		// pool size
		Integer minPoolSize = configurationProperties
				.getConfigPropertyValue(DataSourceConfigProperties.MIN_POOL_SIZE, null);
		if (minPoolSize != null && minPoolSize > 0) {
			ds.setInitialSize(minPoolSize);
			ds.setMinIdle(minPoolSize);
		}

		Integer maxPoolSize = configurationProperties.getConfigPropertyValue(
				DataSourceConfigProperties.MAX_POOL_SIZE, DataSourceConfigProperties.DEFAULT_MAX_POOL_SIZE);
		if (maxPoolSize != null && maxPoolSize > 0) {
			ds.setMaxTotal(maxPoolSize);
			if (ds.getMaxIdle() > maxPoolSize) {
				ds.setMaxIdle(maxPoolSize);
			}
		}

		// autocommit
		if (configurationProperties.isDisableAutoCommit()) {
			ds.setDefaultAutoCommit(Boolean.FALSE);
		}

		LOGGER.debug(() -> "(Data context id: " + dataContextId + "): "
				+ "DBCP2 DataSource setted up for jdbc url: " + url + " [Max pool size: " + maxPoolSize + "]");

		return ds;
	} catch (Exception e) {
		throw new ConfigurationException("Failed to configure [" + getDataSourceType() + "] DataSource", e);
	}
}
 

import org.apache.commons.dbcp2.BasicDataSourceFactory; //导入依赖的package包/类
private static void connect() throws Exception {
	dataSource = BasicDataSourceFactory.createDataSource(properties);
}