dbconnection.java~4~

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

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;
  }

}