java实现航班信息查询管理系统

蔚落 2022-11-13 06:21 195阅读 0赞

### 一、任务概述 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0F5dWUxMjIw_size_16_color_FFFFFF_t_70]

### 二、目录结构 ###

![目录结构][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0F5dWUxMjIw_size_16_color_FFFFFF_t_70 1]

### 三、详细代码 ###

JDBC工具类模块

package com.kaikeba.task.task010404.utils;
    
    import com.alibaba.druid.pool.DruidDataSource;
    
    import java.sql.*;
    import java.util.List;
    import java.util.ResourceBundle;
    
    public class JDBCUtils { 
    
        // 1、定义初始变量
        // 1.1 连接对象
        private Connection conn;
        // 1.2 预状态通道对象
        private PreparedStatement ps;
        // 1.3 结果集对象
        private ResultSet resultSet;
        // 1.4 存储受影响的行数数据
        private int count;
        // 1.5 数据库连接地址
        private static final String url;
        // 1.6 用户名
        private static final String username;
        // 1.7 密码
        private static final String password;
        // 1.8 驱动地址
        private static final String driverClassName;
        // 1.9 创建德鲁伊数据池连接对象
        private static final DruidDataSource dds = new DruidDataSource();
    
    
        // 加载驱动
        static { 
            // 读取属性文件数据
            ResourceBundle bundle = ResourceBundle.getBundle("dbConfig");
            driverClassName = bundle.getString("driverClassName");
            url = bundle.getString("url");
            username = bundle.getString("username");
            password = bundle.getString("password");
            // 设置属性
            dds.setUsername(username);
            dds.setPassword(password);
            dds.setUrl(url);
            dds.setDriverClassName(driverClassName);  // 驱动地址
            // dds.setInitialSize(20); // 设置初始连接个数
            dds.setTestWhileIdle(false); // 解决报错【testWhileIdle is true, validationQuery not set】
        }
    
    
        /** * 获得连接 * * @return 连接对象 */
        public Connection getConn() { 
            try { 
                conn = dds.getConnection();
            } catch (SQLException sqlException) { 
                sqlException.printStackTrace();
            }
            return conn;
        }
    
        /** * 获得预状态通道对象 * * @param sql sql语句 * @return 预状态通道对象 */
        public PreparedStatement getPs(String sql) { 
            try { 
                ps = getConn().prepareStatement(sql);
            } catch (SQLException sqlException) { 
                sqlException.printStackTrace();
            }
            return ps;
        }
    
        /** * 绑定参数 * * @param list 参数列表 */
        private void params(List<Object> list) { 
            if (list != null && list.size() > 0) { 
                for (int i = 0; i < list.size(); i++) { 
                    try { 
                        ps.setObject(i + 1, list.get(i));
                    } catch (SQLException sqlException) { 
                        sqlException.printStackTrace();
                    }
                }
            }
        }
    
    
        /** * 执行【增删改】操作 * * @param sql sql语句 * @param list 参数列表 * @return 影响行数 */
        public int update(String sql, List<Object> list) { 
            getPs(sql);
            params(list);
            try { 
                count = ps.executeUpdate();
            } catch (SQLException sqlException) { 
                sqlException.printStackTrace();
            }
            return count;
        }
    
        /** * 执行【查询】操作 * * @param sql sql语句 * @param list 参数列表 * @return 查询得到的数据 */
        public ResultSet query(String sql, List<Object> list) { 
            getPs(sql);
            params(list);
            try { 
                resultSet = ps.executeQuery();
            } catch (SQLException sqlException) { 
                sqlException.printStackTrace();
            }
            return resultSet;
        }
    
        /** * 查询全部数据 * @param sql SQL语句 * @return 全部数据 */
        public ResultSet queryAll(String sql) { 
            getPs(sql);
            try { 
                resultSet = ps.executeQuery();
            } catch (SQLException sqlException) { 
                sqlException.printStackTrace();
            }
            return resultSet;
        }
    
        /** * 关闭所有资源 */
        public void closeAll() { 
            try { 
                if (resultSet != null)
                    resultSet.close();
                if (ps != null)
                    ps.close();
                if (conn != null)
                    conn.close();
            } catch (SQLException sqlException) { 
                sqlException.printStackTrace();
            }
        }
    
    }

AirInfo

