欢迎来到天天文库
浏览记录
ID:40557284
大小:69.50 KB
页数:13页
时间:2019-08-04
《Java连接SQLServer》由会员上传分享,免费在线阅读,更多相关内容在教育资源-天天文库。
1、我们在做jsp开发的时候,经常需要对数据库进行查询及增删改,而这些操作使用的又是非常频繁,因此,我写了一个javabean,来实现与数据库的连接以及对数据库的增删改。现在拿出来与大家共享,希望大家尊重作者的劳动,使用时保留作者信息以及版本信息等等,谢谢!QueryBean.java:pacakageoperate_db;/** *Title: selectinsertupdateanddelete *Description: selectinsertupdateanddelete *C
2、opyright: Copyright(c)2001 *@author Lci21 *@version1.0 */importjava.sql.*;publicclassQueryBean{ publicStringquery_statement; /*定义sql语句*/ publicStringparam[]; /*查询条件,或者是新的记录*/ publicResultSetresult=null; publicConnectionconn;
3、 publicvoidsetParam(String[]param) { this.param=param; } publicvoidsetQuerystatement(Stringquery_statement) { this.query_statement=query_statement; } publicvoidsetConnection(StringdriverName,StringjdbcURL,Stringusername,Stringpas
4、swd)throwsException { Connectionconn1; Class.forName(driverName); conn1=DriverManager.getConnection(jdbcURL,username,passwd); conn1.setAutoCommit(false); this.conn=conn1; } /*获取查询结果*/ publicResultSetgetResult()
5、{ try { PreparedStatementselect_stm=conn.prepareStatement(query_statement,java.sql.ResultSet.TYPE_SCROLL_INSENSITIVE,java.sql.ResultSet.CONCUR_READ_ONLY); if(param!=null) for(inti=0;i6、 select_stm.setString(i+1,param[i]); result=select_stm.executeQuery(); }catch(Exceptione){System.out.println(e);} returnresult; } /*对数据库进行增加记录操作*/ publicvoidinse7、rtRecord()throwsSQLException,java.io.UnsupportedEncodingException { try { PreparedStatementinsert_stm=conn.prepareStatement(query_statement); if(param!=null) for(inti=0;i8、 insert_stm.setString(i+1,param[i]); insert_stm.executeUpdate(); insert_stm.close(); conn.commit(); } catch(Exceptione) { System.out.println(e); conn.rollback()
6、 select_stm.setString(i+1,param[i]); result=select_stm.executeQuery(); }catch(Exceptione){System.out.println(e);} returnresult; } /*对数据库进行增加记录操作*/ publicvoidinse
7、rtRecord()throwsSQLException,java.io.UnsupportedEncodingException { try { PreparedStatementinsert_stm=conn.prepareStatement(query_statement); if(param!=null) for(inti=0;i8、 insert_stm.setString(i+1,param[i]); insert_stm.executeUpdate(); insert_stm.close(); conn.commit(); } catch(Exceptione) { System.out.println(e); conn.rollback()
8、 insert_stm.setString(i+1,param[i]); insert_stm.executeUpdate(); insert_stm.close(); conn.commit(); } catch(Exceptione) { System.out.println(e); conn.rollback()
此文档下载收益归作者所有