com.alibaba.druid.pool.DruidDataSourceFactory实现了javax.naming.spi.ObjectFactory，可以作为JNDI数据源来配置。

假如你现在还在为自己的技术担忧，假如你现在想提升自己的工资，假如你想在职场上获得更多的话语权，假如你想顺利的度过35岁这个魔咒，假如你想体验BAT的工作环境，那么现在请我们一起开启提升技术之旅吧，详情请点击

一、下载Druid的jar包

　　下载地址：，如下图所示：

　　

　　druid.jar依赖log4j的jar包，所以还需要下载log4j的jar包。

　　log4j的下载地址如下：，如下图所示：

　　

二、使用Druid配置JNDI数据源

2.1、前期准备工作

　　创建一个Web测试项目Druid_JNDI_Config，将下载下来druid-1.0.9.jar和log4j-1.2.17.jar添加到项目中，在项目的META-INF目录下创建一个context.xml文件

　　目录结构如下图所示：

　　

　　在tomcat服务器的lib目录下添加Oracle、MySQL、SQLServer三种数据库的驱动jar包，如下图所示：

　　

2.2、在context.xml文件中加入JNDI的配置信息

　　在context.xml文件中加入如下配置信息

1 
     
       2     
       3 
       18 19 
       20 
       35 36 
       37 
       52 
     

 　　配置项中指定了各个参数后，在连接池内部是这么使用这些参数的。数据库连接池在初始化的时候会创建initialSize个连接，当有数据库操作时，会从池中取出一个连接。如果当前池中正在使用的连接数等于maxActive，则会等待一段时间，等待其他操作释放掉某一个连接，如果这个等待时间超过了maxWait，则会报错；如果当前正在使用的连接数没有达到maxActive，则判断当前是否空闲连接，如果有则直接使用空闲连接，如果没有则新建立一个连接。在连接使用完毕后，不是将其物理连接关闭，而是将其放入池中等待其他操作复用。同时连接池内部有机制判断，如果当前的总的连接数少于miniIdle，则会建立新的空闲连接，以保证连接数得到miniIdle。如果当前连接池中某个连接在空闲了timeBetweenEvictionRunsMillis时间后任然没有使用，则被物理性的关闭掉。有些数据库连接的时候有超时限制（mysql连接在8小时后断开），或者由于网络中断等原因，连接池的连接会出现失效的情况，这时候设置一个testWhileIdle参数为true，可以保证连接池内部定时检测连接的可用性，不可用的连接会被抛弃或者重建，最大情况的保证从连接池中得到的Connection对象是可用的。当然，为了保证绝对的可用性，你也可以使用testOnBorrow为true（即在获取Connection对象时检测其可用性），

不过这样会影响性能。

2.3、在web.xml引用JDNI数据源

　　在web.xml文件中加入如下的配置引用JNDI数据源

1 
      2 
     
       7 
      
        8 
       
        index.jsp
        9 
       10 11 
       17 
       18 
      
        19 
       
        Oracle DB Connection
        20 
       
        jdbc/OracleDataSource
        21 
       
        javax.sql.DataSource
        22 
       
        Container
        23 
       24 25 
       26 
      
        27 
       
        MySQL DB Connection
        28 
       
        jdbc/MysqlDataSource
        29 
       
        javax.sql.DataSource
        30 
       
        Container
        31 
       32 33 
       34 
      
        35 
       
        SQLServer DB Connection
        36 
       
        jdbc/SqlServerDataSource
        37 
       
        javax.sql.DataSource
        38 
       
        Container
        39 
       40 
     

2.4、测试JNDI数据源

　　部署Druid_JNDI_Config Web应用到Tomcat服务器测试JNDI数据源，如下图所示：

　　

　　部署到tomcat服务器的webapps目录之后，tomcat服务器就会自动在\conf\Catalina\localhost目录下生成一个Druid_JNDI_Config.xml文件，如下图所示：

　　

　　Druid_JNDI_Config.xml文件中的内容就是我们在META-INF目录的context.xml文件中配置的那些内容。

　　jsp测试页面如下：

1 <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%> 2 <%--引入JSTL标签库 --%> 3 <%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c"%> 4 <%@ taglib uri="http://java.sun.com/jsp/jstl/sql" prefix="sql"%> 5  6  7  8  9  10 11  12 
针对MySQL数据库JNDI数据源测试
 13 <%--使用sql:query标签发送SQL语句去数据库查询数据，查询的结果集保存到rs变量当中，dataSource属性指明使用的数据源--%> 14 
     
       15 <%--MySQL JNDI数据源测试 SQL--%> 16 select * from lead_oams_applications 17 
      18 <%--使用c:forEach标签遍历查询结果集rs中的每一行--%> 19 
     
       20 <%--${row.字段名}获取字段的值--%> 21 ${row.resourceid}---${row.app_name}
      
 22 
      23 
     
 24 