package com.kaikeba.task.task010404.bean;
    
    
    public class AirInfo { 
    
        // 编号
        private int number;
        // 航班号
        private int flightNumber;
        // 目的地
        private String destination;
        // 起飞日期
        private String date;
    
        public AirInfo() { 
        }
    
        public AirInfo(int number, int flightNumber, String destination, String date) { 
            this.number = number;
            this.flightNumber = flightNumber;
            this.destination = destination;
            this.date = date;
        }
    
        public int getNumber() { 
            return number;
        }
    
        public void setNumber(int number) { 
            this.number = number;
        }
    
        public int getFlightNumber() { 
            return flightNumber;
        }
    
        public void setFlightNumber(int flightNumber) { 
            this.flightNumber = flightNumber;
        }
    
        public String getDestination() { 
            return destination;
        }
    
        public void setDestination(String destination) { 
            this.destination = destination;
        }
    
        public String getDate() { 
            return date;
        }
    
        public void setDate(String date) { 
            this.date = date;
        }
    
        @Override
        public String toString() { 
            return "AirInfo{" +
                    "number=" + number +
                    ", flightNumber=" + flightNumber +
                    ", destination='" + destination + '\'' +
                    ", date=" + date +
                    '}';
        }
    }

Dao模块

package com.kaikeba.task.task010404.dao;
    
    
    import com.kaikeba.task.task010404.bean.AirInfo;
    
    import java.util.List;
    
    public interface AirInfoDao { 
    
        /** * 根据起飞时间查询 * @param date 起飞时间 * @return 对应的航班信息 */
        public List<AirInfo> findByDate(String date);
    
        /** * 根据目的地查询 * @param destination 目的地 * @return 对应的航班信息 */
        public List<AirInfo> findByDestination(String destination);
    
        /** * 查看所有航班 * @return 所有航班信息 */
        public List<AirInfo> findAll();
    
        /** * 更新航班信息【根据编号】 * @param airInfo 航班信息 * @return 影响行数 */
        public int update(AirInfo airInfo);
    
        /** * 删除航班信息【根据编号】 * @param number 编号 * @return 影响行数 */
        public int delete(int number);
    }

Dao实现类模块

package com.kaikeba.task.task010404.dao.impl;
    
    import com.kaikeba.task.task010404.bean.AirInfo;
    import com.kaikeba.task.task010404.dao.AirInfoDao;
    import com.kaikeba.task.task010404.utils.JDBCUtils;
    
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.List;
    
    public class AirInfoDaoImpl extends JDBCUtils implements AirInfoDao { 
    
        @Override
        public List<AirInfo> findByDate(String date) { 
            // 定义SQL查询语句
            String sql = "SELECT number,flightNumber,destination,date FROM air_info WHERE date=?";
            // 声明一个空数组，用于存储查询参数
            List<Object> list = new ArrayList<>();
            // 将查询参数添加到数组中
            list.add(date);
            // 执行查询语句
            ResultSet resultSet = query(sql, list);
            // 声明一个空数组，用于存放查询得到的数据
            List<AirInfo> airInfos = new ArrayList<>();
            try { 
                while (resultSet.next()) { 
                    // 声明一个 AirInfo 对象
                    AirInfo airInfo = new AirInfo();
                    // 设置属性
                    airInfo.setNumber(resultSet.getInt("number"));
                    airInfo.setFlightNumber(resultSet.getInt("flightNumber"));
                    airInfo.setDestination(resultSet.getString("destination"));
                    airInfo.setDate(resultSet.getString("date"));
                    // 将 AirInfo 对象数据添加到列表中
                    airInfos.add(airInfo);
                }
            } catch (SQLException throwables) { 
                throwables.printStackTrace();
            } finally { 
                // 关闭资源
                closeAll();
            }
            return airInfos;
        }
    
        @Override
        public List<AirInfo> findByDestination(String destination) { 
            // 定义SQL查询语句
            String sql = "SELECT number,flightNumber,destination,date FROM air_info WHERE destination=?";
            // 声明一个空数组，用于存储查询参数
            List<Object> list = new ArrayList<>();
            // 将查询参数添加到数组中
            list.add(destination);
            // 执行查询语句
            ResultSet resultSet = query(sql, list);
            // 声明一个空数组，用于存放查询得到的数据
            List<AirInfo> airInfos = new ArrayList<>();
            try { 
                while (resultSet.next()) { 
                    // 声明一个 AirInfo 对象
                    AirInfo airInfo = new AirInfo();
                    // 设置属性
                    airInfo.setNumber(resultSet.getInt("number"));
                    airInfo.setFlightNumber(resultSet.getInt("flightNumber"));
                    airInfo.setDestination(resultSet.getString("destination"));
                    airInfo.setDate(resultSet.getString("date"));
                    // 将 AirInfo 对象数据添加到列表中
                    airInfos.add(airInfo);
                }
            } catch (SQLException throwables) { 
                throwables.printStackTrace();
            } finally { 
                // 关闭资源
                closeAll();
            }
            return airInfos;
        }
    
        @Override
        public List<AirInfo> findAll() { 
            // 声明一个空数组，用于存放查询得到的数据
            List<AirInfo> airInfos = new ArrayList<>();
            // 定义查询SQL语句
            String sql = "SELECT number,flightNumber,destination,date FROM air_info";
            // 执行查询语句，获取查询结果
            ResultSet resultSet = queryAll(sql);
            try { 
                while (resultSet.next()) { 
                    // 声明一个 AirInfo 对象
                    AirInfo airInfo = new AirInfo();
                    // 设置属性
                    airInfo.setNumber(resultSet.getInt("number"));
                    airInfo.setFlightNumber(resultSet.getInt("flightNumber"));
                    airInfo.setDestination(resultSet.getString("destination"));
                    airInfo.setDate(resultSet.getString("date"));
                    // 将 AirInfo 对象数据添加到列表中
                    airInfos.add(airInfo);
                }
            } catch (SQLException throwables) { 
                throwables.printStackTrace();
            } finally { 
                // 关闭资源
                closeAll();
            }
            return airInfos;
        }
    
        @Override
        public int update(AirInfo airInfo) { 
            // 定义SQL查询语句
            String sql = "UPDATE air_info SET flightNumber=?,destination=?,date=? WHERE number=?";
            // 声明一个空数组，用于存储查询参数
            List<Object> list = new ArrayList<>();
            // 将查询参数添加到数组中
            list.add(airInfo.getFlightNumber());
            list.add(airInfo.getDestination());
            list.add(airInfo.getDate());
            list.add(airInfo.getNumber());
            // 执行查询语句
            return update(sql, list);
        }
    
        @Override
        public int delete(int number) { 
            // 定义SQL查询语句
            String sql = "DELETE FROM air_info WHERE number=?";
            // 声明一个空数组，用于存储查询参数
            List<Object> list = new ArrayList<>();
            // 将查询参数添加到数组中
            list.add(number);
            // 执行查询语句
            return update(sql, list);
        }
    }

