Druid数据库连接池的使用

packagecom.aff.connection;

importjava.io.InputStream;
importjava.sql.Connection;
importjava.util.Properties;
importjavax.sql.DataSource;
importorg.junit.Test;
importcom.alibaba.druid.pool.DruidDataSourceFactory;

//使用配置文件方式获取Druid数据库连接池
public classTestDruid {
    @Test
    public void getConnection() throwsException {
        Properties pros = newProperties();
        InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("druid.properties");
        pros.load(is);
        DataSource source =DruidDataSourceFactory.createDataSource(pros);
        Connection conn =source.getConnection();
        System.out.println(conn);
    }
}

packagecom.aff.util;
importjava.io.InputStream;
importjava.sql.Connection;
importjava.sql.SQLException;
importjava.util.Properties;
importjavax.sql.DataSource;
importcom.alibaba.druid.pool.DruidDataSourceFactory;

//使用Druid数据连接池获取连接
public classJDBCUtilsDruid {
    private staticDataSource source;
    static{
        try{
            Properties pros = newProperties();
            InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("druid.properties");
            pros.load(is);
            source =DruidDataSourceFactory.createDataSource(pros);
        } catch(Exception e) {
            e.printStackTrace();
        }
    }

    public static Connection getConnection() throwsSQLException {
        Connection conn =source.getConnection();
        returnconn;
    }
}

@Test
    public voidtestGetCount() {
        Connection conn = null;
        try{
            conn =JDBCUtilsDruid.getConnection();
            Long count =dao.getCount(conn);
            System.out.println(count);
            System.out.println("获取成功");
        } catch(Exception e) {
            e.printStackTrace();
        } finally{
            JDBCUtils.closeResource(conn, null);
        }
    }