针对Oracle数据库JNDI数据源测试
 25 <%--使用sql:query标签发送SQL语句去数据库查询数据，查询的结果集保存到rs变量当中，dataSource属性指明使用的数据源--%> 26 
     
       27 <%--Oracle JNDI数据源测试 SQL--%> 28 SELECT * FROM LEAD_OAMS_DBSOURCES 29 
      30 <%--使用c:forEach标签遍历查询结果集rs中的每一行--%> 31 
     
       32 <%--${row.字段名}获取字段的值--%> 33 ${row.RESOURCEID}---${row.DBSOURCE_NAME}---${row.DBSOURCE_TYPE}
      
 34 
      35 
     
 36 
SQLServer JNDI数据源测试
 37 <%--使用sql:query标签发送SQL语句去数据库查询数据，查询的结果集保存到rs变量当中，dataSource属性指明使用的数据源--%> 38 
     
       39 <%--SQLServer JNDI数据源测试 SQL--%> 40 select * from t_demo 41 
      42 <%--使用c:forEach标签遍历查询结果集rs中的每一行--%> 43 
     
       44 <%--${row.字段名}获取字段的值--%> 45 ${row.id}---${row.name}
      
 46 
      47  48 

　　运行结果如下：

　　

三、在Java代码中获取JNDI中的数据源

3.1、获取JNDI中的数据源

　　编写一个JdbcUtil工具类，JdbcUtil工具类负责从JNDI容器中获取DataSource，再通过DataSource获取数据库连接。

代码如下：

