import java.rmi.*;
import java.rmi.server.*;
import java.sql.*;

public class cityWeatherReportServer extends UnicastRemoteObject implements cityWeatherReportInterface
  {
   /* 這是“城市天氣預(yù)報(bào)”的服務(wù)器程序，用于響應(yīng)客戶端的請求 */

   Connection con1 = null;    //定義數(shù)據(jù)庫連接對象
   Connection con2 = null;   
   Statement stmt1 = null;    //定義數(shù)據(jù)庫聲明對象
   Statement stmt2 = null;   
   ResultSet rset1 = null;    //定義記錄結(jié)果集對象
   ResultSet rset2 = null;   
   private String cityName = null;

   private cityWeatherReportServer() throws RemoteException
     {
      super();
     }

   public cityWeatherReportServer(String cityName) throws RemoteException
     {
      super();
      this.cityName = cityName;
     }

   public String getCityTemperature() throws RemoteException
     {
      /* 處理城市天氣溫度的查詢請求 */

      String ResponseStr = null;
      String sSQLCmd = null;
      int Recordset1 = 0;
      int Recordset2 = 0;
      String HighTemperature = null;
      String LowTemperature = null;

      if(cityName.equals("") || cityName == null || cityName.length() < 1)
        {
         ResponseStr = "error";
        }
      else
        {
         sSQLCmd = "SELECT HighTemperature, LowTemperature FROM CityWeather WHERE CityName = '"+ cityName +"'";
         
         try
           {
            /* 建立與后臺數(shù)據(jù)庫服務(wù)器的連接 */ 
            DriverManager.registerDriver(new sun.jdbc.odbc.JdbcOdbcDriver());
            con1 = DriverManager.getConnection("jdbc:odbc:DemoDB","demo","demo");
            stmt1 = con1.createStatement ();
            rset1 = stmt1.executeQuery (sSQLCmd);

            while(rset1.next())
              {
               Recordset1 = rset1.getInt(1); 
               Recordset2 = rset1.getInt(2);
               HighTemperature = Integer.toString(Recordset1);
               LowTemperature = Integer.toString(Recordset2);
               ResponseStr = "（最高氣溫）" + HighTemperature + "℃" + "  （最低氣溫）" + LowTemperature + "℃";
              }
            rset1.close();
            con1.close();
           }

         catch(SQLException e)
           {
            ResponseStr = "error";
            System.out.println("!服務(wù)器端數(shù)據(jù)庫連接出錯(cuò)：" + e.toString());
           }
        }

      return ResponseStr;
     }

   public String getWeatherForecast() throws RemoteException
     {
      /* 處理城市天氣情況的查詢請求 */

      String ResponseStr = null;
      String sSQLCmd = null;
      String Recordset1 = null;
      String WeatherInfo = null;

      if(cityName.equals("") || cityName == null || cityName.length() < 1)
        {
         ResponseStr = "error";
        }
      else
        {
         sSQLCmd = "SELECT WeatherInfo FROM CityWeather WHERE CityName = '"+ cityName +"'";
         
         try
           {
            /* 建立與后臺數(shù)據(jù)庫服務(wù)器的連接 */ 
            DriverManager.registerDriver(new sun.jdbc.odbc.JdbcOdbcDriver());
            con2 = DriverManager.getConnection("jdbc:odbc:DemoDB","demo","demo");
            stmt2 = con2.createStatement ();
            rset2 = stmt2.executeQuery (sSQLCmd);

            while(rset2.next())
              {
               Recordset1 = rset2.getString(1); 
               WeatherInfo = (Recordset1 == null) ? "不詳" : Recordset1;
               ResponseStr = WeatherInfo;
              }
            rset2.close();
            con2.close();
           }

         catch(SQLException e)
           {
            ResponseStr = "error";
            System.out.println("!服務(wù)器端數(shù)據(jù)庫連接出錯(cuò)：" + e.toString());
           }
        }

      return ResponseStr;

     }
  }