在Tomcat 7配置Servlet 3.0项目的MySQL 5.5的DBCP连接池

chszs

《在Tomcat 7配置Servlet 3.0项目的MySQL 5.5的DBCP连接池》
2012-6-5

版权声明：本文属于原创，版权归作者chszs所有，使用源码无任何限制，但转载文章需经作者同意。

一、简介

数据库连接池的基本原理是，在内部对象池中维护一定数量的数据库连接，并对外暴露从连接池获取数据库连接和释放连接的方法。

数据库连接池技术的优点：

²       资源重用。避免频繁创建连接、释放连接带来的性能开销。

²       更快的系统响应速度。减少了初始化数据库连接的时间，因为数据库连接池在初始化时，已经创建了一定数量的数据库连接。

²       统一的连接管理。避免数据库连接的内存泄漏。

本文教你如何在Tomcat 7.0.27应用服务器上配置Jakarta Commons Database Connection Pool(DBCP连接池)，配置的连接池在Servlet 3.0项目中运行正常。

DBCP是一个数据库连接池工具，而Tomcat Servlet引擎中包含了该技术。

注意：在Tomcat 5.x和Tomcat 6.x等版本下配置JNDI数据源有很多不同。

二、JAR包

MySQL的JDBC驱动包是必须的，下载mysql-connector-java-5.1.19.zip，并解压；

再把文件mysql-connector-java-5.1.19-bin.jar复制到Tomcat\lib目录；

DBCP连接池依赖于两个包：commons-dbcp.jar和commons-pool.jar。但这两个库都已经被封装到Tomcat/lib/tomcat-dbcp.jar文件中，而且，对类的包名重新命名，以避免与应用程序发生干扰。

Tomcat的lib目录已经包含了tomcat-dbcp.jar库。

三、Tomcat配置MySQL数据源

Tomcat配置数据源，不同的数据库有不同的配法，基本上相同，仅仅是具体的参数略有不同。这里配置MySQL数据源。

在Tomcat的conf子目录内，打开context.xml配置文件，看这里：

1. <?xml version='1.0' encoding='utf-8'?>
   
2. <Context>
   
3.     <!-- Default set of monitored resources -->
   
4.     <WatchedResource>WEB-INF/web.xml</WatchedResource>
   
5. 
   
6.     <!-- Uncomment this to disable session persistence across Tomcat restarts -->
   
7.     <!--
   
8.     <Manager pathname="" />
   
9.     -->
   
10. 
    
11.     <!-- Uncomment this to enable Comet connection tacking (provides events
    
12.          on session expiration as well as webapp lifecycle) -->
    
13.     <!--
    
14.     <Valve className="org.apache.catalina.valves.CometConnectionManagerValve" />
    
15.     -->
    
16. </Context>
    

复制代码

在<context>标签内增加一个<Resource>标签，并去除注释，内容如下：

1. <?xml version='1.0' encoding='utf-8'?>
   
2. <Context>
   
3.         <WatchedResource>WEB-INF/web.xml</WatchedResource>
   
4.         <Resource name="jdbc/mysql5" auth="Container"
   
5.               type="javax.sql.DataSource"
   
6.                           maxActive="80" maxIdle="20" maxWait="10000" removeAbandoned="true"
   
7.               username="guan" password="guan123456"
   
8.                           driverClassName="com.mysql.jdbc.Driver"
   
9.               url="jdbc:mysql://localhost:3306/webt3" />
   
10. </Context>
    

复制代码

注意：黄色强调的内容为新增内容。四、验证

构建一个简单的Web项目，项目使用了Tomcat 7的DBCP连接池，从MySQL数据库读写数据。具体如下：

1、创建MySQL数据库

创建了数据库、表、用户，并对用户的访问权限进行授权，最后插入一点数据。

1. mysql> CREATE DATABASE webt3;
   
2. mysql> CREATE USER 'guan'@'%' IDENTIFIED BY 'guan123456';
   
3. mysql> GRANT ALL ON webt3.* TO 'guan'@'%';
   
4. mysql> USE webt3;
   
5. mysql> DROP TABLE IF EXISTS `student`;
   
6. mysql> CREATE TABLE `student`(
   
7. `id` INT(11) NOT NULL AUTO_INCREMENT,
   
8. `name` VARCHAR(20) DEFAULT NULL,
   
9. `record` INT(11) DEFAULT NULL,
   
10. PRIMARY KEY(`id`)
    
11. ) ENGINE=INNODB DEFAULT CHARSET=utf8;
    

复制代码

向表中插入几条数据：

1. mysql> INSERT INTO student VALUES(NULL, 'hello', 12345);
   
2. mysql> INSERT INTO student VALUES(NULL, '张素钠', 98373);
   
3. mysql> INSERT INTO student VALUES(NULL, '万科', 33238);
   

复制代码

2、创建动态Web项目

在Eclipse的JEE版中创建动态Web项目，项目的各项设置如下图所示：

注意是Servlet 3.0项目，为了配置使用数据库连接池，要生成web.xml部署描述符文件。

生成的项目结构如下图所示：

3、修改web.xml部署描述符

打开项目下WebContent/WEB-INF目录的web.xml文件，修改内容：

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   
3.         xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
   
4.         xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
   
5.         id="WebApp_ID" version="3.0">
   
6.         <display-name>webt3</display-name>
   
7.         <welcome-file-list>
   
8.                 <welcome-file>index.jsp</welcome-file>
   
9.         </welcome-file-list>
   
10.         <resource-ref>
    
11.                 <description>Tomcat 7 DBCP</description>
    
12.                 <res-ref-name>jdbc/mysql5</res-ref-name>
    
13.                 <res-type>javax.sql.DataSource</res-type>
    
