C3P0数据库连接池-蒲公英云

C3P0数据库连接池

心已赠人 2022-05-16 12:44 342阅读 0赞

C3P0是Spring内置的数据源
需要导入的jar包是：
- c3p0-0.9.2-pre1.jar
- mchange-commons-0.2.jar

方式一

读取配置文件c3p0-config.xml（可以放在src下或者WEB-INF/classes下）

方式二

package com.kexin.utils;
import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
import com.mchange.v2.c3p0.ComboPooledDataSource;
/**
 * 使用c3p0获取数据库连接
 * @author KeXin
 *
 */
public class C3p0Utils {
    private static ComboPooledDataSource ds;
    static{
        ds = new ComboPooledDataSource();
        try {
            ds.setDriverClass("com.mysql.jdbc.Driver");
            ds.setJdbcUrl("jdbc:mysql://localhost:3306/database1");
            ds.setUser("root");
            ds.setPassword("root");
            ds.setMaxPoolSize(30);
            ds.setMinPoolSize(5);
            ds.setInitialPoolSize(10);
        } catch (PropertyVetoException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    /**
     * ②获取Connection对象
     * @return
     * @throws SQLException
     */
    public static Connection getConnection() throws SQLException{
        return ds.getConnection();
    }
    /**
     * ③关闭连接
     */
    public static void release(Connection conn,Statement st,ResultSet rs){
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (st != null) {
            try {
                st.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}