|
1.调用实例 <%@ page contenttype="text/html" import="operate_db.*,java.sql.*"%> <jsp:usebean id="querybean" scope="request" class="operate_db.querybean" /> <% string prm1,prm2,prm3; resultset rst=null; prm1 = ...; prm2 = ...; prm3 = ...; querybean.setconnection("sun.jdbc.odbc.jdbcodbcdriver","jdbc:odbc:数据源名","sa",""); try{ string[] param = {prm1,prm2,prm3}; /*设置select语句*/ querybean.setquerystatement("select * from table where field1 = ? and field2=? and field3=?"); querybean.setparam(param); rst=querybean.getresult(); }catch(exception e){system.out.println(e); } while (rst.next()){ %><%=rst.getstring(1)%> <%}%> 2.javabean querybean querybean.java: pacakage operate_db; /** * title: select insert update and delete * description: select insert update and delete * copyright: copyright (c) 2001 * @author lci21 * @version 1.0 */ import java.sql.*; public class querybean { public string query_statement; /*定义sql语句*/ public string param[]; /*查询条件,或者是新的记录*/ public resultset result=null; public connection conn; public void setparam(string[] param) { this.param=param; } public void setquerystatement(string query_statement) { this.query_statement=query_statement; } public void setconnection(string drivername,string jdbcurl,string username,string passwd) throws exception { connection conn1; class.forname(drivername); conn1=drivermanager.getconnection(jdbcurl,username,passwd); conn1.setautocommit(false); this.conn = conn1; } /*获取查询结果*/ public resultset getresult() { try { preparedstatement select_stm=conn.preparestatement(query_statement,java.sql.resultset.type_scroll_insens99vive,java.sql.resultset.concur_read_only); if (param!=null) for(int i=0;i<param.length;i++) select_stm.setstring(i+1,param[i]); result=select_stm.executequery(); }catch(exception e){system.out.println(e);} return result; } /*对数据库进行增加记录操作*/ public void insertrecord() throws sqlexception,java.io.unsupportedencodingexception { try { preparedstatement insert_stm=conn.preparestatement(query_statement); if (param!=null) for(int i=0;i<param.length;i++) insert_stm.setstring(i+1,param[i]); insert_stm.executeupdate(); insert_stm.close(); conn.commit(); } catch(exception e) { system.out.println(e); conn.rollback(); } } /*对数据记录进行更改操作*/ public void updaterecord() throws sqlexception,java.io.unsupportedencodingexception { try { preparedstatement update_stm=conn.preparestatement(query_statement); if (param!=null) for (int i=0;i<param.length;i++) update_stm.setstring(i+1,param[i]); update_stm.executeupdate(); update_stm.close(); conn.commit(); } catch(exception e) { system.out.println(e); conn.rollback(); } } /*删除数据记录*/ public void deleterecord() throws sqlexception,java.io.unsupportedencodingexception { try { preparedstatement delete_stm=conn.preparestatement(query_statement); if (param!=null) for (int i=0;i<param.length;i++) delete_stm.setstring(i+1,param[i]); delete_stm.executeupdate(); delete_stm.close(); conn.commit(); } catch(exception e) { system.out.println(e); conn.rollback(); } } } 希望大家尊重作者的劳动,使用时保留作者信息以及版本信息等等,谢谢! 如果以后不是很忙的话,我会逐步写一些文章,把自己的一些开发经验与大家分享。 初步的文章标题: **轻松建立并管理数据库连接池! **利用javabean轻松实现页面导航及数据分页显示! **利用最终类的静态方法轻松实现对中文乱码的处理! **利用javabean轻松实现服务器端对数据类型的检测! **利用javabean轻松实现对服务器端日期格式的检测与处理! ...... ...... ...... 希望大家尊重作者的劳动,使用时保留作者信息以及版本信息等等,谢谢!
|