dindao.java

基于JSP的航空机票订票系统

                }
                catch(SQLException ee)
                {
                    
                }
            }
            return ary;
        }

     
//examine 查询所用航班的航班号
    public ArrayList examine(Connection connection)
    {
            String sql="select Hao from sch";
            ArrayList tes=new ArrayList();
            Statement statement=null;
            ResultSet result=null;
            try
            {
                statement=connection.createStatement();
                result=statement.executeQuery(sql);
                if(result.next())
                {
                   Anpai anpai=new Anpai();
                   anpai.setHao(result.getString("Hao"));
                   tes.add(anpai);
                }
                return tes;
            }
            catch(SQLException e)
            {
                
            }
            finally
		{
			try
			{
				if(statement!=null)statement.close();
			}
			catch (SQLException ee)
			{
			}
		}
            return tes;
    }
    // reced 获得用户所要退票的航班信息
    public Sched reced(Connection connection,String hao,String id)
    {
            Sched sch=new Sched();
            String sql="select Hao,Rqi, Qifei,Mudi,Jiage,Piao from din where Hao=?  and id=?";
            PreparedStatement statement=null;
            ResultSet resultset=null;
             try
            {
                    statement=connection.prepareStatement(sql);
                    statement.setString(1,hao);
                    statement.setString(2,id);
                    resultset=statement.executeQuery();
                    while(resultset.next())
                    {  
                        sch.setHao(resultset.getString("Hao"));
                        sch.setRqi(resultset.getString("Rqi"));   
                        sch.setQifei(resultset.getString("Qifei"));
                        sch.setMudi(resultset.getString("Mudi"));
                        sch.setJiage(resultset.getInt("Jiage"));  
                        sch.setPiaosu(resultset.getInt("Piao"));
                    }
                    return sch;
             }
             catch(SQLException e)
             {
                 
             }
            finally
            {
                try
                {
                    if(statement!=null) statement.close();
                    if(resultset!=null) resultset.close();
                }
                catch(SQLException ee)
                {
                    
                }
            }
            return sch;     
    }
    // amendReced 获得用户的id 和所选择的航班号 修改用户所要退的票数
    public int amendReced(Connection connection,Sched sch,int rec , String id)
    {
        int value=-1;
        PreparedStatement statement=null;
        String sql="update din set Piao=? where Hao=? and id=?";
        
        int i=0,j=0;
        
        try
        {
            // 将用户原来的所订购的票数放入i中
            i=sch.getPiaosu();
            // 用i减去用户所要退的票数 得到的结果放入j中
            j=i-rec;
            statement=connection.prepareStatement(sql);
            statement.setInt(1,j);
            statement.setString(2,sch.getHao());
            statement.setString(3,id);      
            value=statement.executeUpdate();
           return value;
        }
        catch(SQLException e)
        {
        }
        finally
        {
          try
         {
                   
               if(statement!=null) statement.close();
          } 
         catch(SQLException e)
         {
                    
         }  
        }
            return value;
      }
    // Upreced 用户退票后 修改该航班的总票数
    public int Upreced(Connection connection ,Sched sch,int dal)
    {
        int wat=-1;
            int i=0;
            int j=0;
            PreparedStatement statement=null;
            PreparedStatement state=null;
            //  先查询用户所要退票的该航班的票数
            String sql="select Piaosu from sch where Hao=?";
            // 修改该航班的票数
            String sql2="update sch set Piaosu=? where Hao=?";
            ResultSet resultset=null;
            try
            {
                statement=connection.prepareStatement(sql);
                statement.setString(1,sch.getHao());
                resultset=statement.executeQuery();
                if(resultset.next())
                {
                    // 获得用户退票前该航班的票数
                    i=resultset.getInt("Piaosu"); 
                }
                // 航班的票数加上用户所退的票数 得到退票后该航班的票数
               j=i+dal;
              
               state=connection.prepareStatement(sql2);
               
               state.setInt(1,j);
               state.setString(2,sch.getHao());
               wat=state.executeUpdate();
               return wat;              
            }
          
            catch(SQLException e)
            {
            }
            finally
            {
                try
                {
                    if(resultset!=null) resultset.close();
                    if(statement!=null) statement.close();
                }
                catch(SQLException e)
                {
                    
                }  
            }
            return wat;
    }
    //获得客户端当前日期时间
    public Date getDate(Connection connection)
    {
        Statement statement=null;
         Date date=null;
         ResultSet result=null;
         // 获取数据库当前日期时间 
        String sql="select current_date() as newdate";
        try
        {
           statement=connection.createStatement();
            result=statement.executeQuery(sql);
            while(result.next())
            {
               date=result.getDate("newdate");
               return date;
            }
        }
         catch(SQLException e)
            {
            }
            finally
            {
                try
                {
                    if(result!=null) result.close();
                    if(statement!=null) statement.close();
                }
                catch(SQLException e)
                {
                    
                }  
            }
            return date;
    }
    // compareDate比较所服务器日期是否在所订购的航班日期前一天
    public boolean compareDate(String str)
    {
        // 获得服务器日期
         Calendar day=Calendar.getInstance();
	 Date date=Date.valueOf(day.get(Calendar.YEAR)+"-"+(day.get(Calendar.MONTH)+1)+"-"+(day.get(Calendar.DATE)));
	 Date rqi=Date.valueOf(str);
         // 判断航班日期是否在服务器日期之后
         boolean i=rqi.after(date);
         return i;
         
    }
    
}