我写了个,觉得太复杂了……
package connection;
import java.sql.*;public class conn{
private Statement stmt=null;
ResultSet rs=null;
private Connection conn=null;//构造函数
public conn(){
}//根据参数,加载驱动程序,建立连接
public void OpenConn(String dsn,String uid,String pwd) throws Exception{
try{
dsn="jdbc:odbc:"+dsn;
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
conn=DriverManager.getConnection(dsn,uid,pwd);
}
catch(Exception ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
}//执行查询类的sql语句,有返回集
public ResultSet executeQuery(String sql){
rs=null;
try{
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rs=stmt.executeQuery(sql);
}
catch(SQLException ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
return rs;
}//执行更新类的sql语句,无返回集
public void executeUpdate(String sql){
stmt=null;
rs=null;
try{
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
stmt.executeQuery(sql);
stmt.close();
conn.close();
}
catch(SQLException ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
}//关闭对象
public void closeStmt(){
try{
stmt.close();
}
catch(SQLException ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
} public void closeConn(){
try{
conn.close();
}
catch(SQLException ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
}
}
package connection;
import java.sql.*;public class conn{
private Statement stmt=null;
ResultSet rs=null;
private Connection conn=null;//构造函数
public conn(){
}//根据参数,加载驱动程序,建立连接
public void OpenConn(String dsn,String uid,String pwd) throws Exception{
try{
dsn="jdbc:odbc:"+dsn;
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
conn=DriverManager.getConnection(dsn,uid,pwd);
}
catch(Exception ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
}//执行查询类的sql语句,有返回集
public ResultSet executeQuery(String sql){
rs=null;
try{
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rs=stmt.executeQuery(sql);
}
catch(SQLException ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
return rs;
}//执行更新类的sql语句,无返回集
public void executeUpdate(String sql){
stmt=null;
rs=null;
try{
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
stmt.executeQuery(sql);
stmt.close();
conn.close();
}
catch(SQLException ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
}//关闭对象
public void closeStmt(){
try{
stmt.close();
}
catch(SQLException ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
} public void closeConn(){
try{
conn.close();
}
catch(SQLException ex){
System.err.println("aq.executeQuery:"+ex.getMessage());
}
}
}
import java.util.*;
import java.io.*;public class CardBean{
private Connection con;
public CardBean(){
String CLASSFORNAME="com.microsoft.jdbc.sqlserver.SQLServerDriver";
String SERVANDDB="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=test";
String USER="xy";
String PWD="123456"; try{
Class.forName(CLASSFORNAME);
con=java.sql.DriverManager.getConnection(SERVANDDB,USER,PWD);
}catch(Exception e){
e.printStackTrace();
}
} public void addCardBean(String xm1,String xb1,String dwmc1,String dhhm1,String sjhm1,String czhm1,String syh1,String sf1,String csr1,String sfgy1,String hangye1,String mpfl1,String yzbm1,String email1,String txdz1,String bz1,String mpzfl1){
try{
PreparedStatement pstmt=con.prepareStatement("insert into xy.pcard values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
pstmt.setString(1,xm1);
pstmt.setString(2,xb1);
pstmt.setString(3,dwmc1);
pstmt.setString(4,dhhm1);
pstmt.setString(5,sjhm1);
pstmt.setString(6,czhm1);
pstmt.setString(7,syh1);
pstmt.setString(8,sf1);
pstmt.setString(9,csr1);
pstmt.setString(10,sfgy1);
pstmt.setString(11,hangye1);
pstmt.setString(12,mpfl1);
pstmt.setString(13,yzbm1);
pstmt.setString(14,email1);
pstmt.setString(15,txdz1);
pstmt.setString(16,bz1);
pstmt.setString(17,mpzfl1);
pstmt.execute();
}catch(Exception e){
}
} public ResultSet getCardBean(String id){
ResultSet result=null;
try{
Statement stm=con.createStatement();
result=stm.executeQuery("select * from xy.pcard where ID='"+id+"'");
return result;
}catch(Exception e){
}
return result;
} public ResultSet getCardBean(){
ResultSet result=null;
try{
Statement stm=con.createStatement();
result=stm.executeQuery("select * from xy.pcard");
return result;
}catch(Exception e){
}
return result;
} public void delCardBean(){
try{
PreparedStatement pstmt=con.prepareStatement("delete from xy.pcard");
pstmt.execute();
}catch(Exception e){
}
} public void delCardBean(String id){
try{
PreparedStatement pstmt=con.prepareStatement("delete from xy.pcard where ID='"+id+"'");
pstmt.execute();
}catch(Exception e){
}
}
public ResultSet queryCardBean(String str){
ResultSet result=null;
String sql="select * from xy.pcard where "+str;
System.out.println(sql);
try{
Statement stm=con.createStatement();
result=stm.executeQuery(sql);
return result;
}catch(SQLException e){
System.out.println("not found card");
}
return result;
}
}