作者:baggio785
日期:2006-4-24
关键词:DataSource(数据源),Tomcat ,连接池

前言


本文根据实例详细介绍了如何在tomcat中配置数据源。网上此类文章很多,但是基本都是雷同的,而且对一些特殊问题以及原理并未详细阐述,所以想根据自己的实际经验,并结合例子写一篇详细的文章。
本文是偶的一些拙见,有不正确的地方请大家多多评论指正

开发环境

本文的环境:JDK1.4.2,TOMCAT5.0.28,Oracle9i

JDBC简介

提到数据源,那就不能不说JDBC。JDBCJava Database Connectivity的缩写。在java.sql包中提供了JDBC API,定义了访问数据库的接口和类。但是JDBC API不能直接访问数据库,必须依赖于数据库厂商提供的JDBC驱动程序,即JDBC DRIVER
Java.sql 中常用的接口和类如下:
       Driver 接口和 DriverManager
       Connection
       Statement
       PreparedSataement

       ResultSet

 

1     Driver 接口和 DriverManager
       DriverManager
类用来建立和数据库的连接以及管理 JDBC 驱动程序,常用方法如下:
方法 描述
registerDriver(Driver driver) DriverManager 中注册 JDBC 驱动程序
getConnection(String url,String user,String pwd) 建立和数据库的连接,返回 Connection 对象
setLoginTimeOut(int seconds) 设定等待数据库连接的最长时间
setLogWriter(PrintWriter out) 设定输入数据库日至的 PrintWriter 对象
2     Connection
       Connection
代表和数据库的连接,其常用方法如下:
方法 描述
getMetaData() 返回数据库的 MetaData 数据。 MetaData 数据包含了数据库的相关信息,例如当前数据库连接的用户名、使用的 JDBC 驱动程序、数据库允许的最大连接数、数据库的版本等等。
createStatement() 创建并返回 Statement 对象
PrepareStatement(String sql) 创建并返回 prepareStatement 对象
3      Statement
       Statement
用来执行静态 sql 语句。例如,对于 insert update delete 语句,调用 executeUpdate(String sql) 方法,而 select 语句可以调用 executeQuery(String sql) 方法, executeQuery(String sql) 方法返回 ResultSet 对象。
4      PrepareStatement
   PrepareStatement
用于执行动态的 sql 语句,即允许 sql 语句中包含参数。使用方法为:
   String sql = “select col1 from tablename where col2=? And col3=?”;
   PrepareStatement perpStmt = conn.preparestatement(sql);
   perpStmt.setstring(1,col2Value);
      perpStmt.setFloat(2,col3Value);
      ResultSet rs = perpStmt.executeQuery();
5      ResultSet
ResultSet
用来表示 select 语句查询得到的记录集,一个 StateMent 对象在同一时刻只能打开一个 ResultSet 对象。通过 ResultSet getXXX() 方法来得到字段值。 ResultSet 提供了 getString() getFloat() getInt() 等方法。可以通过字段的序号或者字段的名字来制定获取某个字段的值。例如:在上例中 getString(0),getString(col1) 都可以获得字段 col1 的值。
 
事务处理

在实际应用中,我们会遇到同时提交多个
sql 语句,这些 sql 语句要么全部成功,要么全部失败,如果其中一条提交失败,则必须撤销整个事务。为此, Connection 类提供了 3 个控制事务的方法:
 
方法 描述
setAutoCommit(boolen autoCommit) 设置是否自动提交事务,默认为自动提交
commit() 提交事务
rollback() 撤销事务
参考例子:
try{
conn.SetautoCommit(false);
stmt = conn.createstatement();
stmt.executeUpdate(“delete form table1 where col1=1”);
stmt.eecuteUpdate(“delete from table2 where col2=1”);
conn.comm.it();
}catch(Exception e){
       e.printStackTrace;
try{
              conn.rollback();
} catch(Exception e1){
       e1.printStackTrace;
}
}
通过一个 JSP 例子来访问 oracle 数据库:
<%@ page import=”java.util.*”>
<%@ page import=”java.sql.*”>
<%
try{
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
// 加载 oracle 驱动程序
Class.forName(“oracle.jdbc.driver.OracleDriver.”);
// 注册 oracle 驱动程序
DriverManager.regidterDriver(new oracle.jdbc.driver.OracleDriver());
// 建立数据库连接
conn=DriverManager.getConnection(“jdbc:oracle:thin:@your db ip:your db port:sid”,dbuser,dbpassword);
stmt = conn.createStatement();
rs = stmt.executeQuery(“select * from tablename”);
while(rs.next){
       out.print(rs.getstring(“colname”));
}
}catch(Exception e){
}
finally{
rs.close();
stmt.close();
conn.close();
}
%>

 
数据源简介

JDBC2.0
提供了 javax.sql.DataSource 的接口,负责与数据库建立连接,实际应用时不需要编写连接数据库代码,直接从数据源获得数据库的连接。 Dataource 中事先建立了多个数据库连接,这些数据库连接保持在数据库连接池中,当程序访问数据库时,只需要从连接池从取出空闲的连接,访问数据库结束,在将这些连接归还给连接池。
DataSource 对象由容器( Tomcat )提供,不能使用创建实例的方法来生成 DataSource 对象,要采用 JAVA JNDI Java Nameing and Directory Interface java 命名和目录接口)来获得 DataSource 对象的引用。(另有一种说法:“其实从技术上来说,数据源连接方式是不需要目录服务的,我们同样可以通过序列化数据源对象直接访问文件系统。这点是需要明确的。”感兴趣的朋友可以试试。) JNDI 是一种将对象和名字绑定的技术,对象工厂负责生产出对象,这些对象都和唯一的名字相绑定。程序中可以通过这个名字来获得对象的引用。 Tomcat DataSource 作为一种可配置的 JNDI 资源来处理,生成 DataSource 对象的工厂为 org.apache.comm.ons.dbcp.BasicDataSourceFactory  