14.                 <res-auth>Container</res-auth>
    
15.         </resource-ref>
    
16. </web-app>
    

复制代码

注：黄色强调部分是新增内容，要与Tomcat的server.xml的配置保持一致。

4、编写代码

4.1、创建实体类ch.entity.Student.java，如下：

1. package ch.entity;
   
2. 
   
3. import java.io.Serializable;
   
4. 
   
5. public class Student implements Serializable {
   
6.         private static final long serialVersionUID = -2851451446149648542L;
   
7. 
   
8.         private int id;
   
9.         private String name;
   
10.         private int record;
    
11. 
    
12.         public int getId() {
    
13.                 return id;
    
14.         }
    
15. 
    
16.         public void setId(int id) {
    
17.                 this.id = id;
    
18.         }
    
19. 
    
20.         public String getName() {
    
21.                 return name;
    
22.         }
    
23. 
    
24.         public void setName(String name) {
    
25.                 this.name = name;
    
26.         }
    
27. 
    
28.         public int getRecord() {
    
29.                 return record;
    
30.         }
    
31. 
    
32.         public void setRecord(int record) {
    
33.                 this.record = record;
    
34.         }
    
35. 
    
36.         @Override
    
37.         public String toString() {
    
38.                 return "Student [id=" + id + ", name=" + name + ", record=" + record
    
39.                                 + "]";
    
40.         }
    
41. 
    
42. }
    

复制代码

4.2、创建数据库访问类ch.dao.DBconn.java，如下：

1. package ch.dao;
   
2. 
   
3. import java.sql.*;
   
4. import java.util.List;
   
5. import java.util.ArrayList;
   
6. import javax.naming.Context;
   
7. import javax.naming.InitialContext;
   
8. import javax.naming.NamingException;
   
9. import javax.sql.DataSource;
   
10. import ch.entity.Student;
    
11. 
    
12. public class DBconn {
    
13.         Context context = null;
    
14.         DataSource ds = null;
    
15.         Connection conn = null;
    
16.         List<Student> students;
    
17.        
    
18.         public DBconn(){
    
19.                 initConnection();
    
20.                 this.students = new ArrayList<Student>();
    
21.         }
    
22.        
    
23.         private void initConnection(){
    
24.                 try {
    
25.                         context = new InitialContext();
    
26.                 } catch (NamingException e) {
    
27.                         System.err.println("连接池上下文不存在! " + e.getMessage());
    
28.                 }
    
29.                 try {
    
30.                         ds = (DataSource)context.lookup("java:comp/env/jdbc/mysql5");
    
31.                 } catch (NamingException e) {
    
32.                         System.err.println("数据源没发现! " + e.getMessage());
    
33.                 }
    
34.                 try {
    
35.                         conn = ds.getConnection();
    
36.                 } catch (SQLException e) {
    
37.                         System.err.println("获取连接失败! " + e.getMessage());
    
38.                 }
    
39.         }
    
40.        
    
41.         private void freeConnection() {
    
42.                 try {
    
43.                         conn.close();
    
44.                 } catch (Exception e) {
    
45.                         System.err.println("释放连接出错! ");
    
46.                         e.printStackTrace();
    
47.                 }
    
48.         }
    
49.        
    
50.         public List<Student> getAllStudents() {
    
51.                 Statement stmt = null;
    
52.                 ResultSet rs = null;
    
53.                 String sql = "SELECT id, name, record FROM student";
    
54.                 try {
    
55.                         stmt = conn.createStatement();
    
56.                         rs = stmt.executeQuery(sql);
    
57.                         rs = stmt.getResultSet();
    
58.                         while (rs.next()) {
    
59.                                 Student tmp = new Student();
    
60.                                 tmp.setId(rs.getInt(1));
    
61.                                 tmp.setName(rs.getString(2));
    
62.                                 tmp.setRecord(rs.getInt(3));
    
63.                                 students.add(tmp);
    
64.                         }
    
65.                         if (rs != null)
    
66.                                 rs.close();
    
67.                         if (stmt != null)
    
68.                                 stmt.close();
    
69.                 } catch (SQLException ex) {
    
70.                         System.out.println("SQLException: " + ex.getMessage());
    
71.                         System.out.println("SQLState: " + ex.getSQLState());
    
72.                         System.out.println("VendorError: " + ex.getErrorCode());
    
73.                 } finally{
    
74.                         freeConnection();
    
75.                 }
    
76.                 return students;
    
77.         }
    
78. }
    

复制代码

4.3、在WebContent目录下创建JSP文件：index.jsp

1. <%@ page language="java" contentType="text/html; charset=UTF-8"
   
2.     pageEncoding="UTF-8"%>
   
3. <%@ page import="ch.entity.Student, ch.dao.DBconn, java.util.*"  %>
   
4. <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
   
5.   "http://www.w3.org/TR/html4/loose.dtd">
   
6. <html>
   
7. <head>
   
8. <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
   
9. <title>测试连接池</title>
   
10. </head>
    
11. <body>
    
12. <%
    
13. DBconn conn = new DBconn();
    
14. List<Student> students = conn.getAllStudents();
    
15. if(students!=null && students.size()>0){
    
16.         for(Student student : students){
    
17.                 out.println(student.toString());
    
18.         }
    
19. }
    
20. %>
    
21. </body>
    
22. </html>
    

复制代码

5、部署项目并运行

把项目部署到Tomcat 7，并运行Tomcat应用服务器，显示结果如下：

6、结论

证明数据库连接池配置成功！

chszs

在代码中加入黄色的效果未能体现出来，我重新截图如下，大家自行对照。

jieforest

好文。连接池虽然不算新技术，但Servlet 3.0是新技术。