www.pudn.com > network-java.rar > ConnDB.java

package netManager.util; 
 
/** 
 * 
 ConnDB
 
 * 
Description: 数据库连接及操作
 
 * 
Copyright: Copyright (c) 2005
 
 * 
Company: 
 
 * @author：谢飞 
 * @version 1.0 
 */ 
  
import java.sql.DriverManager; 
import java.sql.Connection; 
import java.sql.Statement; 
import java.sql.ResultSet; 
import netManager.framework.exception.BaseException; 
import org.apache.commons.logging.Log; 
import org.apache.commons.logging.LogFactory; 
 
 
public class ConnDB { 
	 
  public Connection con; 
  private Log log = LogFactory.getLog("ConnDB"); 
  BaseException be = new BaseException(); 
    
  public ConnDB() throws BaseException{ 
  	try { 
      	Class.forName("oracle.jdbc.driver.OracleDriver").newInstance(); 
     	//Class.forName("com.m.jdbc.sqlserver.SQLServerDriver"); 
      	//System.out.println("驱动程序注册成功!"); 
    } 
    catch (Exception e) { 
      	System.out.println("未找到驱动程序!"); 
      	log.error(e); 
      	be.setRootCause(e); 
      	be.setMessageKey("error.db.driver"); 
      	throw be; 
    } 
  } 
 
  public Connection getconn() throws BaseException{ 
    try { 
      //String url = "jdbc:microsoft:sqlserver://127.0.0.1"; 
      PropUtil prop = new PropUtil("prop.properties"); 
  	  String url = prop.getDbUrl(); 
      String username = prop.getDbUserName(); 
      String password = prop.getDbPassword();       
      //System.out.println("已连接到数据库!"); 
      return DriverManager.getConnection(url, username, password); 
    } 
    catch (Exception e) { 
      e.printStackTrace(); 
      log.error(e); 
      be.setRootCause(e); 
      be.setMessageKey("error.db.conn"); 
      throw be; 
    } 
    //return null; 
  } 
 
  public boolean execute(String sql, Connection con) { 
    try { 
      Statement s = con.createStatement(); 
      return s.execute(sql); 
    } 
    catch (Exception e) { 
      e.printStackTrace(); 
	} 
    return false; 
  } 
 
  
    public void close(ResultSet rs) { 
      try { 
        rs.close(); 
      } 
      catch (Exception ex) { 
        ex.printStackTrace(); 
      } 
    } 
 
    public void close(Statement stmt) { 
      try { 
        stmt.close(); 
      } 
      catch (Exception ex) { 
        ex.printStackTrace(); 
      } 
    } 
 
    public void close(Connection conn) { 
      try { 
        conn.close(); 
      } 
      catch (Exception ex) { 
        ex.printStackTrace(); 
      } 
    } 
     
  }