1 package me.gacl.util;  2   3 /** 4 * 
ClassName: JdbcUtil
 5 * 
Description: 从JNDI容器中获取DataSource，再通过DataSource获取数据库连接
 6 */ 7 import java.sql.Connection; 8 import java.sql.ResultSet; 9 import java.sql.SQLException; 10 import java.sql.Statement; 11 import javax.naming.Context; 12 import javax.naming.InitialContext; 13 import javax.naming.NamingException; 14 import com.alibaba.druid.pool.DruidDataSource; 15 16 public class JdbcUtil { 17 18 /* 19 web.xml文件中的JNDI数据源引用配置 20 21 
       22 
      
        23 
       
        Oracle DB Connection
        24 
       
        jdbc/OracleDataSource
        25 
       
        javax.sql.DataSource
        26 
       
        Container
        27 
       28 29 
       30 
      
        31 
       
        MySQL DB Connection
        32 
       
        jdbc/MysqlDataSource
        33 
       
        javax.sql.DataSource
        34 
       
        Container
        35 
       36 37 
       38 
      
        39 
       
        SQLServer DB Connection
        40 
       
        jdbc/SqlServerDataSource
        41 
       
        javax.sql.DataSource
        42 
       
        Container
        43 
       44 */ 45 46 //Oracle数据库配置的JNDI数据源连接名,后面跟的是DataSource名，DataSource名在web.xml文件中的
      进行了配置 47 private static final String ORACLE_DB_JNDINAME = "java:comp/env/jdbc/OracleDataSource"; 48 //MySQL数据库配置的JNDI数据源连接名，java:comp/env是必须加的,后面跟的是DataSource名 49 private static final String MYSQL_DB_JNDINAME = "java:comp/env/jdbc/MysqlDataSource"; 50 //SQLServer数据库配置的JNDI数据源连接名，java:comp/env是必须加的,后面跟的是DataSource名 51 private static final String SQLSERVER_DB_JNDINAME = "java:comp/env/jdbc/SqlServerDataSource"; 52 53 private static DruidDataSource dsOracle = null; 54 private static DruidDataSource dsMySql = null; 55 private static DruidDataSource dsSqlServer = null; 56 57 static{ 58 try { 59 //1、初始化名称查找上下文 60 Context ctx = new InitialContext(); 61 //2、通过JNDI名称找到DataSource 62 dsOracle = (DruidDataSource) ctx.lookup(ORACLE_DB_JNDINAME); 63 dsMySql = (DruidDataSource) ctx.lookup(MYSQL_DB_JNDINAME); 64 dsSqlServer = (DruidDataSource) ctx.lookup(SQLSERVER_DB_JNDINAME); 65 } catch (NamingException e) { 66 e.printStackTrace(); 67 } 68 } 69 70 /** 71 * MethodName: getOracleConnection 72 * Description: 获取Oracle数据库连接 73 * @author xudp 74 * @return 75 * @throws SQLException 76 */ 77 public static Connection getOracleConnection() throws SQLException { 78 return dsOracle.getConnection(); 79 } 80 81 /** 82 * MethodName: getMySqlConnection 83 * Description: 获取MySQL数据库连接 84 * @author xudp 85 * @return 86 * @throws SQLException 87 */ 88 public static Connection getMySqlConnection() throws SQLException { 89 return dsMySql.getConnection(); 90 } 91 92 /** 93 * MethodName: getSqlServerConnection 94 * Description: 获取SQLServer数据库连接 95 * @author xudp 96 * @return 97 * @throws SQLException 98 */ 99 public static Connection getSqlServerConnection() throws SQLException { 100 return dsSqlServer.getConnection(); 101 } 102 103 /** 104 * @Method: release 105 * @Description: 释放资源， 106 * 要释放的资源包括Connection数据库连接对象，负责执行SQL命令的Statement对象，存储查询结果的ResultSet对象 107 * @Anthor:孤傲苍狼 108 * 109 * @param conn 110 * @param st 111 * @param rs 112 */ 113 public static void release(Connection conn,Statement st,ResultSet rs){ 114 if(rs!=null){ 115 try{ 116 //关闭存储查询结果的ResultSet对象 117 rs.close(); 118 }catch (Exception e) { 119 e.printStackTrace(); 120 } 121 rs = null; 122 } 123 if(st!=null){ 124 try{ 125 //关闭负责执行SQL命令的Statement对象 126 st.close(); 127 }catch (Exception e) { 128 e.printStackTrace(); 129 } 130 } 131 132 if(conn!=null){ 133 try{ 134 //关闭Connection数据库连接对象 135 conn.close(); 136 }catch (Exception e) { 137 e.printStackTrace(); 138 } 139 } 140 } 141 }

3.2、测试JNDI数据源

　　编写一个测试的Servlet，测试代码如下：

1 package me.gacl.test;  2   3 import java.io.IOException; 4 import java.sql.Connection; 5 import java.sql.PreparedStatement; 6 import java.sql.ResultSet; 7 import java.sql.SQLException; 8 import java.util.ArrayList; 9 import java.util.LinkedHashMap; 10 import java.util.List; 11 import java.util.Map; 12 import javax.servlet.ServletException; 13 import javax.servlet.http.HttpServlet; 14 import javax.servlet.http.HttpServletRequest; 15 import javax.servlet.http.HttpServletResponse; 16 import me.gacl.util.JdbcUtil; 17 18 /** 19 * 
ClassName: JNDITestServlet
 20 * 
Description: 
 21 * 
Company:广州利迪网络科技有限公司 
 22 * @author xudp 23 * @version 1.0 V 24 * @createTime 2014-10-23 上午09:32:52 25 */ 26 public class JNDITestServlet extends HttpServlet { 27 28 public void doGet(HttpServletRequest request, HttpServletResponse response) 29 throws ServletException, IOException { 30 31 //Oracle数据库连接 32 Connection oracleConnection = null; 33 //MySql数据库连接 34 Connection mySqlConnection = null; 35 //SQLServer数据库连接 36 Connection sqlServerConnection = null; 37 38 //负责执行SQL的PreparedStatement对象 39 PreparedStatement pstmtOracle = null; 40 PreparedStatement pstmtMySQL = null; 41 PreparedStatement pstmtSqlServer = null; 42 43 //查询出来的结果集 44 ResultSet rsOracle = null; 45 ResultSet rsMySQL = null; 46 ResultSet rsSqlServer = null; 47 48 //存储查询出来的数据，每一行数据映射成一个Map，字段名作为key，字段的值作为value 49 List
       
        > oracleDataList = new ArrayList
        
       

　　JNDITest.jsp页面代码如下：

1 <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%> 2 <%--引入JSTL标签库 --%> 3 <%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c"%> 4  5  6  7  8  9 10  11 
从Oracle数据库中取出来的数据
 12 <%--使用c:forEach标签遍历List集合--%> 13 
     
       14 ${oracleDataMap.resourceid}---${oracleDataMap.dbsource_name}---${oracleDataMap.dbsource_type}
      
 15 
      16 
     
 17 
从mySql数据库中取出来的数据
 18 <%--使用c:forEach标签遍历List集合--%> 19 
     
       20 ${mySqlDataMap.resourceid}---${mySqlDataMap.app_name}
      
 21 
      22 
     
 23 
从sqlServer数据库中取出来的数据
 24 <%--使用c:forEach标签遍历List集合--%> 25 
     
       26 ${sqlServerDataMap.id}---${sqlServerDataMap.name}
      
 27 
      28  29 

　　运行结果如下：

　　

 

假如你现在还在为自己的技术担忧，假如你现在想提升自己的工资，假如你想在职场上获得更多的话语权，假如你想顺利的度过35岁这个魔咒，假如你想体验BAT的工作环境，那么现在请我们一起开启提升技术之旅吧，详情请点击