视图模块

package com.kaikeba.task.task010404.view;
    
    import com.kaikeba.task.task010404.bean.AirInfo;
    
    import java.util.List;
    import java.util.Scanner;
    
    public class Views { 
    
        // 声明一个数据输入对象
        Scanner input_in = new Scanner(System.in);
    
        /** * 欢迎语 */
        public void welcome() { 
            System.out.println("********* 欢迎使用航班信息管理系统 *********");
        }
    
        /** * 开始菜单 * * @return 服务编号 */
        public int menu() { 
            // 提示用户输入服务编号
            System.out.print("请选择操作（1、列出所有航班；2、按起飞时间查询；3、按目的地查询；4、删除航班；5、更新航班；6、离开系统）：");
            // 接收用户输入数据，并校验，数据校验正确，将其返回
            return checkData(1, 6);
        }
    
        /** * 校验数据 * * @param start 开始数字 * @param end 结束数字 * @return 校验无误的数据 */
        public int checkData(int start, int end) { 
            // 声明一个整数变量用于接受用户输入的服务编号
            int num;
            // 开启 while 循环用于校验用户输入数据是否有误
            while (true) { 
                // 接受用户输入的数据
                String input_text = input_in.nextLine();
                try { 
                    // 将用户输入的数据转换为 int 类型
                    num = Integer.parseInt(input_text);
                } catch (Exception e) { 
                    System.out.println("输入有误，请重新输入！");
                    continue;
                }
                // 判断用户输入数据是否小于初始值或大于结束值
                if (num < start || num > end) { 
                    System.out.println("输入有误，请重新输入！");
                    continue;
                }
                // 返回数据
                return num;
            }
        }
    
        /** * 校验用户输入数据是否可转换为整数类型 * * @return 用户输入数据 */
        public int checkInt() { 
            // 声明一个整数变量用于接受用户输入的服务编号
            int num;
            // 开启 while 循环用于校验用户输入数据是否有误
            while (true) { 
                // 接受用户输入的数据
                String input_text = input_in.nextLine();
                try { 
                    // 将用户输入的数据转换为 int 类型
                    num = Integer.parseInt(input_text);
                } catch (Exception e) { 
                    System.out.println("输入有误，请重新输入！");
                    continue;
                }
                // 返回数据
                return num;
            }
        }
    
        /** * 输入时间 * * @return 时间 */
        public String enterDate() { 
            System.out.print("请输入日期(格式：2021-01-01)：");
            return input_in.nextLine();
        }
    
        /** * 输入目的地 * * @return 目的地数据 */
        public String enterDestination() { 
            System.out.print("请输入目的地：");
            return input_in.nextLine();
        }
    
        /** * 删除航班 * * @return 航班编号 */
        public int delete() { 
            System.out.print("请输入需要删除的航班编号：");
            return checkInt();
        }
    
    
        /** * 删除成功 */
        public void deleteSuccess() { 
            System.out.println("删除成功！");
        }
    
        /** * 删除失败 */
        public void deleteFail() { 
            System.out.println("删除失败，请检查航班编号是否存在！");
        }
    
    
        /** * 更新航班 * * @return AirInfo 对象 */
        public AirInfo update() { 
            AirInfo airInfo = new AirInfo();
            System.out.print("请输入需要更新的航班编号：");
            airInfo.setNumber(checkInt());
            System.out.print("请输入新的航班号：");
            airInfo.setFlightNumber(checkInt());
            System.out.print("请输入新的目的地：");
            airInfo.setDestination(input_in.nextLine());
            System.out.print("请输入新的起飞日期(格式：2021-01-01)：");
            airInfo.setDate(input_in.nextLine());
            return airInfo;
        }
    
        /** * 更新成功 */
        public void updateSuccess() { 
            System.out.println("更新成功！");
        }
    
        /** * 更新失败 */
        public void updateFail() { 
            System.out.println("更新失败，请检查航班编号是否存在！");
        }
    
        /** * 退出提示 */
        public void signOut() { 
            System.out.println("很高兴为您服务，期待您的再次使用！");
        }
    
    
        /** * 展示航班信息 * * @param list 航班数据列表 */
        public void show(List<AirInfo> list) { 
            System.out.println("\t编号 \t航班号 \t目的地 \t起飞日期");
            if (list.size()>0){ 
                for (AirInfo airInfo : list) { 
                    System.out.println("\t" + airInfo.getNumber() + " \t\t" + airInfo.getFlightNumber() + " \t" + airInfo.getDestination() + " \t" + airInfo.getDate());
                }
            }else { 
                System.out.println("当前航班信息为空");
            }
        }
    }

