dbisopen.java~16~

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

package mmscenter;
import java.sql.*;
import java.util.*;
import java.lang.*;
public class DbIsOpen extends Engine{
    protected Connection connection=null;
    protected Statement statement=null;
    protected java.lang.String password= "";
    protected java.lang.String driver= "org.gjt.mm.mysql.Driver";
    protected java.lang.String Url= "jdbc:mysql://"+Config.db_host+":3306/"+Config.db_name;//"jdbc:odbc:travel";
    protected java.lang.String userID= "mms";
    protected boolean dbIsOpen = false;
  public DbIsOpen() {
    super("DbIsOpen");
    setDaemon(true);
  }
  public void Close(){
        try
         {
                 //closeStatement();
                 if(!connection.isClosed())
                 {
                          connection.close();
                 }
         }
         catch(Throwable e){System.out.println(e);}
         connection = null;
         //dbIsOpen = false;
        }
  public Connection getConnection() throws SQLException{
         if(connection != null && !connection.isClosed())
         {
           dbIsOpen = true;
                 return connection;
         }
         try{
     Class.forName(driver);
     //DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
     connection = DriverManager.getConnection (Url, userID, password);
     dbIsOpen = true;
         }
         catch(Exception e)
         {
           dbIsOpen = false;
                 System.out.println("exception in getConnection " + e.getMessage());
         }
   return connection ;
  }
  public void run(){
    while(true){
      try{
        getConnection();
      }catch(Exception e){
        e.printStackTrace() ;
      }
      try{
        Close();
      }catch(Exception e){
        e.printStackTrace() ;
      }
      try{
        System.out.println("数据库连接"+dbIsOpen);
        //sleep(TimeConfig.TIME_ONE_MINUTE);
      }catch(Exception e){

      }
    }
  }
  public static void main(String[] args) {
    DbIsOpen dbIsOpen1 = new DbIsOpen();
    dbIsOpen1.run();
    try{
      Thread.sleep(1000);
      }catch(Exception e){
        e.printStackTrace() ;
      }
  }
}