Java实现航空航班管理系统

package com.hangkong;

public class Plane {

  private int id; //编号

  private String planeNum; //航班号

  private String address; //目的地

  private String date; //日期

  public Plane( int id, String planeNum, String address, String date) {

   super ();

   this .id = id;

   this .planeNum = planeNum;

   this .address = address;

   this .date = date;

  }

  public Plane(){

   super ();

  }

  //Alt+Shift+s

  public int getId() {

   return id;

  }

  public void setId( int id) {

   this .id = id;

  }

  public String getPlaneNum() {

   return planeNum;

  }

  public void setPlaneNum(String planeNum) {

   this .planeNum = planeNum;

  }

  public String getAddress() {

   return address;

  }

  public void setAddress(String address) {

   this .address = address;

  }

  public String getDate() {

   return date;

  }

  public void setDate(String date) {

   this .date = date;

  }

  @Override

  public String toString() {

   return "Plane" + id + "\t\t" + planeNum + "\t\t" + address + "\t\t" + date;

   //return "Plane ID:" + id + "\t航班编号:" + planeNum + "\t目的地:" + address + "\t起飞时间:" + date;

  }

}

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------

-- Table structure for `plane`

-- ----------------------------

DROP TABLE IF EXISTS `plane`;

CREATE TABLE `plane` (

   `id` int (20) NOT NULL AUTO_INCREMENT,

   `planeNum` varchar (20) DEFAULT NULL ,

   `address` varchar (20) DEFAULT NULL ,

   ` date ` varchar (20) DEFAULT NULL ,

   PRIMARY KEY (`id`)

) ENGINE=InnoDB AUTO_INCREMENT=16 DEFAULT CHARSET=utf8;

-- ----------------------------

-- Records of plane

-- ----------------------------

INSERT INTO `plane` VALUES ( '1' , 'DZ001' , '东京' , '2019-9-1' );

INSERT INTO `plane` VALUES ( '2' , 'DZ002' , '上海' , '2019-8-28' );

INSERT INTO `plane` VALUES ( '3' , 'DZ003' , '广州' , '2019-8-29' );

INSERT INTO `plane` VALUES ( '4' , 'DZ004' , '深圳' , '2019-8-29' );

INSERT INTO `plane` VALUES ( '5' , 'DZ005' , '厦门' , '2019-8-30' );

INSERT INTO `plane` VALUES ( '6' , 'DZ006' , '杭州' , '2019-8-30' );

INSERT INTO `plane` VALUES ( '7' , 'DZ007' , '武汉' , '2019-8-30' );

INSERT INTO `plane` VALUES ( '8' , 'DZ008' , '成都' , '2019-8-30' );

INSERT INTO `plane` VALUES ( '9' , 'DZ009' , '西安' , '2019-8-30' );

INSERT INTO `plane` VALUES ( '10' , 'DZ0010' , '郑州' , '2019-8-30' );

INSERT INTO `plane` VALUES ( '11' , 'DZ0011' , '长沙' , '2019-8-30' );

INSERT INTO `plane` VALUES ( '12' , 'DZ0012' , '民权' , '2019-8-31' );

INSERT INTO `plane` VALUES ( '13' , 'DZ0013' , '莫斯科' , '2019-9-1' );

INSERT INTO `plane` VALUES ( '14' , 'DZ0014' , '曼谷' , '2019-9-2' );

INSERT INTO `plane` VALUES ( '15' , 'DZ0015' , '阿布扎比' , '2019-9-2' );

package com.hangkong;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.util.HashSet;

import java.util.Scanner;

import java.util.Set;

import org.omg.CosNaming.NamingContextExtPackage.StringNameHelper;

import com.mysql.jdbc.ExceptionInterceptor;

import com.sun.javafx.runtime.VersionInfo;

import com.sun.xml.internal.ws.api.pipe.NextAction;

public class TestFly {

  static Connection con = null ; //连接

  static PreparedStatement ps = null ; //模板

  static ResultSet rs = null ; //结果集

  public static void main(String[] args) throws Exception {

   System.out.println( "******************************************大壮航空航班信息管理系统********************************************\n" );

   //show();

   boolean bool = Dome();

   while (bool){

    bool = Dome();

   }

   if (!bool){

    System.out.println( "**************************************已成功退出大壮航空航班信息管理系统**************************************\n" );

    System.exit( 0 );

   }

  }

  //流程

  public static boolean Dome() throws Exception{

   Scanner scan = new Scanner(System.in);

   show();

   int key = scan.nextInt();

   switch (key) {

   case 1 :

    showMessage(listMessage());

    break ;

   case 2 :{

    System.out.println( "输入起飞时间：" );

    String date = scan.next();

    showMessage(selectDate(date));

   } break ;

   case 3 :{

    System.out.println( "输入目的地：" );

    String Address = scan.next();

    showMessage(selectAddress(Address));

   } break ;

   case 4 :{

    System.out.println( "输入航班编号：" );

    String planeNum = scan.next();

    deleteFly(planeNum);

   } break ;

   case 5 :{

    System.out.println( "输入航班编号和更改后目的地和时间：" );

    String planeNum = scan.next();

    String Address = scan.next();

    String date = scan.next();

    updateFly(Address,date,planeNum);

   } break ;

   case 6 :{

    System.out.println( "输入航班编号、目的地、起飞时间：" );

    String planeNum = scan.next();

    String Address = scan.next();

    String date = scan.next();

    creatPlane(planeNum,Address,date);

   } break ;

   default :

    //scan.close();

    return false ;

   }

   //scan.close();

   return true ;

  }