调度模块

package com.kaikeba.task.task010404;
    
    import com.kaikeba.task.task010404.bean.AirInfo;
    import com.kaikeba.task.task010404.dao.AirInfoDao;
    import com.kaikeba.task.task010404.dao.impl.AirInfoDaoImpl;
    import com.kaikeba.task.task010404.view.Views;
    
    import java.util.List;
    
    
    public class Main { 
        public static void main(String[] args) { 
            // 声明一个视图对象
            Views vs = new Views();
            // 声明一个数据库对象
            AirInfoDao dao = new AirInfoDaoImpl();
            // 声明一个 List 集合用于存放数据
            List<AirInfo> data;
            // 初始化变量
            int number;
            int result;
    
            // 欢迎语句
            vs.welcome();
    
            w:
            while (true) { 
                // 菜单选项，接收用户输入服务编号
                number = vs.menu();
                switch (number) { 
                    // 列出所有航班
                    case 1:
                        data = dao.findAll();
                        vs.show(data);
                        break;
                    // 按起飞时间查询
                    case 2:
                        String date = vs.enterDate();
                        data = dao.findByDate(date);
                        vs.show(data);
                        break;
                    // 按目的地查询
                    case 3:
                        String destination = vs.enterDestination();
                        data = dao.findByDestination(destination);
                        vs.show(data);
                        break;
                    // 删除航班
                    case 4:
                        int num = vs.delete();
                        result = dao.delete(num);
                        if (result > 0) { 
                            vs.deleteSuccess();
                        } else { 
                            vs.deleteFail();
                        }
                        break;
                    // 更新航班
                    case 5:
                        AirInfo airInfo = vs.update();
                        result = dao.update(airInfo);
                        if (result > 0) { 
                            vs.updateSuccess();
                        } else { 
                            vs.updateFail();
                        }
                        break;
                    // 离开系统
                    case 6:
                        vs.signOut();
                        break w;
                }
            }
        }
    }

### 四、运行截图 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0F5dWUxMjIw_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0F5dWUxMjIw_size_16_color_FFFFFF_t_70 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0F5dWUxMjIw_size_16_color_FFFFFF_t_70]: /images/20221022/1fb9f7c412a34112ad6b135e9833cc4d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0F5dWUxMjIw_size_16_color_FFFFFF_t_70 1]: /images/20221022/adca89cf78e642c5820868f78a1864f8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0F5dWUxMjIw_size_16_color_FFFFFF_t_70 2]: /images/20221022/25aa31e53d79494fb858943d5411ee17.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0F5dWUxMjIw_size_16_color_FFFFFF_t_70 3]: /images/20221022/014019d2c43a4104a82067b88f4b83fc.png