connectionpool.java~1~

彩信网关程序。只支持发送。

package mmscenter;
/**
 * Title:
 * Description:
 *      数据库连接池
 * Copyright:    Copyright (c) 2002
 * Company:
 * @author
 * @version 1.0
 */

import java.sql.*;
import java.lang.*;
import orderapp.Config;
public class ConnectionPool{
       public String DBDriver;
       public String ConnStr;
       public String Account;
       public String Password;
       Connection con;
       Statement stmt;
       ResultSet rs;
       public ConnectionPool(){
         DBDriver="org.gjt.mm.mysql.Driver";
         ConnStr="jdbc:mysql://"+Config.db_host+":3306/"+Config.db_name;
         Account=Config.db_user;
         Password=Config.db_password;
         con=null;
         rs=null;

        try{
      Class.forName(DBDriver);
      con=DriverManager.getConnection(ConnStr,Account,Password);
      stmt=con.createStatement();
        }
        catch(Exception e){
    System.err.println("mysql():"+e.getMessage());
    e.printStackTrace();
        }
       }
       public ResultSet executeQuery(String sql){
        rs=null;
        try{
    //con=DriverManager.getConnection(ConnStr,Account,Password);
    //stmt=con.createStatement();
    rs=stmt.executeQuery(sql);
        }
        catch(SQLException ex){
    //System.err.println("aq.executeQuery:"+ex.getMessage());
        }
        return rs;
       }
       public int executeUpdate(String sql){
        try{
    //con=DriverManager.getConnection(ConnStr,Account,Password);
    //Statement stmt=con.createStatement();
    int i=stmt.executeUpdate(sql);
    //stmt.close();
    //con.close();
    return i;

        }
        catch(Exception ee){
    ee.printStackTrace();
    return 999;
        }
       }
       public void release(){

        try{
    rs.close();
    stmt.close();
    con.close();
        }
        catch(Exception e){
    e.printStackTrace();
        }


       }

}