  //注册驱动，获取连接

  public static Connection getCon() throws Exception{

   Class.forName( "com.mysql.jdbc.Driver" );

   con = DriverManager.getConnection( "jdbc:mysql://localhost:3306/fly" , "root" , "" );

   return con;

  }

  //创建初始信息，插入信息

  public static void creatPlane(String planeNum,String address, String date) throws Exception{

   getCon();

   String sql = "insert into plane values (null,?,?,?)" ;

   ps = con.prepareStatement(sql);

   ps.setString( 1 , planeNum);

   ps.setString( 2 , address);

   ps.setString( 3 , date);

   ps.executeUpdate();

   ps.close();

   con.close();

   selectPlaneNum(planeNum);

  }

  //系统主菜单

  public static void show(){

   System.out.println( "请选择操作：(1.列出所有航班，2.按起飞时间查询，3.按目的地查询，4.删除航班，5.更新航班，6.增加航班，7.退出系统)" );

  }

  //获取结果集合输出

  public static void showMessage(Set<Plane> set){

   System.out.println( "\n********************************大壮航空***********************************\n" );

   if (set.size() == 0 ){

    System.out.println( "未匹配到任何数据！" );

    System.out.println( "\n********************************大壮航空***********************************\n" );

    return ;

   }

   System.out.println( "Plane\t\t航班编号\t目的地\t\t起飞时间" );

   for ( Plane value : set){

    System.out.println(value);

   }

   System.out.println( "\n********************************大壮航空***********************************\n" );

  }

  //列出所有航班信息

  public static Set<Plane> listMessage() throws Exception{

   getCon();

   String sql = "select * from plane" ;

   ps = con.prepareStatement(sql);

   rs = ps.executeQuery();

   Set<Plane> set = new HashSet<>();

   while (rs.next()){

    int id = rs.getInt( "id" );

    String planeNum = rs.getString( "planeNum" );

    String address = rs.getString( "address" );

    String dateTime = rs.getString( "date" );

    Plane plane = new Plane(id, planeNum, address, dateTime);

    set.add(plane);

   }

   ps.close();

   con.close();

   return set;

  }

  //按起飞时间查询

  public static Set<Plane> selectDate(String date) throws Exception{

   getCon();

   String sql = "select * from plane where date = ? " ;

   ps = con.prepareStatement(sql);

   ps.setString( 1 , date);

   rs = ps.executeQuery();

   Set<Plane> set = new HashSet<>();

   //String planes = "";

   while (rs.next()){

    int id = rs.getInt( "id" );

    String planeNum = rs.getString( "planeNum" );

    String address = rs.getString( "address" );

    String dateTime = rs.getString( "date" );

    Plane plane = new Plane(id, planeNum, address, dateTime);

    set.add(plane);

    //planes += plane.toString() + "\n";

   }

   ps.close();

   con.close();

   return set;

  }

  //按目的地查询

  public static Set<Plane> selectAddress(String Address) throws Exception{

   getCon();

   String sql = "select * from plane where address = ? " ;

   ps = con.prepareStatement(sql);

   ps.setString( 1 , Address);

   rs = ps.executeQuery();

   Set<Plane> set = new HashSet<>();

   //String planes = "";

   while (rs.next()){

    int id = rs.getInt( "id" );

    String planeNum = rs.getString( "planeNum" );

    String address = rs.getString( "address" );

    String dateTime = rs.getString( "date" );

    Plane plane = new Plane(id, planeNum, address, dateTime);

    set.add(plane);

    //planes += plane.toString() + "\n";

   }

   ps.close();

   con.close();

   return set;

  }

  //按航班编号

  public static void selectPlaneNum(String planeNum) throws Exception{

   getCon();

   String sql = "select * from plane where planeNum = ? " ;

   ps = con.prepareStatement(sql);

   ps.setString( 1 , planeNum);

   rs = ps.executeQuery();

   boolean x = true ;

   while (rs.next()){

    if (x){

     System.out.println( "\n********************************大壮航空***********************************\n" );

     System.out.println( "Plane\t\t航班编号\t目的地\t\t起飞时间" );

    }

    int id = rs.getInt( "id" );

    String planenum = rs.getString( "planeNum" );

    String address = rs.getString( "address" );

    String date = rs.getString( "date" );

    System.out.println( "Plane" + id + "\t\t" + planenum + "\t\t" + address + "\t\t" + date);

    x = false ;

   }

   System.out.println( "\n********************************大壮航空***********************************\n" );

  }

  //按航班编号删除航班

  public static void deleteFly(String planeNum) throws Exception{

   getCon();

   String sql = "delete from plane where planeNum = ? " ;

   ps = con.prepareStatement(sql);

   ps.setString( 1 , planeNum);

   ps.executeUpdate();

   ps.close();

   con.close();

   System.out.println( "\n********************************大壮航空***********************************\n" );

   System.out.println( "已删除！" );

   System.out.println( "\n********************************大壮航空***********************************\n" );

  }

  //按航班编号更新航班目的地和时间

  public static void updateFly(String Address,String date,String planeNum) throws Exception{

   getCon();

   String sql = "update plane set address = ?,date = ? where planeNum = ? " ;

   ps = con.prepareStatement(sql);

   ps.setString( 1 , Address);

   ps.setString( 2 , date);

   ps.setString( 3 , planeNum);

   ps.executeUpdate();

   ps.close();

   con.close();

   selectPlaneNum(planeNum);

  }

}