import com.mchange.v2.c3p0.C3P0Registry; //导入依赖的package包/类
/**
 * Close all pooled datasources created by C3P0.
 */
public static void closePolledDataSources() {
	for (PooledDataSource dataSource:(Set<PooledDataSource>)C3P0Registry.allPooledDataSources()) {
		try {
			dataSource.close();
			DataSources.destroy(dataSource);
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}
 

import com.mchange.v2.c3p0.C3P0Registry; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
@Override
public void collectDBPoolMetrics(MonitorElement clientElem) {

    Set dsList = C3P0Registry.getPooledDataSources();

    if (dsList == null || dsList.size() == 0) {
        return;
    }

    /**
     * Step 2: 匹配对应的jdbc url
     */
    for (Object ds : dsList) {

        if (!ComboPooledDataSource.class.isAssignableFrom(ds.getClass())) {
            continue;
        }

        ComboPooledDataSource pds = (ComboPooledDataSource) ds;

        String jdbcURL = pds.getJdbcUrl();

        /**
         * 匹配客户端应用
         */
        MonitorElementInstance inst = this.matchElemInstance(clientElem, jdbcURL);

        if (inst == null) {
            continue;
        }

        collectDataSourceStat(inst, pds);
    }
}
 

import com.mchange.v2.c3p0.C3P0Registry; //导入依赖的package包/类
@Override
public synchronized DataSource selectDataSource(String tenantIdentifier) {
    PooledDataSource pooledDataSource = C3P0Registry.pooledDataSourceByName(tenantIdentifier);
    if (pooledDataSource == null) {
        pooledDataSource = proccessDataSource(tenantIdentifier);
    }
    return pooledDataSource;
}
 

import com.mchange.v2.c3p0.C3P0Registry; //导入依赖的package包/类
@Override
public synchronized DataSource selectDataSource(String tenantIdentifier) {
    PooledDataSource pooledDataSource = C3P0Registry.pooledDataSourceByName(tenantIdentifier);
    if (pooledDataSource == null) {
        pooledDataSource = proccessDataSource(tenantIdentifier);
    }
    System.out.println("select-data-source-base-multi-tenant");
    return pooledDataSource;
}
 

import com.mchange.v2.c3p0.C3P0Registry; //导入依赖的package包/类
public static DataSource getCatalogDS() {
	@SuppressWarnings("unchecked")
	Set<DataSource> c3p0pools = C3P0Registry.allPooledDataSources(); 
	return c3p0pools.iterator().next();
}