Chinaunix首页 | 论坛 | 博客
  • 博客访问: 482993
  • 博文数量: 1496
  • 博客积分: 79800
  • 博客等级: 大将
  • 技术积分: 9940
  • 用 户 组: 普通用户
  • 注册时间: 2008-09-09 13:22
文章分类

全部博文(1496)

文章存档

2011年(1)

2008年(1495)

我的朋友

分类:

2008-09-09 13:26:36


  连结数据库
  
  JDBC使用数据库URL来说明数据库驱动程序。数据库URL类似于通用的URL,但SUN 在定义时作了一点简化,其语法如下:
  
  Jdbc::[node]/[database]
  
  其中子(subprotocal)定义驱动程序类型,node提供网络数据库的位置和端口号,后面跟可选的参数。例如:
  
  String url=”jdbc:inetdae:myserver:1433?language=us-english&sql7=true”
  
  表示采用inetdae驱动程序连接1433端口上的myserver数据库,选择语言为美国英语,数据库的版本是mssql server 7.0。
  
  java应用通过指定DriverManager装入一个驱动程序类。语法如下:
  
  Class.forName(“”);
  
  或
  
  Class.forName(“”).newInstance();
  
  然后,DriverManager创建一个特定的连接:
  
  Connection connection=DriverManager.getConnection(url,login,password);
  
  Connection接口通过指定数据库位置,登录名和密码连接数据库。Connection接口创建一个Statement实例执行需要的查询:
  
  Statement stmt=connection.createStatement();
  
  Statement具有各种方法(API),如executeQuery,execute等可以返回查询的结果集。结果集是一个ResultSet对象。具体的可以通过jdbc开发文档查看。可以sun的站点上
  
  下面例子来说明:
  
  import java.sql.*; // 输入JDBC package
  
  String url = "jdbc:inetdae:myserver:1433";// 主机名和端口
  String login = "user";// 登录名
  String password = "";// 密码
  
  try {
  DriverManager.setLogStream(System.out); file://为显示一些的信息打开一个流
  file://调用驱动程序,其名字为com.inet.tds.TdsDriver
  file://Class.forName("com.inet.tds.TdsDriver");
  file://设置超时
  DriverManager.setLoginTimeout(10);
  file://打开一个连接
  Connection connection = DriverManager.getConnection(url,login,password);
  file://得到数据库驱动程序版本
  
  DatabaseMetaData conMD = connection.getMetaData();
  System.out.println("Driver Name:\t" + conMD.getDriverName());
  System.out.println("Driver Version:\t" + conMD.getDriverVersion());
  
  file://选择数据库
  connection.setCatalog( "MyDatabase");
  
  file://创建Statement
  
  Statement st = connection.createStatement();
  
  file://执行查询
  
  ResultSet rs = st.executeQuery("SELECT * FROM mytable");
  
  file://取得结果,输出到屏幕
  
  while (rs.next()){
  for(int j=1; j<=rs.getMetaData().getColumnCount(); j++){
  System.out.print( rs.getObject(j)+"\t");
  }
  System.out.println();
  }
  
  file://关闭对象
  st.close();
  connection.close();
  } catch(Exception e) {
  e.printStackTrace();
  }
  
  建立连结池
  
  一个动态的网站频繁地从数据库中取得数据来构成html页面。每一次请求一个页面都会发生数据库操作。但连接数据库却是一个需要消耗大量时间的工作,因为请求连接需要建立通讯,分配资源,进行权限认证。这些工作很少能在一两秒内完成。所以,建立一个连接,然后再后续的查询中都使用此连接会大大地提高性能。因为servlet可以在不同的请求间保持状态,因此采用数据库连接池是一个直接的解决方案。
  
  Servlet在的进程空间中驻留,可以方便而持久地维护数据库连接。接下来,我们介绍一个完整的连接池的实现。在实现中,有一个连接池管理器管理连接池对象,其中每一个连接池保持一组数据库连接对象,这些对象可为任何servlet所使用。
  
  一、数据库连接池类 DBConnectionPool,提供如下的方法:
  
  1、从池中取得一个打开的连接;
  
  2、将一个连接返回池中;
  
  3、在关闭时释放所有的资源,并关闭所有的连接。
  
  另外,DBConnectionPool还处理连接失败,比如超时,通讯失败等错误,并且根据预定义的参数限制池中的连接数。
  
  二、管理者类,DBConnetionManager,是一个容器将连接池封装在内,并管理所有的连接池。它的方法有:
  
  1、 调用和注册所有的jdbc驱动程序;
  
  2、 根据参数表创建DBConnectionPool对象;
  
  3、 映射连接池的名字和DBConnectionPool实例;
  
  4、 当所有的连接客户退出后,关闭全部连接池。
  
  这些类的实现,以及如何在servlet中使用连接池的应用在随后的文章中讲解
  
  DBConnectionPool类代表一个由url标识的数据库连接池。前面,我们已经提到,jdbc的url由三个部分组成:标识(总是jdbc),子标识(例如,odbc.oracle),和数据库标识(跟特定的数据库有关)。连接池也具有一个名字,供客户程序引用。另外,连接池还有一个用户名,一个密码和一个最大允许连接数。如果web应用允许所有的用户使用某些数据库操作,而另一些操作是有限制的,则可以创建两个连接池,具有同样的url,不同的user name和password,分别处理两类不同的操作权限。现把DBConnectionPool详细介绍如下:
  
  三、DBConnectionPool的构造
  
  构造函数取得上述的所有参数:
  
  public DBConnectionPool(String name, String URL, String user,
  String password, int maxConn) {
  this.name = name;
  this.URL = URL;
  this.user = user;
  this.password = password;
  this.maxConn = maxConn;
  }
  
  将所有的参数保存在实例变量中。
  
  四、从池中打开一个连接
  
  DBConnectionPool提供两种方法来检查连接。两种方法都返回一个可用的连接,如果没有多余的连接,则创建一个新的连接。如果最大连接数已经达到,第一个方法返回null,第二个方法则等待一个连接被其他进程释放。
  
  public synchronized Connection getConnection() {
  Connection con = null;
  if (freeConnections.size() > 0) {
  // Pick the first Connection in the Vector
  // to get round-robin usage
  con = (Connection) freeConnections.firstElement();
  freeConnections.removeElementAt(0);
  try {
  if (con.isClosed()) {
  log("Removed bad connection from " + name);
  // Try again recursively
  con = getConnection();
  }
  }
  catch (SQLException e) {
  log("Removed bad connection from " + name);
  // Try again recursively
  con = getConnection();
  }
  }
  else if (maxConn == 0 || checkedOut < maxConn) {
  con = newConnection();
  }
  if (con != null) {
  checkedOut++;
  }
  return con;
  }
  
  所有空闲的连接对象保存在一个叫freeConnections 的Vector中。如果存在至少一个空闲的连接,getConnection()返回其中第一个连接。下面,将会看到,进程释放的连接返回到freeConnections的末尾。这样,最大限度地避免了数据库因一个连接不活动而意外将其关闭的风险。
  
  再返回客户之前,isClosed()检查连接是否有效。如果连接被关闭了,或者一个错误发生,该方法递归调用取得另一个连接。
  
  如果没有可用的连接,该方法检查是否最大连接数被设置为0表示无限连接数,或者达到了最大连接数。如果可以创建新的连接,则创建一个新的连接。否则,返回null。
  
  方法newConnection()用来创建一个新的连接。这是一个私有方法,基于用户名和密码来确定是否可以创建新的连接。
  
  private Connection newConnection() {
  Connection con = null;
  try {
  if (user == null) {
  con = DriverManager.getConnection(URL);
  }
  else {
  con = DriverManager.getConnection(URL, user, password);
  }
  log("Created a new connection in pool " + name);
  }
  catch (SQLException e) {
  log(e, "Can not create a new connection for " + URL);
  return null;
  }
  return con;
  }
  
  jdbc的DriverManager提供一系列的getConnection()方法,可以使用url和用户名,密码等参数创建一个连接。
  
  第二个getConnection()方法带有一个超时参数 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) {
  // Timeout has expired
  return null;
  }
  }
  return con;
  }
  
  局部变量startTime初始化当前的时间。一个whi
【责编:admin】

--------------------next---------------------

阅读(127) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~