mysql的连接池配置文件,数据库连接池/配置文件数据库连接池

1.方式

一种是使用直接c3p0数据库连接池&＃xff0c;一种是使用配置文件将连接信息写在配置文件中。

将连接信息写在配置文件中有很多好处&＃xff0c;比如如果想替换一个线上项目的数据库&＃xff0c;只要改变配置文件中的链接信息就可以了。再就是一些需要修改的地方&＃xff0c;比如想要修改链接池的属性&＃xff0c;也只需要修配置文件就可以了&＃xff0c;不需要去修改java代码&＃xff0c;那样还需要重新编译生成class文件&＃xff0c;重新运行一遍。

2.直接使用jar包

、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、

package com.begin21.w1106.ClassTest.excute;

import java.beans.PropertyVetoException;

import java.sql.Connection;

import java.sql.SQLException;

import com.mchange.v2.c3p0.ComboPooledDataSource;

//数据库连接池

public class ConnectionPool {

private static ComboPooledDataSource comboPooledDataSource;

//初始化连接池

public static final void initDBSource(){

comboPooledDataSource &＃61; new ComboPooledDataSource();

try {

comboPooledDataSource.setDriverClass("com.mysql.jdbc.Driver");

} catch (PropertyVetoException e) {

e.printStackTrace();

}

comboPooledDataSource.setJdbcUrl("jdbc:mysql://localhost:3306/gaobo");

comboPooledDataSource.setUser("root");

comboPooledDataSource.setPassword("");

comboPooledDataSource.setMinPoolSize(3); //最小线程数

comboPooledDataSource.setMaxPoolSize(20);//最大线程数

comboPooledDataSource.setInitialPoolSize(5);//初始线程数

comboPooledDataSource.setAcquireIncrement(2);//每次新增线程数

comboPooledDataSource.setMaxIdleTime(5);//线程空闲时间

}

/**

* 从连接池中获取连接

* &＃64;return

*/

public static synchronized Connection getConnection() {

Connection conn &＃61; null;

try {

conn &＃61; comboPooledDataSource.getConnection();

} catch (SQLException e) {

e.printStackTrace();

}

return conn;

}

public static void closeOpenResource(AutoCloseable resource) {

if (null !&＃61; resource) {

try {

resource.close();

} catch (Exception e) {

e.printStackTrace();

}}}}

、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、、

package com.begin21.w1106.ClassTest.excute;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

public class Main2 {

public static void main(String[] args) {

ConnectionPool.initDBSource();

query();}

private static void query() {

Connection conn &＃61; ConnectionPool.getConnection();

PreparedStatement prst &＃61; null;

ResultSet rs &＃61; null;

String sql &＃61; "select * from repo_sto";

try {

prst &＃61; conn.prepareStatement(sql);

rs &＃61; prst.executeQuery();

while(rs.next()) {

System.out.println(rs.getString(2));}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} finally {

ConnectionPool.closeOpenResource(rs);

ConnectionPool.closeOpenResource(prst);

// close不是关闭数据库连接池的连接对象&＃xff0c;而是把它放回连接池

ConnectionPool.closeOpenResource(conn);}}}

3.使用配置文件

配置文件 db.properties

package com.begin21.w1106.ClassTest.excute;

import java.beans.PropertyVetoException;

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.SQLException;

import java.util.Properties;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class ConnectionPoolProp {

private static ComboPooledDataSource comboPooledDataSource;

public static final void initDBSource() {

Properties properties &＃61; new Properties();

try {

File file &＃61; new File(ConnectionPoolProp.class.getResource("/").getFile().toString() &＃43; "dbs.properties");  //引用配置文件

System.out.println(ConnectionPoolProp.class.getResource("/").getFile());

InputStream inputStream &＃61; new FileInputStream(file);

properties.load(inputStream);

} catch (IOException e) {

e.printStackTrace();

}

comboPooledDataSource &＃61; new ComboPooledDataSource();

try {

comboPooledDataSource.setDriverClass(properties.getProperty("driver"));

} catch (PropertyVetoException e) {

e.printStackTrace();

}

comboPooledDataSource.setJdbcUrl(properties.getProperty("url"));

comboPooledDataSource.setUser(properties.getProperty("user"));

comboPooledDataSource.setPassword(properties.getProperty("password"));

comboPooledDataSource.setMinPoolSize(Integer.parseInt(properties.getProperty("c3p0.minPoolSize")));

comboPooledDataSource.setMaxPoolSize(Integer.parseInt(properties.getProperty("c3p0.maxPoolSize")));

comboPooledDataSource.setInitialPoolSize(Integer.parseInt(properties.getProperty("c3p0.initPoolSize")));

comboPooledDataSource.setAcquireIncrement(Integer.parseInt(properties.getProperty("c3p0.acquireIncrement")));

comboPooledDataSource.setMaxStatements(Integer.parseInt(properties.getProperty("c3p0.maxStatements").trim()));

comboPooledDataSource.setMaxIdleTime(Integer.parseInt(properties.getProperty("c3p0.maxIdleTime")));

}

public static synchronized Connection getConnection() {

Connection conn &＃61; null;

try {

conn &＃61; comboPooledDataSource.getConnection();

} catch (SQLException e) {

e.printStackTrace();

}

return conn;

}

public static void closeOpenResource(AutoCloseable resource) {

if (null !&＃61; resource) {

try {

resource.close();

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();}}}}