开发者社区> 古镇月影> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

jsp 数据连接池 2

简介: 引用:http://bbs.hh010.com/thread-32010-2-1.html //下面这两个是连接池,下面两个文件都放在一个mybean的包里.   package mybean;   import java.
+关注继续查看

 引用:http://bbs.hh010.com/thread-32010-2-1.html

//下面这两个是连接池,下面两个文件都放在一个mybean的包里.
  package mybean;
  import java.sql.*;
  import java.util.*;
  public class DBConnPool {
  //正在使用连接的数量
  private int using;
  //目前可用的连接数,即空闲连接
  private Vector connections=new Vector();
  //最大连接数
  private int maxconn;
  //连接池名
  private String poolname;
  //数据库标识
  private String dbid;
  //驱动程序名
  private String drivername;
  //数据库帐号
  private String username;
  //数据库密码
  private String passwd;
  public DBConnPool(String poolname,String dbid,String drivername,
  String username,String passwd,int maxconn){
  this.poolname=poolname;
  this.drivername=drivername;
  this.dbid =dbid;
  this.username =username;
  this.passwd=passwd;
  this.maxconn=maxconn;
  }
  /*将空闲连接返回给连接池*/
  public synchronized void returnConnection(Connection conn){
  //将指定连接加到向量末尾
  connections.addElement(conn);
  //连接用户减一
  using--;
  }
  /*从连接池得到一个连接*/
  public synchronized Connection getConnection(){
  Connection conn = null; //Connection是一个类,
  //connections是一个向量,用于存储连接对象,它所存储是的所有空闲状态的可用连接
  if (connections.size() > 0) {
  //获取连接列表的第一个连接
  conn = (Connection) connections.elementAt(0);
  connections.removeElementAt(0);//获得一个连接,并将此连接从队列中删除.
  //如果此连接已关闭,刚继续获取,
  try {
  if (conn.isClosed())
  conn = getConnection();
  }
  catch (Exception e) {
  e.printStackTrace();
  }
  }
  //如果实际使用的连接数小于最大连接数即有可用连接),就新增加一个连接
  else if (maxconn == 0 || using < maxconn){
  //如此时无可用连接(maxconn == 0)且连接数又未达到上限(using < maxconn)),就创建一个新连接
  conn=newConnection();
  }
  //如果连接数已达到上限就返回空指针
  if (conn!=null){
  using++;
  }
  return conn;
  }

/*创建新的连接*/
  public Connection newConnection(){
  Connection conn=null;
  try{
  //加载驱动
  Class.forName(drivername);
  conn=DriverManager.getConnection(dbid,username,passwd);
  }catch(Exception e){
  e.printStackTrace();
  return null;
  }
  return conn;
  }
  /*关闭所有连接*/
  public synchronized void closeConn(){
  Enumeration allConnections=connections.elements();
  while (allConnections.hasMoreElements()){
  Connection conn=(Connection) allConnections.nextElement();
  try{
  conn.close();
  }catch(SQLException e){
  e.printStackTrace();
  }
  }
  connections.removeAllElements();
  }
  }
  package mybean;
  import java.sql.*;
  import java.util.*;
  public class DBConnManager {
  //连接池名列表
  private Vector poolnames =new Vector();
  //驱动程序名列表
  private Vector drivernames=new Vector();
  //数据库标识列表
  private Vector dbids=new Vector();
  //用户名列表
  private Vector usernames=new Vector();
  //用户密码列表
  private Vector passwds=new Vector();
  //最大连接数列表
  private Vector maxconns=new Vector();
  //连接池队列
  private Hashtable connPools=new Hashtable();
  public DBConnManager() {
  //添加Access数据库的连接信息
  poolnames.addElement("access");
  drivernames.addElement("sun.jdbc.odbc.JdbcOdbcDriver");
  dbids.addElement("jdbcdbc:shopping");
  usernames.addElement("");
  passwds.addElement("");
  maxconns.addElement("5");
  //添加SQL Server2000数据库的连接信息
  poolnames.addElement("sqlserver2000");
  drivernames.addElement("com.microsoft.jdbc.sqlserver.SQLServerDriver");
  dbids.addElement("jdbc:microsoft:sqlserver://localhost:1433;DatabserName=shopping");
  usernames.addElement("");
  passwds.addElement("");
  maxconns.addElement("5");

//连接Mysql数据库信息
  poolnames.addElement("mysql");
  drivernames.addElement("org.gjt.mm.mysql.Driver");
  dbids.addElement("jdbc:mysql://localhost/shopping");
  usernames.addElement("");
  passwds.addElement("");
  maxconns.addElement("5");
  //连接Oracle8i/9i数据库
  poolnames.addElement("oracle");
  drivernames.addElement("oracle.jdbc.driver.OracleDriver");
  dbids.addElement("jdbcracle:thinlocalhost:1521:shopping");
  usernames.addElement("");
  passwds.addElement("");
  maxconns.addElement("5");
  //创建连接池
  createPools();
  }
  /*将连接返回给由指定的连接池*/
  public void returnConnection(String name,Connection conn){
  DBConnPool pool=(DBConnPool) connPools.get(name);
  if (pool!=null)
  {
  pool.returnConnection(conn);
  }
  }
  /*得到一个指定连接池中的连接*/
  public Connection getConnection(String name){
  DBConnPool pool=(DBConnPool) connPools.get(name);
  if (pool!=null)
  {
  return pool.getConnection();
  }
  return null;
  }
  /*关闭所有连接*/
  public synchronized void closeConns(){
  Enumeration allPools=connPools.elements();
  while (allPools.hasMoreElements()){
  DBConnPool pool=(DBConnPool) allPools.nextElement();
  pool.closeConn();
  }
  }
  /*创建连接池*/
  private void createPools(){
  for (int i=0;i<poolnames.size();i++)
  {
  String poolname=poolnames.elementAt(i).toString();
  String drivername=drivernames.elementAt(i).toString();
  String dbid=dbids.elementAt(i).toString();
  String username=usernames.elementAt(i).toString();
  String passwd=passwds.elementAt(i).toString();
  int maxconn=0;
  try{
  maxconn=Integer.parseInt(maxconns.elementAt(i).toString());
  }catch (NumberFormatException e){
  e.printStackTrace();
  }
  DBConnPool pool=new DBConnPool(poolname,drivername,dbid,username,
  passwd,maxconn);
  connPools.put(poolname,pool);
  }
  }
  }

