querypassengermodel.java

eclipse java/jsp 航空管理系统

/*
 * @(#)AddPassenger.java 1.0 2005/04/19 
 * <p>copyright:    Copyright 东软 国际合作事业部版权所有</p>
 * <p>company:      neusoft</p>
 * <p>time:         2005.04.19</p>
 */
package jiasir.model;

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import javax.naming.NamingException;
import javax.servlet.jsp.jstl.sql.Result;
import javax.sql.DataSource;
import jiasir.ConnDataBaseBean;
import jiasir.SQLCommandBean;
import jiasir.form.Passenger;
import org.apache.log4j.Logger;

import zhangchunliang.model.AppMode;

/**
 * 处理在删除页面查询违禁品信息的Model
 * @author    王嘉   
 * @version   1.0， 2005/04/24 
 */
public class QueryPassengerModel {
    /** 用户操作日志记录器 */
    static Logger userOperation = Logger.getLogger("userOperation");
    
    /** 用户异常日志记录器 */
    static Logger userError = Logger.getLogger("userError");

    //Temporary Note
    /** 系统调试日志记录器 */
    static Logger systemDebug = Logger.getLogger(QueryPassengerModel.class);
    /**
     *飞机票号
     */
    public String flightTicket;
    /**
     *旅客姓名
     */
    public String passengerName;
    /**
     *旅客证件种类
     */
    public String passengerIdKind;
    /**
     *证件号码
     */
    public String passengerId;
    /**
     *旅客国籍
     */
    public String passengerNat;
    /**
     *违禁品号
     */
    public String thingsNum;
    /**
     *违禁品名
     */
    public String things;
    /**
     *违禁品数量
     */
    public String thingsQuantity;
    /**
     *对违禁品的操作
     */
    public String hold;
    /**
     *出境或入境，c为出，i为入
     */
    public String cori;
    /**
     *航班号
     */
    public String flightNo;
    /**
     *航班起飞时间
     */
    public String flightDate;
    /**
     *执行插入的日期
     */
    public String insertDate;
    /**
     *执行插入的用户Id
     */
    public String insertUserId;
    /**
     *执行修改的日期
     */
    public String updateDate;
    /**
     *执行修改的用户Id
     */
    public String updateUserId;
    /**
     * 查询数据库的方式
     */
    public int queryType;
    /**
     * 查询数据库所需的信息
     */
    public String queryInfo;
    
    /**
     * QueryPassengerModel类的默认(无参)构造方法
     */
    public QueryPassengerModel(){
    }
    
