JDBC数据源连接池配置及应用

使用JDBC建立数据库连接的两种方式:

1.在代码中使用DriverManager获得数据库连接。这种方式效率低，并且其性能、可靠性和稳定性随着用户访问量得增加逐渐下降。

2.使用配置数据源的方式连接数据库，该方式其实质就是在上述方法的基础上增加了数据库连接池，这种方式效率高。

数据源连接池的方式连接数据库与在代码中使用DriverManager获得数据库连接存在如下差别：

1）数据源连接池的方式连接数据库是在程序中,通过向一个JNDI(Java Naming and Directory Interface)服务器查询,即调用Context接口的lookup()方法,来得到DataSource对象,然后调用DataSource对象的getConnection()方法建立连接

2）为了能重复利用数据库连接对象,提高对请求的响应时间和服务器的性能,采用连接池技术.连接池技术预先建立多个数据库连接对象,然后将连接对象保存到连接池中,当客户请求到来时,从池中取出一个连接对象为客户服务,当请求完成时,客户程序调用close()方法,将连接对象放回池中.

3）在代码中使用DriverManager获得数据库连接的方式中,客户程序得到的连接对象是物理连接,调用连接对象的close()方法将关闭连接,而采用连接池技术,客户程序得到的连接对象是连接池中物理连接的一个句柄,调用连接对象的close()方法,物理连接并没有关闭,数据源的实现只是删除了客户程序中的连接对象和池中的连接对象之间的联系.

为了测试方便可以在数据库（这里以mysql 5为例）中建立一个USER表：

CREATE TABLE `user` ( 
 `id` int(10) unsigned NOT NULL AUTO_INCREMENT, 
 `username` varchar(50) DEFAULT NULL, 
 `password` varchar(50) DEFAULT NULL, 
 `email` varchar(50) DEFAULT NULL, 
 PRIMARY KEY (`id`), 
);

导入数据库的驱动的jar包到tomcat的lib目录下（这里以mysql5为例，所用到的jar包为：mysql-connector-java-5.0.8-bin.jar）。

1.在代码中使用DriverManager获得数据库连接。这种方式效率低，并且其性能、可靠性和稳定性随着用户访问量得增加逐渐下降。

oracle数据库连接的Java代码如下：

import java.sql.Connection; 
import java.sql.DriverManager; 
 
public class DBConnection { 
  
  
 private final static String DB_URL = "jdbc:oracle:thin:@127.0.0.1:1521:orcl"; 
  
  
 private final static String DB_DRIVER = "oracle.jdbc.driver.OracleDriver"; 
  
  
 private final static String DB_USERNAME = "root"; 
  
  
 private final static String DB_PASSWORD = "admin"; 
  
  
 public Connection getConnection(){ 
   
  Connection conn = null; 
  try{ 
    
   Class.forName(DB_DRIVER); 
    
   conn = DriverManager.getConnection(DB_URL,DB_USERNAME,DB_PASSWORD); 
  }catch(Exception ex){ 
   ex.printStackTrace(); 
  } 
  return conn; 
 } 
  
  
 public void closeConnection(Connection conn){ 
  try{ 
   if(conn!=null){ 
     
    if(!conn.isClosed()){ 
     conn.close(); 
    } 
   } 
  }catch(Exception ex){ 
   ex.printStackTrace(); 
  } 
 } 
  
}

mysql数据库连接的JSP代码如下：

<%@page import="java.sql.*, com.mysql.jdbc.Driver"%> 
<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%> 
 
  
 <% 
 //com.mysql.jdbc.Driver 
 Class.forName(Driver.class.getName()).newInstance(); 
 String url = "jdbc:mysql://localhost:3306/demo?useUnicode=true&characterEncoding=UTF8"; 
 String user = "root"; 
 String password = "123"; 
  
 Connection conn = DriverManager.getConnection(url, user, password); 
 Statement stmt = conn.createStatement(); 
  
 String sql = "select * from user"; 
 ResultSet rs = stmt.executeQuery(sql); 
  
 while(rs.next()) { 
  out.print("
" + "====================" + "
"); 
  out.print(rs.getLong("id") + " "); 
  out.print(rs.getString("username") + " "); 
  out.print(rs.getString("password") + " "); 
  out.print(rs.getString("email") + " "); 
 } 
 %>

2.使用配置数据源的方式连接数据库，该方式其实质就是在上述方法的基础上增加了数据库连接池，这种方式效率高。

1）mysql数据库数据源连接池的JSP代码如下：

<%@page import="java.sql.*, javax.naming.*, javax.sql.DataSource"%> 
<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%> 
 
 
 <% 
 Context initCtx = new InitialContext(); 
 DataSource ds = (DataSource)initCtx.lookup("java:comp/env/jdbc/demoDB"); 
 Connection conn = ds.getConnection(); 
  
 Statement stmt = conn.createStatement(); 
  
 String sql = "select * from user"; 
 ResultSet rs = stmt.executeQuery(sql); 
  
 while(rs.next()) { 
  out.print("
" + "====================" + "
"); 
  out.print(rs.getLong("id") + " "); 
  out.print(rs.getString("username") + " "); 
  out.print(rs.getString("password") + " "); 
  out.print(rs.getString("email") + " "); 
 } 
 %>

2）添加如下代码到tomcat的conf目录下的server.xml中：

3）在web工程目录下的web.xml的根节点下配置如下内容：

 
 mysqlDB Connection 
 jdbc/demoDB 
 javax.sql.DataSource 
 Container

完成上述步骤数据源的连接池配置已经完成，但是为了提高项目的可移植性，最好将上述第二步的内容放入到工程的meta-INF目录的context.xml中（这个文件需要自行建立）：

3.使用配置数据源的数据库连接池时的数据库操作工具类

代码如下：

package db.utils; 
 
import java.sql.Connection; 
import java.sql.PreparedStatement; 
import java.sql.ResultSet; 
import java.sql.ResultSetmetaData; 
import java.sql.SQLException; 
import java.sql.Statement; 
import java.text.DateFormat; 
import java.util.ArrayList; 
import java.util.Date; 
import java.util.HashMap; 
import java.util.List; 
import java.util.Map; 
 
import javax.naming.InitialContext; 
import javax.sql.DataSource; 
 
//import org.apache.log4j.Logger; 
 
 
public class DbUtils { 
  
 //private static Logger logger = Logger.getLogger("DbUtils"); 
  
  
 public int execute(String sql, List

JDBC数据源连接池配置及应用

Java相关栏目本月热门文章