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

84 阅读 0 评论 56 点赞

我是靠谱客的博主鲤鱼睫毛膏，最近开发中收集的这篇文章主要介绍groovy系列三 groovy脚本获取数据库连接池，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

整体思路：

跟java代码一样配置数据库连接池就可以
写个java工具类DataSourceUtil获取数据库连接池
在groovy直接使用DataSourceUtil获取数据源就可以了，其他就是groovy的SQL查询了

上代码：

数据源配置

<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>

获取数据源的工具类
获取bean

@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;
    }
}

获取数据源

public class DataSourceUtil {

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

脚本中获取数据库连接池

// 使用数据库连接池创建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])
        }