AI专业者开发社区 1 号成员
  •  0 回帖  •  4 浏览  •  4 个月前
 

java学习笔记—第三方数据库连接池包1（29）

第一步：导入 dbcp 包

第二步：通过核心类连接数据

       BasicDataSource 它是 javax.sql.DataSrouce 的子类。

       一个工具类：BasicDataSourceFactory。

 

手工通过代码连接数据库：

    BasicDataSource ds = new BasicDataSource();

   </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">设置driver</span>



       ds.setDriverClassName("com.mysql.jdbc.Driver");

   </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">设置url</span>



       ds.setUrl("jdbc:mysql:///db909?characterEncoding=UTf8");

   ds.setPassword(</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">1234</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">);

   ds.setUsername(</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">root</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">);

   ds.setMaxActive(</span><span style="color: rgba(128, 0, 128, 1)">5</span>) ;<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">设置最多有几个连接</span>



       ds.setInitialSize(2);//设置在开始时创建几个连接
  手工连接，不建议这么做。

第三步：创建一个资源文件

在 dbcp 中一个类专门用于读取资源文件的:

       BasicDataSourceFactory

#以下所有属性，都来自于 BaiscDataSource 的 setXxxx
// 增加一个配置文件jdbc.properties
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql:///db909
username=root
password=1234
maxActive=3

Properties p = new Properties();
p.load(DbcpPool.class.getResourceAsStream("jdbc.properties"));
DataSource ds =
new BasicDataSourceFactory().createDataSource(p) ;

第四步、使用连接池

在一个项目中，就只能拥有一个 DataSource 的实例。在这个 dataqSource3 中有多个 Connectioin。

声明一个工厂类，创建维护唯一的一个 DataSource

package cn.itcast.utils;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
public class DataSourceUtils {
    private DataSourceUtils(){}
    private static DataSource ds; 
    static{
        try{
            Properties p = 
                    new Properties();
            p.load(DataSourceUtils
.class.getClassLoader() 
.getResourceAsStream("jdbc.properties"));
            ds = 
                    new BasicDataSourceFactory().createDataSource(p); 
        }catch(Exception e){}}
    //返回一个唯一的连接
    public static Connection getCon(){ 
        Connection con = null;
        try {
            con = ds.getConnection();} catch (SQLException e) {e.printStackTrace();
        }
        return con;
    }
    //提供一个方法返回 DataSource
    public static DataSource getDs(){ 
        return ds;
    }
}