connectionpool.java~10~

短信网关发送接受平台。

package data;

/**
 * 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(java.lang.ClassNotFoundException 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();
	      }


       }

}