下面这个是主页面.JSP文件
  <%@ page contentType="text/html; charset=GBK" %>
  <%@ page import ="java.sql.*" %>
  <jsp:useBean id="connManager" scope="application" class="mybean.DBConnManager" />
  <html>
  <head>
  <title>
  购物商城首页
  </title>
  </head>
  <body bgcolor="#B0C4DE">
  <center><h1>欢迎访问本购物商城</h1></center>
  <%
  //Connection connA=connManager.getConnection("access");
  Connection connS=connManager.getConnection("sqlserver2000");
  if (connS==null)
  {
  %>
  数据库正忙,请稍后再访问
  <%
  }
  //Statement stmtA=connA.createStatement();
  Statement stmtS=connS.createStatement();
  %>
  <%
  String sql="select * from userinfo";
  ResultSet rs=stmtS.executeQuery(sql);
  while (rs.next())
  {
  %>
  <tr>
  <td><%=rs.getString("username")%></td>
  <td><%=rs.getString("userpass")%></td>
  </tr>
  <%
  }
  rs.close();
  stmtS.close();
  connManager.returnConnection("sqlserver2000",connS);
  %>
  </body>
  </html>

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
JDBC数据库连接池
JDBC数据库连接池
24 0
JSP连接mysql数据库的重点
1:用mysql驱动把mysql与tomcat的连接起来。把mysql驱动包(不用解压)放到Tomcat安装目录中lib文件夹下即可。  2:然后在自己的新建的web应用程序上面就可以下下面的代码 3:JDBC连接mysql数据库三步走 第一首先加载数据库驱动,注册到驱动管理器Class.
943 0
java数据库连接池dbcp的使用
<p></p> <p style="color:rgb(75,75,75); font-family:verdana,Arial,helvetica,sans-seriff; font-size:13px; line-height:19.200000762939453px"> 近年来,随着Internet/Intranet建网技术的飞速发展和在世界范围内的迅速普及,计算机</p> <
1161 0
JSP数据库综合练习
一.问题概述         实现了数据库的增删改查和分页显示。         分页显示:mysql String cmd = "select * from t_user limit "+firstResult+","+pageSize; mysql> SELECT * FROM ta...
811 0
JNDI连接数据库
一、JNDI数据库连接通用数据访问层(JNDIDBManager) 代码下: package com.myphome.dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; impor
1718 0
jsp 数据饼图
引用:http://www.andjava.com/a/tab2/tab2_9/2012/0302/1628.html <%@pagelanguage="Java"%><%@pageimport="java.
552 0
+关注
1699
文章
3
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载