|
|
|
JSP+JDBC(Thin模式)连接Oracle |
热 ★★★★ |
|
JSP+JDBC(Thin模式)连接Oracle |
|
作者:闵涛 文章来源:闵涛的学习笔记 点击数:1228 更新时间:2009/4/23 10:55:12 |
|
在JSP中连接到Oracle一般有2种方式:
1、Oracle JDBC的oci8方式
2、Oracle
JDBC的thin方式
我比较喜欢第2种,因为WEB发布服务器与数据库服务器一般都不会放在同一台电脑中,而在使用thin方式连接时,WEB服务器端无须安装oracle的客户端。
在动手先代码之前,我们先把环境配置妥善。先从安装了Oracle的数据库服务器中,找到Oracle安装目录,然后将该目录下的jdbc\lib\classes12.jar文件拷贝到WEB发布服务器的某个目录。假设就直接放在C:\根目录下吧,然后把该路径添加到‘系统--高级--环境变量’中变量名为‘CLASSPATH’的值中,如:D:\Program
Files\SQLLIB\java\db2java.zip;D:\Program
Files\SQLLIB\java\runtime.zip;c:classes12.jar;
也就是让java能够找到这个包。
配置好环境后,我们就开始开始动手写代码了。关于数据库连接的代码,应该写个专门的连接类来调用,没必要想网络上有些文章那样,直接写到JSP的代码中。
关于连接的代码很简单
private Connection newConnection(String user,String password)
{ Connection con = null; try {
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
con = DriverManager.getConnection
(“jdbc:oracle:thin:@192.168.96.1:1521:oracle9i”,user,password); }
catch (SQLException e) { return null; } return con; }
如果帐号密码没有错,那这个函数就应该能返回个可用的连接。但如此简单的连接在一个项目中使用,是远远达不到效果的。我们可以在这个数据库连接类中加入更多的功能,如连接池等等。下面我就把该数据库连接类的代码详细的列出来,大家可以参考参考。
/* * @Title 公司网站 * @Author: zf * @Version 1.0 *
@Memo:定义数据库连接及其数据库连接池等 */ package com.kingson.db;
import
java.io.*; import java.sql.*; import java.util.*; import
java.util.Date;
public class DBConnectionManager { static
private DBConnectionManager instance; // 唯一实例 static private int
clients;
private Vector drivers = new Vector(); private
PrintWriter log; private Hashtable pools = new
Hashtable();
/** * 返回唯一实例.如果是第一次调用此方法,则创建实例 * * @return
DBConnectionManager 唯一实例 */ static synchronized public
DBConnectionManager getInstance() { if (instance == null) { instance
= new DBConnectionManager(); } clients++; return
instance; }
/** * 建构函数私有以防止其它对象创建本类实例 */ private
DBConnectionManager() { init(); }
/** *
将连接对象返回给由名字指定的连接池 * * @param name 在属性文件中定义的连接池名字 * @param con
连接对象 */ public void freeConnection(String name, Connection con)
{ DBConnectionPool pool = (DBConnectionPool) pools.get(name); if
(pool != null) { pool.freeConnection(con); } }
/** *
获得一个可用的(空闲的)连接.如果没有可用连接,且已有连接数小于最大连接数 * 限制,则创建并返回新连接 * * @param
name 在属性文件中定义的连接池名字 * @return Connection 可用连接或null */ public
Connection getConnection(String name) { DBConnectionPool pool =
(DBConnectionPool) pools.get(name); if (pool != null) { return
pool.getConnection(); } return null; }
/** *
获得一个可用连接.若没有可用连接,且已有连接数小于最大连接数限制, *
则创建并返回新连接.否则,在指定的时间内等待其它线程释放连接. * * @param name 连接池名字 * @param
time 以毫秒计的等待时间 * @return Connection 可用连接或null */ public
Connection getConnection(String name, long time) { DBConnectionPool
pool = (DBConnectionPool) pools.get(name); if (pool != null)
{ return pool.getConnection(time); } return
null; }
/** * 关闭所有连接,撤销驱动程序的注册 */ public synchronized
void release() { // 等待直到最后一个客户程序调用 if (--clients != 0)
{ return; }
Enumeration allPools = pools.elements(); while
(allPools.hasMoreElements()) { DBConnectionPool pool =
(DBConnectionPool)
allPools.nextElement(); pool.release(); } Enumeration allDrivers
= drivers.elements(); while (allDrivers.hasMoreElements()) { Driver
driver = (Driver) allDrivers.nextElement(); try
{ DriverManager.deregisterDriver(driver); log("撤销JDBC驱动程序 " +
driver.getClass().getName()+"的注册"); } catch (SQLException e)
{ log(e, "无法撤销下列JDBC驱动程序的注册: " +
driver.getClass().getName()); } } }
/** *
根据指定属性创建连接池实例. * * @param props 连接池属性 */ private void
createPools(Properties props) { Enumeration propNames =
props.propertyNames(); while (propNames.hasMoreElements()) { String
name = (String) propNames.nextElement(); if (name.endsWith(".url"))
{ String poolName = name.substring(0, name.lastIndexOf(".")); String
url = props.getProperty(poolName + ".url"); if (url == null)
{ log("没有为连接池" + poolName + "指定URL"); continue; } String user
= props.getProperty(poolName + ".user"); String password =
props.getProperty(poolName + ".password"); String dbip =
props.getProperty(poolName + ".db_ip", "192.168.96.1"); String dbport =
props.getProperty(poolName + ".db_port", "1521"); String dbuid =
props.getProperty(poolName + ".db_uid", "ORACLE9I"); String maxconn =
props.getProperty(poolName + ".maxconn", "0"); //连接信息 String dbInfo
= user + "/" + password + "@" + dbip + ":" + dbport + ":" + dbuid; int
max; try { max =
Integer.valueOf(maxconn).intValue(); } catch (NumberFormatException
e) { log("错误的最大连接数限制: " + maxconn + " .连接池: " + poolName); max =
0; } DBConnectionPool pool = new DBConnectionPool(poolName,
url,dbInfo, max); pools.put(poolName, pool); log("成功创建连接池" +
poolName); } } }
/** * 读取属性完成初始化 */ private void
init() { InputStream is =
getClass().getResourceAsStream("db.properties"); Properties dbProps =
new Properties(); try { dbProps.load(is); } catch (Exception
e) { System.err.println("不能读取属性文件. "
+ "请确保db.properties在CLASSPATH指定的路径中"); return; } String
logFile = dbProps.getProperty("logfile", "newslog.txt"); try { log =
new PrintWriter(new FileWriter(logFile, true), true); } catch
(IOException e) { System.err.println("无法打开日志文件: " + logFile); log =
new
PrintWriter(System.err); } loadDrivers(dbProps); createPools(dbProps); }
/** *
装载和注册所有JDBC驱动程序 * * @param props 属性 */ private void
loadDrivers(Properties props) { String driverClasses =
props.getProperty("driver"); StringTokenizer st = new
StringTokenizer(driverClasses); while (st.hasMoreElements())
{ String driverClassName = st.nextToken().trim(); try { Driver
driver =
(Driver) Class.forName(driverClassName).newInstance(); DriverManager.registerDriver(driver); drivers.addElement(driver); log("成功注册JDBC驱动程序"
+ driverClassName); } catch (Exception e) { log("无法注册JDBC驱动程序: "
+ driverClassName + ", 错误: " + e); } } }
/** *
将文本信息写入日志文件 */ private void log(String msg) { log.println(new
Date() + ": " + msg); }
/** * 将文本信息与异常写入日志文件 */ private
void log(Throwable e, String msg) { log.println(new Date() + ": " +
msg); e.printStackTrace(log); }
/***************连接池类*************************************************/
/** *
此内部类定义了一个连接池.它能够根据要求创建新连接,直到预定的最 *
大连接数为止.在返回连接给客户程序之前,它能够验证连接的有效性. */ class DBConnectionPool
{ private int checkedOut; private Vector freeConnections = new
Vector(); private int maxConn; private String name; private
String URL; private String dbInfo;
/** * 创建新的连接池 * *
@param name 连接池名字 * @param URL 数据库的JDBC URL * @param dbInfo
数据库连接信息 * @param maxConn 此连接池允许建立的最大连接数 */ public
DBConnectionPool(String name, String URL, String dbInfo, int maxConn)
{ this.name = name; this.URL = URL; this.dbInfo =
dbInfo; this.maxConn = maxConn; }
/** *
将不再使用的连接返回给连接池 * * @param con 客户程序释放的连接 */ public synchronized
void freeConnection(Connection con) { //
将指定连接加入到向量末尾 freeConnections.addElement(con); checkedOut--; notifyAll(); }
/** *
从连接池获得一个可用连接.如没有空闲的连接且当前连接数小于最大连接 *
数限制,则创建新连接.如原来登记为可用的连接不再有效,则从向量删除之, *
然后递归调用自己以尝试新的可用连接. */ public synchronized Connection getConnection()
{ Connection con = null; if (freeConnections.size() > 0) { //
获取向量中第一个可用连接 con = (Connection)
freeConnections.firstElement(); freeConnections.removeElementAt(0); try
{ if (con.isClosed()) { log("从连接池" + name+"删除一个无效连接"); //
递归调用自己,尝试再次获取可用连接 con = getConnection(); } } catch
(SQLException e) { log("从连接池" + name+"删除一个无效连接"); //
递归调用自己,尝试再次获取可用连接 con = getConnection(); } } else if (maxConn
== 0 || checkedOut < maxConn) { con = newConnection(); } if
(con != null) { checkedOut++; } return con; }
/** *
从连接池获取可用连接.可以指定客户程序能够等待的最长时间 * 参见前一个getConnection()方法. * * @param
timeout 以毫秒计的等待时间限制 */ public synchronized Connection
getConnection(long timeout) { long startTime = new
Date().getTime(); Connection con; while ((con = getConnection()) ==
null) { try { wait(timeout); } catch (InterruptedException e)
{} if ((new Date().getTime() - startTime) >= timeout) { //
wait()返回的原因是超时 return null; } } return
con; }
/** * 关闭所有连接 */ public synchronized void
release() { Enumeration allConnections =
freeConnections.elements(); while (allConnections.hasMoreElements())
{ Connection con = (Connection) allConnections.nextElement(); try
{ con.close(); log("关闭连接池" + name+"中的一个连接"); } catch
(SQLException e) { log(e,[1] [2] 下一页 没有相关教程
|
|
教程录入:mintao 责任编辑:mintao |
|
|
上一篇教程: 用JSP构建三层管理信息系统 下一篇教程: JSP/Servlet应用程序优化八法 |
|
|
【字体:小 大】【发表评论】【加入收藏】【告诉好友】【打印此文】【关闭窗口】 |
|
注:本站部分文章源于互联网,版权归原作者所有!如有侵权,请原作者与本站联系,本站将立即删除! 本站文章除特别注明外均可转载,但需注明出处! [MinTao学以致用网] |
网友评论:(只显示最新10条。评论内容只代表网友观点,与本站立场无关!) |
|
|
|
|
|
|
|
同类栏目 |
|
|
赞助链接 |
|
|
500 - 内部服务器错误。
|
|
|
|
|
|