dbconndb.java

这个是我们做土地局的一个项目。感觉不错。欢迎下载

package huayi.xt;

import java.sql.*;
import java.io.*;
import java.util.*;
import javax.naming.*;

/**
* 从连接池中取得一个空闲的数据库连接
* @return Connection
* @exception Exception
*/
public class dbConndb{
Connection conn = null; 
CallableStatement stmtpro = null;
Statement stmt=null;
ResultSet rs = null;
public dbConndb(){
try {
   Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
   conn=DriverManager.getConnection("jdbc:microsoft:sqlserver://202.118.120.197:1433;databaseName=HuaYi;user=center;password=6651002");
} catch(java.lang.SecurityException se) {
throw se;
} catch(java.lang.Exception e) {
e.printStackTrace();
}
}
//数据处理
public ResultSet executeQuery(String sql){
stmt=null;
rs = null;
try {        
     stmt=conn.createStatement();                                                 
     rs=stmt.executeQuery(sql);
     } catch(SQLException ex){
       System.err.println("sql_data.executeUpdate:"+ex.getMessage());
     //显示数据库连接错误或者查询错误 
                             }   
     return rs;                          
    }
//数据更新
public int executeUpdate(String sql){
stmt=null;	
int number = 0;
try {
       stmt=conn.createStatement();    
       stmt.executeUpdate(sql);
       if (conn==null) { return -1; }
       if (stmt == null) { return -1; }
        } catch(SQLException ex){
       System.err.println("sql_data.executeUpdate:"+ex.getMessage());
       return -1;
        }
       return number;
    }
//存储过程调用,返回编号
public String executeProcedure(String BHMC){
stmtpro = null;
String BH=null;
String sql=null;
sql="{ call P_NB_BH(?,?)}";
try {    
     stmtpro=conn.prepareCall(sql);                                                 
     stmtpro.setString(1,BHMC);
     stmtpro.registerOutParameter(2,Types.CHAR);
     stmtpro.executeUpdate();
     BH = stmtpro.getString(2);
     } catch(SQLException ex){
       System.err.println("sql_data.executeUpdate:"+ex.getMessage());
     //显示数据库连接错误或者查询错误 
                             }   
     return BH;
}
//存储过程调用,返回未审批的公文信息
public  boolean executeGWSP(String YGBH){
stmtpro = null;
String sql=null;
sql="{ call P_NB_GW(?)}";
try {    
     stmtpro=conn.prepareCall(sql);                                                 
     stmtpro.setString(1,YGBH);
     stmtpro.executeUpdate();
     } catch(SQLException ex){
       System.err.println("sql_data.executeUpdate:"+ex.getMessage());
     //显示数据库连接错误或者查询错误 
       return false;
                             }   
     return true;
}
//存储过程调用,返回标志位
public int executeGWLZ(String GWBH){
stmtpro = null;
int BH=0;
String sql=null;
sql="{ call P_NB_LZ(?,?)}";
try {    
     stmtpro=conn.prepareCall(sql);                                                 
     stmtpro.setString(1,GWBH);
     stmtpro.registerOutParameter(2,Types.INTEGER);
     stmtpro.executeUpdate();
     BH = stmtpro.getShort(2);
     } catch(SQLException ex){
       System.err.println("sql_data.executeUpdate:"+ex.getMessage());
     //显示数据库连接错误或者查询错误 
                             }   
     return BH;
}

//关闭数据源，断开连接
public boolean close(){
try{
if(this.rs!=null){
this.rs.close();
} 
if(stmt!=null){
this.stmt.close();
}
if(stmtpro!=null){
this.stmtpro.close();
}
if(conn!=null){
this.conn.close();
}
return true;
}catch(Exception err){
return false;
}
}
    
}