源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

java配置dbcp连接池(数据库连接池)示例分享

  • 时间:2020-02-26 07:37 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要:java配置dbcp连接池(数据库连接池)示例分享
使用jar包:commons-dbcp-1.4.jar、commons-pool-1.6.jar、commons-logging-1.1.3.jar,另外还有数据库的jdbc驱动,适用java6及以上平台 连接池管理类
[u]复制代码[/u] 代码如下:
package cn.songxinqiang.samples.commonsdbcp.util; import java.sql.Connection; import java.sql.DatabaseMetaData; import java.sql.SQLException; import java.util.Properties; import javax.sql.DataSource; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.tomcat.dbcp.dbcp.BasicDataSourceFactory; /**  * tomcat数据库连接池管理类<br>  * 使用为tomcat部署环境<br>  * 需要在类路径下准备数据库连接配置文件dbcp.properties  *  * @author 宋信强  * @mail songxinqiang123@gmail.com  *  * @time 2013-12-27  *  */ public class DBManager {  private static final Log log = LogFactory.getLog(DBManager.class);  private static final String configFile = "dbcp.properties";  private static DataSource dataSource;  static {   Properties dbProperties = new Properties();   try {    dbProperties.load(DBManager.class.getClassLoader()      .getResourceAsStream(configFile));    dataSource = BasicDataSourceFactory.createDataSource(dbProperties);    Connection conn = getConn();    DatabaseMetaData mdm = conn.getMetaData();    log.info("Connected to " + mdm.getDatabaseProductName() + " "      + mdm.getDatabaseProductVersion());    if (conn != null) {     conn.close();    }   } catch (Exception e) {    log.error("初始化连接池失败:" + e);   }  }  private DBManager() {  }  /**   * 获取链接,用完后记得关闭   *   * @see {@link DBManager#closeConn(Connection)}   * @return   */  public static final Connection getConn() {   Connection conn = null;   try {    conn = dataSource.getConnection();   } catch (SQLException e) {    log.error("获取数据库连接失败:" + e);   }   return conn;  }  /**   * 关闭连接   *   * @param conn   *            需要关闭的连接   */  public static void closeConn(Connection conn) {   try {    if (conn != null && !conn.isClosed()) {     conn.setAutoCommit(true);     conn.close();    }   } catch (SQLException e) {    log.error("关闭数据库连接失败:" + e);   }  } }
连接配置文件
[u]复制代码[/u] 代码如下:
#数据库驱动 driverClassName=com.mysql.jdbc.Driver #数据库连接地址 url=jdbc:mysql://localhost/ctg #用户名 username=root #密码 password=123456 #连接池的最大数据库连接数。设为0表示无限制 maxActive=30 #最大空闲数,数据库连接的最大空闲时间。超过空闲时间,数据库连 #接将被标记为不可用,然后被释放。设为0表示无限制 maxIdle=10 #最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制 maxWait=1000 #超过removeAbandonedTimeout时间后,是否进 行没用连接(废弃)的回收(默认为false,调整为true) removeAbandoned=true #超过时间限制,回收没有用(废弃)的连接(默认为 300秒,调整为180) removeAbandonedTimeout=180
测试连接池工作效率,同时演示怎样获取连接和关闭连接
[u]复制代码[/u] 代码如下:
public class ConnectionSource {  public static void main(String[] args){   long begin=System.currentTimeMillis();   for(int i=0;i<10000;i++){    Connection conn=DBManager.getConn();    System.out.print(i+"   ");    DBManager.closeConn(conn);   }   long end=System.currentTimeMillis();   System.out.println("用时:"+(end-begin));  } }
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部