addpassengermodel.java

eclipse java/jsp 航空管理系统

/*
 * @(#)AddPassenger.java 1.0 2005/04/14   
 * <p>copyright:    Copyright 东软 国际合作事业部版权所有</p>
 * <p>company:      neusoft</p>
 * <p>time:         2005.04.14</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.SQLCommandBean;
import jiasir.ConnDataBaseBean;
import org.apache.log4j.Logger;

import zhangchunliang.model.AppMode;

/**
 * 处理添加违禁品信息的Model
 * @author    王嘉    
 * @version   1.0， 2005/04/14
 */
public class AddPassengerModel {
    /** 用户操作日志记录器 */
    static Logger userOperation = Logger.getLogger("userOperation");
    
    /** 用户异常日志记录器 */
    static Logger userError = Logger.getLogger("userError");

    //Temporary Note
    /** 系统调试日志记录器 */
    static Logger systemDebug = Logger.getLogger(AddPassengerModel.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;
    /**
     * AddPassengerModel类的默认(无参)构造方法*/
    public AddPassengerModel(){
    }

    /**
     * 执行添加组的SQL操作方法
     * @return 1            旅客信息添加插入成功
     * @return 7            添加机票号重复
     * @return 8            没有配置MySQL数据库驱动
     * @return 9            SQL语句错误
     */
    public int executeSQL() throws NamingException, SQLException {
    	
    	AppMode.registerUser();
    	
        /** SQL语句字符串缓冲 */
        StringBuffer sqlStrBuffer;
      
        /** SQL语句字符串 */
        String sqlStr;
        
        /** SQL语句操作的结果集 */
        Result result;
        
        /** Values实例化 */
        List values = new ArrayList();

        /** SQLCommandBean实例化 */
        SQLCommandBean sqlCommandBean = new SQLCommandBean();
        
        /** ConnDataBaseBean实例化 */
        ConnDataBaseBean connDataBaseBean = new ConnDataBaseBean();
        
        /** 从连接池中取得一个连接 */
        DataSource dataSource = connDataBaseBean.getDataSource();
        
        /** 设置Connection */
        sqlCommandBean.setConnection(dataSource.getConnection());
        
        /** 设置SqlValues 查询指定违禁品信息*/
        sqlCommandBean.setSqlValue
                       ("SELECT * FROM passenger WHERE flightTicket=?");
        
        /** 设置Values */
        values.add(flightTicket);
        sqlCommandBean.setValues(values);
        try {
            /** 查询结果集 */
            result = sqlCommandBean.executeQuery();
            
            /** 判断机票号是否已存在 */
            if(result.getRowCount() > 0) {
                return 7;
            } else {
                /** SQL语句字符串缓冲实例化, 添加权限组SQL语句 */        
                sqlStrBuffer = new StringBuffer(200);
                sqlStrBuffer.append
                ("INSERT INTO passenger(flightTicket,passengerName,");
                sqlStrBuffer.append
                ("passengerIdKind,passengerId,passengerNat,thingsNum,");
                sqlStrBuffer.append
                ("things,thingsQuantity,hold,cori,flightNo,flightDate,");
                sqlStrBuffer.append
                ("insert_date,update_date) ");
                sqlStrBuffer.append
                ("VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
                
                /** SQL语句字符串实例化 */
                sqlStr = sqlStrBuffer.toString();
                
                /** 设置SqlValues 添加指定违禁品信息*/
                sqlCommandBean.setSqlValue(sqlStr); 
                
                /** 设置Values */
                values.clear();
                values.add(flightTicket);
                values.add(passengerName);
                values.add(passengerIdKind);
                values.add(passengerId);
                values.add(passengerNat);
                values.add(thingsNum);
                values.add(things);
                values.add(thingsQuantity);
                values.add(hold);
                values.add(cori);
                values.add(flightNo);
                values.add(flightDate);
                values.add(insertDate);
                values.add(updateDate);
                sqlCommandBean.setValues(values);
                /** 返回执行结果 */
                return sqlCommandBean.executeUpdate();
            }
        } catch(SQLException e) {
            return 9;
        } finally {
        	
        	AppMode.loginoutUser();
        	
            /** 释放Connection */
            sqlCommandBean.releaseConn();
        }
    }
}