modeldbimpl.java~30~

一个可以实现联网售票的火车售票管理系统

package train.server;

import train.mvc.*;
import train.parameter.*;
import java.util.*;
import java.sql.*;
import java.text.DateFormat;


/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: 沈阳化工学院计算机</p>
 *
 * @author 彭胜勇 胡林
 * @version 1.0
 */
public class ModelDBImpl implements Model {
    View view;
    List trainList;
    Connection conn;
    Statement stmt;
    PreparedStatement pstmt;
    PreparedStatement pstmtt;
    TableModelTrain tableModelTrain;
    public ModelDBImpl() {
        init();
    }

    public static void main(String[] args) {
        ModelDBImpl modeldbimpl = new ModelDBImpl();

    }

    public void init() {
        try {
            Class.forName(CommonConstant.dbDriverClass);
            try {
                conn = DriverManager.getConnection(CommonConstant.url,
                        CommonConstant.user,
                        CommonConstant.password);
                stmt = conn.createStatement();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        } catch (ClassNotFoundException ex) {
            ex.printStackTrace();
        }
    }

    public void addViewListener(View view,TableModelTrain tableModelTrain) {
        this.view = view;
        this.tableModelTrain=tableModelTrain;

    }

    public void deleteTicket(Ticket ticket) {
        String sql = "delete from 已售车票 where 票号 = ? ";
        try {
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, ticket.getTrainID());
            pstmt.executeUpdate();
            pstmt.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }

    }



    public void insertTicket(Ticket ticket) {
        String sql = "insert into 已售车票 values(?,?,?,?,?,?,?,?,?,?,?,?)";
        try {
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, ticket.getTicketNum());
            pstmt.setString(2, ticket.getTrainID());
            pstmt.setString(3, ticket.getCarrageID());
            pstmt.setString(4, ticket.getSeatID());
            pstmt.setString(5, ticket.getSoldStation());
            pstmt.setString(6, ticket.getFromStation());
            pstmt.setString(7, ticket.getArriveStation());
            pstmt.setString(8, ticket.getCenterStation());
            pstmt.setString(9, ticket.getTicketType());
            pstmt.setString(10, ticket.getBeginTime());
            pstmt.setString(11, ticket.getSoldDate());
            pstmt.setString(12, ticket.getPrice());
            pstmt.executeUpdate();
            pstmt.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }


    public List getTrain() {
        String sql = "select * from 列车车次";
        trainList = new ArrayList();
        Train train= null;
        try {
            ResultSet rs = stmt.executeQuery(sql);
            while (rs.next()) {
                train = new Train(
                        rs.getString(1),
                        rs.getString(2),
                        rs.getString(3),
                        rs.getString(4),
                        rs.getString(5),
                        rs.getString(6),
                        rs.getString(7),
                        rs.getString(8));
                trainList.add(train);
            }
            rs.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return trainList;
    }
    public List getStation() {
        String sql = "select * from 车站";
        List stationList = new ArrayList();
        Station station= null;
        try {
            ResultSet rs = stmt.executeQuery(sql);
            while (rs.next()) {
                station = new Station(
                        rs.getString(1),
                        rs.getString(2)
                        );
                stationList.add(station);
            }
            rs.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return stationList;
    }



    public List queryTrainWiID(String trainID) {
        List trainList = new ArrayList();
        Train train = null;
        String sql = "select * from 列车车次 where 车次 = ? ";
        try {
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, trainID);
            ResultSet rs = pstmt.executeQuery();
            while (rs.next()) {
              train = new Train(
                      rs.getString(1),
                      rs.getString(2),
                      rs.getString(3),
                      rs.getString(4),
                      rs.getString(5),
                      rs.getString(6),
                      rs.getString(7),
                      rs.getString(8));
                trainList.add(train);
            }
            rs.close();
            pstmt.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return trainList;
    }

    public List queryTrainWiSta(String fromSta,String endSta) {
        List trainList = new ArrayList();
        Train train = null;
        String sql = "select * from 列车车次 where 始发站 = ? and 终点站 = ? ";
        try {
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, fromSta);
            pstmt.setString(2, endSta);
            ResultSet rs = pstmt.executeQuery();
            while (rs.next()) {
              train = new Train(
                      rs.getString(1),
                      rs.getString(2),
                      rs.getString(3),
                      rs.getString(4),
                      rs.getString(5),
                      rs.getString(6),
                      rs.getString(7),
                      rs.getString(8));
                trainList.add(train);
            }
            rs.close();
            pstmt.close();
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return trainList;
    }

    public List queryStation(String staIndex) {
         List stationList = new ArrayList();
         Station station = null;
         String sql = "select 站名 from 车站 where 站名索引 = ? ";
         try {
             pstmt = conn.prepareStatement(sql);
             pstmt.setString(1, staIndex);
             ResultSet rs = pstmt.executeQuery();
             while (rs.next()) {
               station = new Station(
                       rs.getString(1),
                       rs.getString(2));
                 stationList.add(station);
             }
             rs.close();
             pstmt.close();
         } catch (SQLException ex) {
             ex.printStackTrace();
         }
         return stationList;
     }


    public void refreshTrainTable() {
        this.view.refreshTableTrainChange();
    }


    public int getIndex(Object obj, int objType) {
        if (trainList == null) {
            try {
                throw new Exception("Not data!");
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        }
        int index = 0;
        /*switch (objType) {
        case 0: //CommonConstant.objUser
            Train train = (Train) obj;
            trainList = this.getTrain();
            for (; index < trainList.size(); index++) {
                Train trainTest = (Train) trainList.get(index);
                if (trainTest.getTrainID().equals(user.getUserID())) {
                    return index;
                }
            }
            break;
        default:
            index = -1;
            break;
        }*/
        return index;
    }
}