groovy系列三 groovy脚本获取数据库连接池

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
<bean id="scriptParentDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close" abstract="true">
      <property name="driverClassName" value="${jdbc.driverClassName}" />
        <property name="url" value="${jdbc.url}" />
        <property name="username" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />
		<!-- 最大活动连接，连接池中可同时连接的最大的连接数（默认值为8） -->
		<property name="maxActive" value="${script.jdbc.maxActive}" />

		<!-- 最大空闲连接，连接池中最大的空闲的连接数，超过的空闲连接将被释放，如果设置为负数表示不限制（默认为8个） -->
		<property name="maxIdle" value="${script.jdbc.maxIdle}" />

		<!-- 最小空闲连接，连接池中最小的空闲的连接数，低于这个数量会被创建新的连接（默认为0） -->
		<property name="minIdle" value="${script.jdbc.minIdle}" />

		<!-- 从池中取连接的最大等待时间，单位ms.当没有可用连接时，连接池等待连接释放的最大时间，超过该时间限制会抛出异常，如果设置-1表示无限等待（默认为无限） -->
		<property name="maxWait" value="${script.jdbc.maxWait}" />

		<!-- 每30秒运行一次空闲连接回收器（独立线程）。并每次检查3个连接，如果连接空闲时间超过30分钟就销毁。 -->
		<property name="timeBetweenEvictionRunsMillis" value="${script.jdbc.timeBetweenEvictionRunsMillis}" />

		<!-- 池中的连接空闲30分钟后被回收 -->
		<property name="minEvictableIdleTimeMillis" value="${script.jdbc.minEvictableIdleTimeMillis}" />

		<!-- 连接泄漏回收参数，当可用连接数少于3个时才执行 -->
		<property name="removeAbandoned" value="${script.jdbc.removeAbandoned}" />

		<!-- 连接泄漏回收参数，180秒，泄露的连接可以被删除的超时值 -->
		<property name="removeAbandonedTimeout" value="${script.jdbc.removeAbandonedTimeout}" />

		<!-- 指明连接是否被空闲连接回收器(如果有)进行检验.如果检测失败,则连接将被从池中去除. -->
		<property name="testWhileIdle" value="${script.jdbc.testWhileIdle}" />

		<!--在每次空闲连接回收器线程(如果有)运行时检查的连接数量 -->
		<property name="numTestsPerEvictionRun" value="${script.jdbc.numTestsPerEvictionRun}" />
		<property name="testOnBorrow" value="${script.jdbc.testOnBorrow}" />

		<property name="poolPreparedStatements" value="true" />
		<property name="defaultAutoCommit" value="true" />
		<property name="validationQuery" value="SELECT 1" />
	</bean>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
@Component
public class SpringContextUtil implements ApplicationContextAware {
    public static ApplicationContext applicationContext = null;

    public SpringContextUtil() {
    }

    @SuppressWarnings("unchecked")
	public static <T> T getBean(String beanName, Class<T> beanType) {
        Assert.isTrue(applicationContext != null, "应用上下文不能为空");
        Object bean = applicationContext.getBean(beanName);
        return bean == null ? null : (T)bean;
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        SpringContextUtil.applicationContext = applicationContext;
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
public class DataSourceUtil {

    /**
     * 根据名字获取数据源
     * @param name
     * @return
     */
    public static BasicDataSource getDataSourceByName(String name){
        Assert.hasText(name,"名字不能为空");
        return SpringContextUtil.getBean(name,BasicDataSource.class);
    }
}

1
2
3
4
5
6
7
8
9
// 使用数据库连接池创建groovy sql
  Sql poolSql= new Sql(DataSourceUtil.getDataSourceByName("scriptParentDataSource"))
        String checkSql = "SELECT id FROM test "

        StringBuilder idSb= new StringBuilder()
        poolSql.eachRow(checkSql){row->
            idSb.append(row[0])
        }