利用javabean实现对数据库的连接

xiaoxiao2026-05-24  11

       我们在做jsp开发的时候,经常需要对数据库进行查询及增删改,而这些操作使用的又是非常频繁,因此,我写了一个javabean,来实现与数据库的连接以及对数据库的增删改。现在拿出来与大家共享,希望大家尊重作者的劳动,使用时保留作者信息以及版本信息等等,谢谢! 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_INSENSITIVE,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();             }         }     } 来源:http://www.daima.com.cn/Info/55/Info15729/

相关资源:使用JavaBean连接数据库
转载请注明原文地址: https://www.6miu.com/read-5049294.html

最新回复(0)