Go语言视频零基础入门到精通

javalearner

一、需要的JAR包：
commons-dbcp-1.4.jar
commons-pool-1.6.jar
mysql-connector-java-5.1.20-bin.jar

二、配置文件：dbcp.properties
#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/cwb
username=root
password=8345660 #<!-- 初始化连接 -->
dataSource.initialSize=20 #<!-- 最大空闲连接 -->
dataSource.maxIdle=20 #<!-- 最小空闲连接 -->
dataSource.minIdle=5

#最大连接数量
dataSource.maxActive=100

#是否在自动回收超时连接的时候打印连接的超时错误
dataSource.logAbandoned=true

#是否自动回收超时连接
dataSource.removeAbandoned=true

#超时时间(以秒数为单位)
#设置超时时间有一个要注意的地方，超时时间=现在的时间-程序中创建Connection的时间，
#如果 maxActive比较大，比如超过100，那么removeAbandonedTimeout可以设置长一点比如180，也就是三分钟无响应的连接进行回收，当然应用的不同设置长度也不同。
dataSource.removeAbandonedTimeout=180

#<!-- 超时等待时间以毫秒为单位 -->
#maxWait代表当Connection用尽了，多久之后进行回收丢失连接
dataSource.maxWait=1000 三、使用连接池，获取数据库连接的代码

1. package com.cwb.tool;
   
2. import java.util.Properties;
   
3. import java.io.*;
   
4. import java.sql.Connection;
   
5. import java.sql.ResultSet;
   
6. import java.sql.SQLException;
   
7. import java.sql.Statement;
   
8. import javax.sql.DataSource;
   
9. import org.apache.commons.dbcp.BasicDataSourceFactory;
   
10. import org.apache.log4j.Logger;
    
11. public class DBCPManager {
    
12. 
    
13. private static final Logger logger = Logger.getLogger(DBCPManager.class);
    
14. static private DBCPManager instance; // 唯一实例
    
15. static private DataSource ds;
    
16. private DBCPManager() {
    
17.   ds=setupDataSource();
    
18. }
    
19. private static DataSource setupDataSource() {
    
20. try{
    
21.     Properties prop = new Properties();
    
22.     InputStream inputStream = DBCPManager.class.getClassLoader().getResourceAsStream("dbcp.properties");
    
23.     prop.load(inputStream);
    
24.     ds= BasicDataSourceFactory.createDataSource(prop);
    
25.    
    
26.    } catch (IOException e) {
    
27.      logger.error("加载 dbcp.properties 错误");
    
28.      logger.info(e.toString());
    
29.    }catch(Exception e){
    
30.      logger.info(e.toString());
    
31.   }
    
32.   if(ds!=null) logger.info("获取数据源成功");
    
33.    return ds;
    
34.   }
    
35. static synchronized public DBCPManager getInstance() {
    
36.   if (instance == null) {
    
37.    instance = new DBCPManager();
    
38.   }
    
39.   return instance;
    
40. }
    
41. public void free(ResultSet rs, Statement st, Connection conn) {
    
42.   try{
    
43.    if (rs != null) rs.close();
    
44.   }catch (SQLException e){
    
45.    logger.info("关闭ResultSet出错");
    
46.    logger.info(e.toString());
    
47.   }finally{
    
48.      try{
    
49.        if (st != null)
    
50.         st.close();
    
51.      }catch (SQLException e){
    
52.       logger.info("关闭Statement出错");
    
53.       logger.info(e.toString());
    
54.      }finally{
    
55.        try{
    
56.          if (conn != null) conn.close();
    
57.        } catch (SQLException e)
    
58.      {
    
59.       logger.info("关闭Connection出错");
    
60.       logger.info(e.toString());
    
61.      }
    
62.    }
    
63. }
    
64. }
    
65. public Connection getConnection() {
    
66.   if(ds!=null){
    
67.    try {
    
68.        Connection conn=ds.getConnection();
    
69.        return conn;
    
70.    } catch (SQLException e) {
    
71.       logger.info("获取Connection出错");
    
72.       logger.info(e.toString());
    
73.    }
    
74.   }
    
75.   return null;
    
76. }
    
77. //测试代码
    
78.    public static void main(String[] args) {
    
79.          Connection conn = null;
    
80.          Statement stmt = null;
    
81.          ResultSet rset = null;
    
82.          DBCPManager db=DBCPManager.getInstance();
    
83.          
    
84.          conn=db.getConnection();
    
85.          if(conn==null) System.out.println("conn==null");
    
86.          try {
    
87.              System.out.println("Creating connection.");
    
88.              conn = db.getConnection();
    
89.              System.out.println("Creating statement.");
    
90.              stmt = conn.createStatement();
    
91.              System.out.println("Executing statement.");
    
92.              String sql="select * from count_num";
    
93.              rset = stmt.executeQuery(sql);
    
94.              System.out.println("Results:");
    
95.              int numcols = rset.getMetaData().getColumnCount();
    
96.              while(rset.next()) {
    
97.                  for(int i=1;i<=numcols;i++) {
    
98.                      System.out.print("        " + rset.getString(i));
    
99.                  }
    
100.                  System.out.println("");
     
101.              }
     
102.             
     
103.          } catch(SQLException e) {
     
104.              e.printStackTrace();
     
105.          } finally {
     
106.              db.free(rset,stmt,conn);
     
107.          }
     
108.          
     
109.        }
     
110.    }  
     

复制代码

四、JSP页面中可以这样用：
<%@ page contentType="text/HTML; charset=GB2312" %>
<%@ page import="org.apache.log4j.*" %>
<%@ page import="java.sql.*" %>
<%@ page import="com.cwb.tool.DBCPManager" %> <%
Logger logger = Logger.getLogger("mysqltestjsp");
logger.debug("测试DBCP连接池的使用！！");
%>
<h1> Test DBCP连接池！！！</h1>
<%
   Connection conn = null;
   Statement stmt = null;
   ResultSet rset = null;
   //主要是这两句
   DBCPManager db=DBCPManager.getInstance();
   conn=db.getConnection();

try {
} catch(SQLException e) {
   logger.info(e.toString());
} finally {
   db.free(rset,stmt,conn);
}
%>

   
     
     
      
      

        
      

        
      
     
   

  


源码下载：http://file.javaxxz.com/2014/10/11/030841109.zip