杨校老师课堂之基于Apache的数据库连接池DBCP的工具类开发

package cn.javabs.school.util;
 
import org.apache.commons.dbcp.BasicDataSourceFactory;
 
import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
 
public class DbcpUtils{
    private  static DataSource dataSource;
    static  String  myFile = "dbcp.properties";
 
    static {
        try {
            InputStream resourceAsStream = DbcpUtils.class.getClassLoader().getResourceAsStream(myFile);
            Properties p = new Properties();
            p.load(resourceAsStream);
            // 调用的核心类是BasicDataSourceFactory
            dataSource = BasicDataSourceFactory.createDataSource(p);
        } catch (Exception e) {
            throw  new RuntimeException(e);
        }
    }
    public static DataSource getDataSource(){
        return  dataSource;
    }
 
    public static Connection getConnection(){
        try {
            return  dataSource.getConnection();
        } catch (SQLException e) {
            throw  new RuntimeException(e);
        }
    }
}

driverClassName = com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/0314
username=root
password=sorry

package cn.javabs.school.test;
 
import cn.javabs.school.entity.Admin;
import cn.javabs.school.util.DbcpUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;
 
import java.sql.SQLException;
import java.util.List;
 
/**
 * 测试类: 用于测试数据库是否通畅
 * @author Mryang
 */
public class TestData {
 
    QueryRunner  qr =  new QueryRunner(DbcpUtils.getDataSource());
 
    @Test
    public void fun(){
        try {
            Admin admin = new Admin();
            List<Admin> admins = qr.query("select * from admin", new BeanListHandler<Admin>(Admin.class));
            System.out.println(admins);
        } catch (SQLException e) {
            throw new RuntimeException("error:"+e);
        }
    }
}