    /**
     * 执行添加组的SQL操作方法
     * @return passenger       违禁品信息
     * @throws Exception       没有配置MySQL数据库驱动
     * @throws SQLException    SQL语句错误
     */
    public Passenger[] executeSQL() throws NamingException, SQLException {
    	
    	AppMode.registerUser();
                
        /** SQL语句字符串缓冲 */
        StringBuffer sqlStrBuffer;
        
        /** SQL语句字符串 */
        String sqlStr;
        
        /** Values实例化 */
        List values = new ArrayList();
        
        /** ConnDataBaseBean实例化 */
        ConnDataBaseBean connDataBaseBean = new ConnDataBaseBean();
        
        /** 从连接池中取得一个连接 */
        DataSource dataSource = connDataBaseBean.getDataSource();
        
        /** SQLCommandBean实例化 */
        SQLCommandBean sqlCommandBean = new SQLCommandBean();
        
        /** 设置Connection */
        sqlCommandBean.setConnection(dataSource.getConnection());
        
        /** SQL语句操作的结果集 */
        Result rs;
  
        /** SQL语句字符串缓冲实例化 */
        sqlStrBuffer = new StringBuffer(200);

        /**当用户选择“按飞机票查询”时执行*/
        if (queryType==1){            
            sqlStrBuffer.append("SELECT flightTicket,passengerName,");
            sqlStrBuffer.append("passengerIdKind,passengerId,passengerNat," +
                    "thingsNum,");
            sqlStrBuffer.append("things,thingsQuantity,hold,cori,flightNo," +
                    "flightDate ");
            sqlStrBuffer.append("FROM passenger ");
            sqlStrBuffer.append("WHERE flightTicket=?");
            /** 设置Values */
            values.add(queryInfo);
            sqlCommandBean.setValues(values);
        }
        /**当用户选择“按航班号查询”时执行*/
        else if(queryType==2){
            sqlStrBuffer.append("SELECT flightTicket,passengerName,");
            sqlStrBuffer.append("passengerIdKind,passengerId,passengerNat," +
                    "thingsNum,");
            sqlStrBuffer.append("things,thingsQuantity,hold,cori,flightNo," +
                    "flightDate ");
            sqlStrBuffer.append("FROM passenger ");
            sqlStrBuffer.append("WHERE flightNo=?");
            /** 设置Values */
            values.add(queryInfo);
            sqlCommandBean.setValues(values);
        }
        /**当用户选择“按旅客姓名查询”时执行*/
        else if(queryType==3){
            sqlStrBuffer.append("SELECT flightTicket,passengerName,");
            sqlStrBuffer.append("passengerIdKind,passengerId,passengerNat," +
                    "thingsNum,");
            sqlStrBuffer.append("things,thingsQuantity,hold,cori,flightNo," +
                    "flightDate ");
            sqlStrBuffer.append("FROM passenger ");
            sqlStrBuffer.append("WHERE passengerName=?");
            /** 设置Values */
            values.add(queryInfo);
            sqlCommandBean.setValues(values);
        }
        /**当用户选择“按证件号查询”时执行*/
        else if(queryType==4){
            sqlStrBuffer.append("SELECT flightTicket,passengerName,");
            sqlStrBuffer.append("passengerIdKind,passengerId,passengerNat," +
                    "thingsNum,");
            sqlStrBuffer.append("things,thingsQuantity,hold,cori,flightNo," +
                    "flightDate ");
            sqlStrBuffer.append("FROM passenger ");
            sqlStrBuffer.append("WHERE passengerId=?");
            values.add(queryInfo);
            sqlCommandBean.setValues(values);
        }
        /**当用户选择“按违禁品名查询”时执行*/
        else if(queryType==5){
            sqlStrBuffer.append("SELECT flightTicket,passengerName,");
            sqlStrBuffer.append("passengerIdKind,passengerId,passengerNat," +
                    "thingsNum,");
            sqlStrBuffer.append("things,thingsQuantity,hold,cori,flightNo," +
                    "flightDate ");
            sqlStrBuffer.append("FROM passenger ");
            sqlStrBuffer.append("WHERE things=?");
            values.add(queryInfo);
            sqlCommandBean.setValues(values);
        }
        /**当用户选择“按违禁品号查询”时执行*/
        else if(queryType==6){
            sqlStrBuffer.append("SELECT flightTicket,passengerName,");
            sqlStrBuffer.append("passengerIdKind,passengerId,passengerNat," +
                    "thingsNum,");
            sqlStrBuffer.append("things,thingsQuantity,hold,cori,flightNo," +
                    "flightDate ");
            sqlStrBuffer.append("FROM passenger ");
            sqlStrBuffer.append("WHERE thingsNum=?");
            values.add(queryInfo);
            sqlCommandBean.setValues(values);
        }
        
        /** SQL语句字符串实例化 */
        sqlStr = sqlStrBuffer.toString();
        
        /** 设置sqlValues 查询指定违禁品信息*/
        sqlCommandBean.setSqlValue(sqlStr);
                       
        /** 查询结果集 */
        rs = sqlCommandBean.executeQuery();

        /**执行查询违禁品信息后所得结果的个数*/
        int i =rs.getRowCount();
        
        try {
            /**实例化一个数组，用于存放查询结果*/
            Passenger passenger[]=new Passenger[i];
            /**将查询所得结果放在数组中*/
            for(int index = 0; index < i; index++) {
                /** 实例化数组里存放的结果 */
                passenger[index] = new Passenger();
                /** 给返回变量赋值 */
                passenger[index].setFlightTicket
                                   (rs.getRowsByIndex()[index][0].toString());
                passenger[index].setPassengerName
                                   (rs.getRowsByIndex()[index][1].toString());
                passenger[index].setPassengerIdKind
                                   (rs.getRowsByIndex()[index][2].toString());
                passenger[index].setPassengerId
                                   (rs.getRowsByIndex()[index][3].toString());
                passenger[index].setPassengerNat
                                   (rs.getRowsByIndex()[index][4].toString());
                passenger[index].setThingsNum
                                   (rs.getRowsByIndex()[index][5].toString());
                passenger[index].setThings
                                   (rs.getRowsByIndex()[index][6].toString());
                passenger[index].setThingsQuantity
                                   (rs.getRowsByIndex()[index][7].toString());
                passenger[index].setHold
                                   (rs.getRowsByIndex()[index][8].toString());
                passenger[index].setCori
                                   (rs.getRowsByIndex()[index][9].toString());
                passenger[index].setFlightNo
                                   (rs.getRowsByIndex()[index][10].toString());
                passenger[index].setFlightDate
                                   (rs.getRowsByIndex()[index][11].toString());
            }
            /** 记录用户操作日志：查看违禁品信息 */
            userOperation.info("userId: time: 操作：违禁品信息查询 " + 
                               "结果:成功");
            /**返回已经存放查询结果的数组*/
            return passenger;
        } catch(Exception e) {
            System.out.println("model:" + e);
            return null;
        } finally {
        	
        	AppMode.loginoutUser();
        	
            /** 释放Connection */
            sqlCommandBean.releaseConn();
        }
    }
}