Java Web项目开发案例精粹18-航空订票系统

package com.dao; import java.sql.Connection; import java.sql.Date; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.Calendar; public class DinDao { // inset 插入用户所选择航班的信息 public int inset(Connection connection,Sched sch, int dal,String id) { int value=-1; int var=-1; int i=0; PreparedStatement statement=null; PreparedStatement stat=null; PreparedStatement state=null; //查询数据库中是否有该航班记录 String sql2="select Hao,Piao from din where Hao=? and id=?"; // 插入用户所选择航班的信息 String sql="insert into din(Id,Hao,Qifei,Mudi,Rqi,Jiage,Piao) value(?,?,?,?,?,?,?)"; // 根据用户名和航班号修改票数 String sql3="update din set Piao=? where Hao=? and id=?"; ResultSet result=null; try { // 进行数据库查询 stat=connection.prepareStatement(sql2); stat.setString(1,sch.getHao()); stat.setString(2,id); result=stat.executeQuery(); //判断是否有该航班号的记录 while(result.next()) { // 判断是否有该航班记录,如果有,var=1; var=1; i=result.getInt("Piao"); } if(var==-1) { // 如果var=-1则表示没有改航班的记录,则将用户所订航班信息插入数据库中 statement=connection.prepareStatement(sql); statement.setString(1,id); statement.setString(2,sch.getHao()); statement.setString(3,sch.getQifei()); statement.setString(4,sch.getMudi()); statement.setString(5,sch.getRqi()); statement.setInt(6,sch.getJiage()); statement.setInt(7,dal); value=statement.executeUpdate(); return value; } if(var==1) { //如果var=1则表示有改航班记录,得到记录中的票数+当此用户所订票数 // 进行数据库的修改 int j=i+dal; state=connection.prepareStatement(sql3); state.setInt(1,j); state.setString(2,sch.getHao()); state.setString(3,id); value=state.executeUpdate(); return value; } } catch (SQLException e) { } finally { try { if(statement!=null)statement.close(); } catch (SQLException ee) { } } return value; } // 修改管理员所制定改航班的票数 public int update(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; } //check 获得航班号 进行查询航班号信息 public Sched check(Connection connection,String str) { Sched sch=new Sched(); String sql="select Hao,Rqi, Qifei,Mudi,Jiage,Piaosu from sch where Hao=? "; PreparedStatement statement=null; ResultSet resultset=null; try { statement=connection.prepareStatement(sql); statement.setString(1,str); 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("Piaosu")); } return sch; } catch(SQLException e) { } finally { try { if(statement!=null) statement.close(); if(resultset!=null) resultset.close(); } catch(SQLException ee) { } } return sch; } // quest 根据用户名来获得该用户所订购的所有航班 public ArrayList quest(Connection connection, String id) { ArrayList ary=new ArrayList(); // 查询用户订票信息 String sql="select * from din where Id=?"; PreparedStatement statement=null; ResultSet resultset=null; try { statement=connection.prepareStatement(sql); statement.setString(1,id); resultset=statement.executeQuery(); while(resultset.next()) { Sched sch=new Sched(); sch.setHao(resultset.getString("Hao")); sch.setQifei(resultset.getString("Qifei")); sch.setMudi(resultset.getString("Mudi")); sch.setRqi(resultset.getString("Rqi")); sch.setJiage(resultset.getInt("Jiage")); sch.setPiaosu(resultset.getInt("Piao")); //如果所订航班票数等于0 那么则不将该航班信息放入ArrayList动态数组中 //在JSP页面中省略了票数为0的航班 if(resultset.getInt("Piao")!=0) { ary.add(sch); } } return ary; } catch(SQLException e)