package mmscenter;/** * <p>Title: 旅游氣象站</p> * <p>Description: </p> * <p>Copyright: Copyright (c) 2003</p> * <p>Company: 華風</p> * @author 劉聰 * @version 1.0 */import java.sql.*;import java.util.*;import java.lang.*;public class DBConnection{    String sql="";    protected java.lang.String password= "travel";    protected java.lang.String driver= "org.gjt.mm.mysql.Driver";    protected java.lang.String Url= "";//"jdbc:odbc:travel";    protected java.lang.String userID= "travel";    //protected java.lang.String password= "weathercn";    //protected java.lang.String Url= "jdbc:oracle:thin:@127.0.0.1:1521:weather";    //protected java.lang.String userID= "weathercn";    Connection connection=null;    Statement statement=null;    public DBConnection(String db_name){      this.Url = "jdbc:mysql://"+Config.db_host+":3306/"+Config.db_name;    }        public void Close(){         try          {                  closeStatement();                  if(!connection.isClosed())                  {                           connection.close();                  }          }          catch(Throwable e){System.out.println(e);}          connection = null;        }        private void closeStatement()  {          try          {                  if(statement != null)                          statement.close();          }          catch(Throwable e)          {                  System.out.println("exception in closeStmt " + e);          }          statement=null;  }  public Connection getConnection() throws SQLException{          if(connection != null && !connection.isClosed())          {                  return connection;          }          try{      Class.forName(driver);      //DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());      connection = DriverManager.getConnection (Url, userID, password);          }          catch(Exception e)          {                  System.out.println("exception in getConnection " + e.getMessage());          }    return connection ;  }   public Statement getStatement() throws SQLException{          try          {                  statement = getConnection().createStatement();                  statement.setMaxFieldSize(16000);                  statement.setMaxRows(1000);          }          catch(SQLException e)          {                  System.out.println("exception in getStmt " + e);                  throw e;          };          return statement;  }   public Object execute(String sql)  {           System.out.println("execute");          java.sql.ResultSet rs = null;          java.util.Vector vResult = null;             try          {                  if(!isSelect(sql))                  {                            try            {                return new Integer(getStatement().executeUpdate(sql));                        }                        catch(SQLException e1)                        {                                System.out.println(e1);                                return new Integer(-1 * e1.getErrorCode());                        }          }                  else                  {                         rs = getStatement().executeQuery(sql);                          int columnCount = rs.getMetaData().getColumnCount();                          vResult = new Vector();              while(rs.next())              {                java.util.Vector vTemp = new Vector();                for(int i = 0;i< columnCount;i++)                {                  try {                    String data = rs.getString(i + 1);  //去掉Encode的轉換                    if (data == null)                      vTemp.addElement("");                    else                      vTemp.addElement(data);                    }                    catch (Exception e) {                      System.out.println(e.getMessage());                    }                }              vResult.addElement(vTemp);           }          rs.close();                  }     closeStatement();          }          catch(Throwable e1)          {                }          return vResult;  }  public Integer executeUpdate(String sql)  {          return (Integer)execute(sql);  }  protected boolean isSelect(String psql) {          String sql = psql.trim().toUpperCase();          if(sql.indexOf("SELECT ") <0) return false; // 將==0，改為<0,因如果select在SQL語句的開頭則sql.indexOf("SELECT ")==0，而不是1;修改日期：2001-6-2          return true;  }  public Vector executesql(String sql,int iPage,int iRows)  {    java.sql.ResultSet rs = null;    java.util.Vector vResult=new Vector();    try    {        rs = getStatement().executeQuery(sql);                int columnCount = rs.getMetaData().getColumnCount();                vResult = new Vector();             for(int j=0;rs.next();j++)                   {          if((j >= iPage * iRows) && (j<= ((iPage+1) * iRows - 1)))          {                          java.util.Vector vTemp = new Vector();                          for(int i = 0;i< columnCount;i++)                    {               try               {                  String data = rs.getString(i + 1);                  if (data == null)                    vTemp.addElement("");                  else                    vTemp.addElement(data);               }               catch (Exception e) {                  System.out.println(e.getMessage());              }            }            vResult.addElement(vTemp);          }          else if (j >= ((iPage+1) * iRows - 1))                   break;          else                  continue;        }                rs.close();        statement.close();    }    catch(Throwable e1)        {        }        return vResult;  }}