package trainticket.Dao;
import java.sql.*;
import trainticket.Bean.*;
/**
  數據庫訪問層
 */
public class CallDao
{
     DBCOnn dbConn;
       public CallDao()
     {
         dbConn=new DBCOnn();
        try {
            jbInit();
        } catch (Exception ex) {
            ex.printStackTrace();
        }

    }
      public boolean SelectTrainOrder(String trainNum)//檢查車次是否在數據庫中存在
      {   Connection conn=null;
            try {
            conn=this.dbConn.getConn();
            PreparedStatement ptrt = conn.prepareStatement(
                    "select TrainNo from TrainTicket where TrainNo=?");
            ptrt.setString(1,trainNum);
            ResultSet res=ptrt.executeQuery();
            if(res.next())
            {
                return true;
            }
        } catch (SQLException ex)
        {
            ex.printStackTrace();
        }  finally
      {
            try {
                dbConn.CloseConn(conn);
            } catch (SQLException ex1)
            {
                 ex1.printStackTrace();
            }
      }
            return false;
      }

      public String compareAmount(Info info)//檢測訂購數量
      {
          PreparedStatement ptrt=null;
          Connection conn=null;
          try {
              conn=this.dbConn.getConn();
              if(info.getPrice().equals("seatPrice"))//坐
              {

                    ptrt = conn.prepareStatement(
                    "select seatNum,seatPrice from TrainTicket where TrainNo=?");
              }
              else //床
              {
                  ptrt = conn.prepareStatement(
                    "select bedNum,bedPrice from TrainTicket where TrainNo=?");
              }
            ptrt.setString(1,info.getTrainNumber());//設置車次
            ResultSet res=ptrt.executeQuery();//執行
            while(res.next())
            {
                  if(res.getInt(1)<info.getNumber())//判斷數據庫的數量是否小于訂購的數量
                  {
                      return "Sorry,訂購失敗，車票數量不足";
                  }
                  else
                  {
                      return "車票訂購成功，請支付："+(new Float(info.getNumber()*res.getFloat(2)).toString())+"元";
                  }

            }
        } catch (SQLException ex)
        {
            ex.printStackTrace();
        }
        finally
      {
            try {
                dbConn.CloseConn(conn);
            } catch (SQLException ex1)
            {
                 ex1.printStackTrace();
            }
      }

            return "";

      }

    private void jbInit() throws Exception {
    }


}