配置数据源

配置数据源其实相当简单:
首先在 server.xml 中加入 <Resource> 元素,打开 server.xml ,在 <Context> 中加入以下代码(以 oracle 为例):
 
<Resource name="jdbc/ JNDI 名字 "
               auth="Container"
               type="javax.sql.DataSource"/>
 <ResourceParams name="jdbc/JNDI 名字 ">
    <parameter>
     <name>factory</name>
      <value>org.apache.commons.dbcp.BasicDataSourceFactory</value>
    </parameter>
    <parameter>
      <name>maxActive</name>
      <value>100</value>
    </parameter>
    <parameter>
      <name>maxIdle</name>
      <value>30</value>
    </parameter>
 
    <parameter>
      <name>maxWait</name>
      <value>10000</value>
    </parameter>
 
    <parameter>
     <name>username</name>
     <value> 用户名 </value>
    </parameter>
    <parameter>
     <name>password</name>
     <value> 密码 </value>
    </parameter>
 
    <parameter>
       <name>driverClassName</name>
       <value>oracle.jdbc.driver.OracleDriver</value>
    </parameter>
 
    <parameter>
      <name>url</name>
      <value>jdbc:oracle:thin:@ip: 端口 :sid </value>
    </parameter>
 </ResourceParams>
<Resource> 元素的属性如下:
属性 描述
name 指定 Resource JNDI 的名字
auth 指定管理 Resource Manager ,由两个可选值: Container Application Container 表示由容器来创建和管理 Resource Application 表示由 WEB 应用来创建和管理 Resource 。如果在 web application deployment descriptor 中使用 <resource-ref> ,这个属性是必需的,如果使用 <resource-env-ref> ,这个属性是可选的。
type 指定 Resource 所属的 java 类名
<ResourceParams> 元素的属性如下:
属性 描述
name 指定 ResourceParams JNDI 的名字,必须和 Resource name 保持一致
factory 指定生成 DataSource 对象的 factory 的类名
maxActive 指定数据库连接池中处于活动状态的数据库连接最大数目, 0 表示不受限制
maxIdle 指定数据库连接池中 处于 空闲状态的数据库连接的最大数目, 0 表示不受限制
maxWait 指定数据库连接池中的数据库连接处于空闲状态的最长时间(单位为毫秒),超过这一事件,将会抛出异常。 -1 表示可以无限期等待。
username 指定连接数据库的用户名
password 指定连接数据库的密码
driverClassName 指定连接数据库的 JDBC 驱动程序
url 指定连接数据库的 URL

其他文章说以上配置就OK了,对于web.xml的配置可有可无,其实不是这样子的。如果在web应用中访问了由Servlet容器管理的某个JNDI Resource,则必须在web.xml中声明对这个JNDI Resource的引用。表示资源引用的元素为<resource-ref>,该元素加在<wepapp></ wepapp >中。

<resource-ref>
     <descryiption>DB Connection</descryiption>
<res-ref-name>jdbc/JNDI 名字 </ res-ref-name>
<res-type>javax.sql.DataSource </ res- type>
<res-auth>Container </ res- auth>
</resource-ref>

<resource-ref>
元素的属性如下:

属性 描述
description 对所引用的资源的说明
res-ref-name 指定所引用资源的 JNDI 名字,与 <Resource> 元素中的 name 属性保持一致
res-type 指定所引用资源的类名字,与 <Resource> 元素中的 type 属性保持一致
res-auth 指定所引用资源的 Manager ,与 <Resource> 元素中的 auth 属性保持一致

到这里,数据源就已经配置成功了。但是我在测试的时候除了一点小麻烦,主要原因是对DataSource的概念没搞清楚。我是这么测试的,写一个测试类,然后在eclipse中进行junit测试,
捕获的异常为:
javax.naming.NoInitialContextException : Need to specify class name in environment or system property, or as an applet parameter, or in an application resource file: java.naming.factory.initia l
同样的代码在JSP文件中正常运行,后来翻了一些资料,终于找到了问题的所在了。原来DataSource是由容器(TOMCAT)提供的,所以我的测试会抛出异常。为了再次验证想法是否正确,在jsp文件中import刚才抛出异常的类,在进行连接数据库,结果一切正常。
下面的例子是实际应用中使用 DataSource ,在 jsp 文件中连接 oracle
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@ page import="java.sql.*"%>
<%@ page import="javax.naming.*"%>
<%@ page import="javax.sql.*"%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
 <head>
 </head>
<body>
<%
Context initContext = new InitialContext();
Context envContext = (Context) initContext.lookup("java:/comp/env");
DataSource db = (DataSource)envContext.lookup("jdbc/javablogorl");
// javablogorl <Resource> 元素中 name 属性的值
Connection conn = db.getConnection( ); 
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM blog_systemadmin");
while(rs.next()){
       out.print(rs.getString("admin_name")+" ");
       out.print(rs.getString("admin_password")+"<br>");
}
rs.close();
stmt.close();
conn.close();
%> 
 </body>
</html>
 


Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=674822