vi ／home／www／cnmsql.jsp ## 源代码如下： ＜%@ page language="Java" import="java.sql.*"%＞ ＜% Class.forName （"org.gjt.mm.mysql.Driver"）; Connection conn = DriverManager.getConnection（"jdbc:mysql:／／host_name／db_name","user_name","passWord"）; Statement stmt = conn.createStatement（）; ResultSet rs=stmt.executeQuery（"select * from prov"）; rs.next（）; out.print（rs.getString（"prov_id"）+" "+rs.getString（"prov_name"）+""）; rs.next（）; out.print（rs.getString（"prov_id"）+" "+rs.getString（"prov_name"）+""）; rs.previous（）; out.print（rs.getString（"prov_id"）+" "+rs.getString（"prov_name"）+""）; rs.last（）; out.print（rs.getString（"prov_id"）+" "+rs.getString（"prov_name"）+""）; rs.first（）; out.print（rs.getString（"prov_id"）+" "+rs.getString（"prov_name"）+""）; rs.close（）; stmt.close（）; conn.close（）; %＞ 4 测试该程序 lynx http:／／www.yesgo.loc／cnmysql ##正确的结果应该是： 1 安徽 2 北京 1 安徽 34 台湾 1 安徽 例二：使用连接池连接数据库 1 建立数据源 vi ／usr／local／resin／conf／resin.conf ＜resource-ref＞ ＜res-ref-name＞jdbc／yesgo＜／res-ref-name＞ ／／数据源名称 ＜res-type＞javax.sql.DataSource＜／res-type＞ ／／数据源类型 ＜init-param driver-name="org.gjt.mm.mysql.Driver"／＞ ／／数据库驱动 ＜init-param url=" jdbc:mysql:／／localhost／yesgo "／＞ ／／连接串 ＜init-param user="your_user_name"／＞ ／／用户名 ＜init-param password="your_password"／＞ ／／密码 ＜init-param max-connections="20"／＞ ／／最大连接数 ＜init-param max-idle-time="30"／＞ ／／延时时间 ＜／resource-ref＞ 2 创建JSP源文件 toUCh ／home／www／testpool.jsp chown -R www ／home／www／testpool.jsp chgrp -r root ／home／www／testpool.jsp chmod 771 ／home／www／testpool.jsp vi ／home／www／testpool.jsp ## 源代码如下： ＜%@ page language="java" import="java.sql.*,com.caucho.sql.*;"%＞ ＜% DBPool pool=new DBPool（）; Connection conn = pool.getPool（"data_source_name "）.getConnection（）; Statement stmt = conn.createStatement（）; ResultSet rs=stmt.executeQuery（"select * from prov"）; rs.next（）; out.print（rs.getString（"prov_id"）+rs.getString（"prov_name"）+""）; rs.next（）; out.print（rs.getString（"prov_id"）+rs.getString（"prov_name"）+""）; rs.previous（）; out.print（rs.getString（"prov_id"）+rs.getString（"prov_name"）+""）; rs.last（）; out.print（rs.getString（"prov_id"）+" "+rs.getString（"prov_name"）+""）; rs.first（）; out.print（rs.getString（"prov_id"）+rs.getString（"prov_name"）+""）; rs.close（）; stmt.close（）; conn.close（）; %＞ 3 调试该程序 lynx http:／／www.yesgo.loc／testpool.jsp ##处理的结果跟例一是一样的： 1 安徽 2 北京 1 安徽 34 台湾 1 安徽 例三：使用处理层连接数据库 ##本例告诉你如何使用组件 ##其实你完全可以写一个bean来处理数据库，而不用象例二那么罗索。只用四条语句就可以取出数据库中的所有数据并显示出来，这样做实现了处理层和逻辑层的彻底分离，由逻辑层发出指令、由处理层去响应相关处理，记录集也不会返回到逻辑层的jsp页面，而由处理层的bean处理，使得代码非常精简，效率也更高。至于如何书写组件不是本文档的重点，下面仅给出一个组件的例子并说明逻辑层的调用方法，你会发现其实逻辑层是个官僚，处理层是下属，呵呵。 1 创建处理层组件 下面的组件是我为公司写的数据库处理组件的简化版本，考虑到篇幅和可读性等问题，这里我简化了它的功能（象数据分页、批量更新、获取字段数和字段名称，用set和get提高其扩展性、对其他连库方法的支持等都没有出现在下面的代码中），使之包含所有常用的功能并使之更加清晰和易于理解；其二，我将连库动作加到了构造函数中，这是个优点也是个缺点，优点是简化了连库动作，缺点是降低了通用性，我没有添加设置数据源等方法，从而每当变换一次数据库就需要改写组件中的连接池名称，这在做一个固定项目的时候是可以的，如果你需要set数据源，可以自行添加； ##使用组件的方法： 我这里说的是使用bean的通用方法，你建立自己的bean目录可以仿照该例子。在你的站点根目录下建立resin.conf中指定的存放bean的目录，我上面的举例是classes，那你就建立classes目录，那么classes就是你站点的class根目录。然后在下面依次建立com\gledecity\yesgo\sql，注意它们之间是父子关系，不是同级文件夹，然后将下面即将建立的DBBridge.java放到"站点根目录\classes\com\gledecity\yesgo\sql"目录下，然后将该文件上传到服务器端即可。上面的步骤在微软平台上使用UltraDev之类的开发工具即可完成，当然手工也可以。 源文件如下： ／／------------------------------------------------------------------------------ ／／ File： DBBridge.java ／／ Copyright （c） 2001-2002 Mr.Fengjun Zhao. All Rights Reserved. ／／ Author： 赵凤君@06／18／01 ／／ Last Revision： 赵凤君@01／18／2002 ／／ Description： 数据库接口类。一个统一的数据库接口，实现了逻辑层和 数据层的彻底分离，封装了常用的数据库操作。主要功能是：连接数据库、执行SQL语句、数据库取值操作、数据分页、清除数据、关闭数据库等。 ／／ Version：简化版1.0 ／／------------------------------------------------------------------------------ ／／指定包目录 package com.gledecity.yesgo.sql; ／／导入包 import java.sql.* ; import com.caucho.sql.*; public class DBBridge { ／／声明属性 private DBPool pool ; private Connection conn ; private ResultSet rs ; private Statement stmt ; ／／ -------------------------------------- 构造函数--------------------------------- public DBBridge（） { pool=null ; conn=null ; rs=null ; stmt=null ; try{open（）;} catch（java.sql.SQLException ex）{ex.toString（）;} } ／／ ／／连接数据库的方法 public void open（） throws SQLException { if（ conn!=null && !conn.isClosed（） ） throw new SQLException（ "The connection has been established already." ） ; clear （） ; pool=new DBPool（）; conn = pool.getPool（"your_data_source_name"）.getConnection（）; } ／／执行SQL语句的方法，将JDBC中的executeQuary（）和executeUpdate（）两个方法／／合而为一，注意返回值为整形， public int execSQL（ String sqlStmt ） throws SQLException { if（ conn==null conn.isClosed（） ） throw new SQLException（ "This connection has not been established yet." ） ; if（ sqlStmt==null ） throw new SQLException（ "SQL-statement is null." ） ; clear （） ; conn.setAutoCommit（ true ） ; stmt=conn.createStatement（） ; if（ sqlStmt.toUpperCase（）.startsWith（ "SELECT" ） ） { rs=stmt.executeQuery（ sqlStmt ） ; return -1 ; } else { int numRow=stmt.executeUpdate（ sqlStmt ） ; clear（） ; return num
[1] [2] 下一页
（出处：http://www.sheup.com）
上一页 [1] [2]