ICode9
精准搜索请尝试： 精确搜索
首页
编程语言>
数据库
系统相关
互联网
其他分享
Python
Java
JavaScript
android
PHP
首页 > 其他分享> 文章详细

航班信息管理系统（JDBC）

2021-04-27 18:59:49  阅读：287  来源： 互联网

标签：JDBC return String getString rs 航班 信息管理系统 public airInfo


目录

航班信息管理系统

  • 前言：现在有一家航空公司为了提高用户体验，希望做一个航班信息系统，用户可以根据需求去对航班信息进行操作。组长把这个任务安排给了程序员赵丹，赵丹发现这里需要通过Java代码操作数据库，并且用户是可以在控制台做对应的操作，JDBC可以帮她解决这个问题。学习起来，试着把这个系统实现出来。
  • 目标：
    • 使用 JDBC 操作 MySql 数据库
  • 需求：
    • 显示航班信息系统主菜单
    • 列出所有的航班信息
    • 按起飞时间查询
    • 按目的地查询
    • 删除航班
    • 更新航班
    • 退出系统
  • 提示：
    • 创建数据库表 airinfo，添加测试数据不少于 4 条。要求主键自增。
    • 创建实体类 AirInfo，根据业务提供需要的构造方法和 setter/getter方法。
    • 创建 BaseDao 类，实现数据库连接和关闭功能。
    • 创建 DAO 接口 AirInfoDao，定义查询所有航班，按日期和目的地查询航班，删除航班，更新航班的方法。
    • 创建 DAO 实现类 AirInfoDaoImpl，继承 BaseDao 类，实现 AirInfoDao接口，使用 JDBC 完成相应数据库操作。
    • 创建 Main 类，启动和运行系统。

实现

  • 在开始设计前，先介绍一下本项目的大体结构，如下图所示。
    在这里插入图片描述
    • AirInfo：实体类
    • DBUtils：JDBC工具类，实现数据库连接、增删改查和关闭功能，并且在本项目中，新增了Druid数据库连接池。
    • AirInfoDaoImpl：Dao作为接口，Impl作为实现类，定义查询所有航班，按日期、目的地和航班号查询航班，删除航班，更新航班的方法。
    • AirView：视图类
    • db.properties：数据库及连接池的配置信息。
    • OutNumberBoundException：检验用户输入操作是否不符合要求。
    • Main：启动类

1. 创建数据表

在这里插入图片描述

2. 数据库工具类实现

db.properties
driver = com.mysql.cj.jdbc.Driver
url = jdbc:mysql://localhost:3306/AirInfo?serverTimezone=UTC&characterEncoding=utf-8&useSSL=false
username = root
password = 123456
filters = stat
initialSize = 2
maxActive = 300
maxWait = 60000
timeBetweenEvictionRunsMillis = 60000
minEvictableIdleTimeMillis = 300000
validationQuery = SELECT 1
testWhileIdle = true
testOnBorrow = false
testOnReturn = false
poolPreparedStatements = false
maxPoolPreparedStatementPerConnectionSize = 200
DBUtils.java
/**
 * 数据库连接池 + 工具类
 */
public class DBUtils {
    // 1. 定义变量
    private Connection conn = null;
    private PreparedStatement ps = null;
    private ResultSet rs = null;
    // 定义受影响的行数
    private int count;

    private static String driver;
    private static String url;
    private static String userName;
    private static String passWord;
    private static DruidDataSource druid = new DruidDataSource();


    static {
        // 2. 加载驱动信息
        ResourceBundle bundle = ResourceBundle.getBundle("db");
        driver = bundle.getString("driver");
        url = bundle.getString("url");
        userName = bundle.getString("username");
        passWord = bundle.getString("password");

        // 使用Druid连接池
        druid.setDriverClassName(driver);
        druid.setUrl(url);
        druid.setUsername(userName);
        druid.setPassword(passWord);

        try {
            druid.setFilters(bundle.getString("filters"));
            druid.setInitialSize(Integer.parseInt(bundle.getString("initialSize")));
            druid.setMaxActive(Integer.parseInt(bundle.getString("maxActive")));
            druid.setMaxWait(Long.parseLong(bundle.getString("maxWait")));
            druid.setTimeBetweenEvictionRunsMillis(Long.parseLong(bundle.getString("timeBetweenEvictionRunsMillis")));
            druid.setMinEvictableIdleTimeMillis(Long.parseLong(bundle.getString("minEvictableIdleTimeMillis")));
            druid.setValidationQuery(bundle.getString("validationQuery"));
            druid.setTestWhileIdle(Boolean.parseBoolean(bundle.getString("testWhileIdle")));
            druid.setTestOnBorrow(Boolean.parseBoolean(bundle.getString("testOnBorrow")));
            druid.setTestOnReturn(Boolean.parseBoolean(bundle.getString("testOnReturn")));
            druid.setPoolPreparedStatements(Boolean.parseBoolean(bundle.getString("poolPreparedStatements")));
            druid.setMaxPoolPreparedStatementPerConnectionSize(Integer.parseInt(bundle.getString("maxPoolPreparedStatementPerConnectionSize")));
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }

    // 3. 建立连接
    protected Connection getConn(){
        try {
            // Druid
            conn = druid.getConnection();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        return conn;
    }

    // 4. 获得预处理通道
    protected PreparedStatement getPs(String sql){
        try {
            ps = getConn().prepareStatement(sql);
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        return ps;
    }

    // 5. 绑定参数
    protected void param(List list){
        if (list != null && list.size() > 0){
            for (int i=0; i<list.size(); i++){
                try {
                    ps.setObject(i+1,list.get(i));
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }

    // 6. 执行操作(增删改)
    protected int update(String sql, List list){
        getPs(sql);
        param(list);
        try {
            count = ps.executeUpdate();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        return count;
    }

    // 7. 执行操作(查询)
    protected ResultSet query(String sql, List list){
        getPs(sql);
        param(list);
        try {
            rs = ps.executeQuery();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
        return rs;
    }

    // 8. 关闭连接
    protected void closeAll(){
        try {
            if (rs != null) {
                rs.close();
            }
            if (ps != null) {
                ps.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }

}

3. Bean 类

AirInfo.java
public class AirInfo {
    // 编号
    private int id;
    // 航班号
    private String number;
    // 目的地
    private String destination;
    // 出发时间
    private String flight_date;

    public AirInfo() {
    }

    public AirInfo(int id, String number, String destination, String flight_date) {
        this.id = id;
        this.number = number;
        this.destination = destination;
        this.flight_date = flight_date;
    }

    @Override
    public String toString() {
        return "AirInfo{" +
                "id=" + id +
                ", number='" + number + '\'' +
                ", destination='" + destination + '\'' +
                ", flight_date=" + flight_date +
                '}';
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getNumber() {
        return number;
    }

    public void setNumber(String number) {
        this.number = number;
    }

    public String getDestination() {
        return destination;
    }

    public void setDestination(String destination) {
        this.destination = destination;
    }

    public String getFlight_date() {
        return flight_date;
    }

    public void setFlight_date(String flight_date) {
        this.flight_date = flight_date;
    }
}

4. Dao 类

AirInfoDao.java
/**
 * 航班功能接口
 */
public interface AirInfoDao {
    /**
     * 查询所有航班
     * @return
     */
    public List<AirInfo> findAll();

    /**
     * 根据起飞时间查询航班
     * @param flight_date
     * @return
     */
    public List<AirInfo> findByDate(String flight_date);

    /**
     * 根据目的地查询航班
     * @param destination
     * @return
     */
    public List<AirInfo> findByDestination(String destination);

    /**
     * 根据航班号查询航班
     * @param number
     * @return
     */
    public AirInfo findByNumber(String number);

    /**
     * 删除航班
     * @param id
     * @return
     */
    public boolean deleteFlight(int id);

    /**
     * 更新航班
     * @param id
     * @param newNumber
     * @param newDestin
     * @param newDate
     * @return
     */
    public boolean updateFlight(int id, String newNumber, String newDestin, String newDate);

    public AirInfo findById(int id);
}
AirInfoDaoImpl.java
@SuppressWarnings("all")
public class AirInfoDaoImpl extends DBUtils implements AirInfoDao {
    /**
     * 列出所有航班
     * @return
     */
    @Override
    public List<AirInfo> findAll() {
        try {
            String sql = "select * from airinfo";
            List<AirInfo> airInfos = new ArrayList<>();
            ResultSet rs = query(sql,airInfos);
            while (rs.next()){
                AirInfo airInfo = new AirInfo();
                airInfo.setId(rs.getInt(1));
                airInfo.setNumber(rs.getString(2));
                airInfo.setDestination(rs.getString(3));
                airInfo.setFlight_date(rs.getString(4));

                airInfos.add(airInfo);
            }
            return airInfos;
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            closeAll();
        }

        return null;
    }

    /**
     * 根据起飞时间查找
     * @param flight_date
     * @return
     */
    @Override
    public List<AirInfo> findByDate(String flight_date) {
        try {
            String sql = "select * from airinfo where flight_date = ?";
            List list = new ArrayList();
            list.add(flight_date);
            List<AirInfo> airInfos = new ArrayList<>();
            ResultSet rs = query(sql,list);

            while (rs.next()){
                AirInfo airInfo = new AirInfo();
                airInfo.setId(rs.getInt(1));
                airInfo.setNumber(rs.getString(2));
                airInfo.setDestination(rs.getString(3));
                airInfo.setFlight_date(rs.getString(4));

                airInfos.add(airInfo);
            }
            return airInfos;
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            closeAll();
        }
        return null;
    }

    /**
     * 根据目的地查找
     * @param destination
     * @return
     */
    @Override
    public List<AirInfo> findByDestination(String destination) {
        try {
            String sql = "select * from airinfo where destination = ?";
            List list = new ArrayList();
            list.add(destination);
            List<AirInfo> airInfos = new ArrayList<>();
            ResultSet rs = query(sql,list);

            while (rs.next()){
                AirInfo airInfo = new AirInfo();
                airInfo.setId(rs.getInt(1));
                airInfo.setNumber(rs.getString(2));
                airInfo.setDestination(rs.getString(3));
                airInfo.setFlight_date(rs.getString(4));

                airInfos.add(airInfo);
            }
            return airInfos;
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            closeAll();
        }
        return null;
    }

    /**
     * 根据航班号查找
     * @param number
     * @return
     */
    @Override
    public AirInfo findByNumber(String number) {
        AirInfo airInfo = new AirInfo();
        try {
            String sql = "select * from airinfo where number = ?";
            List list = new ArrayList();
            list.add(number);
            ResultSet rs = query(sql,list);
            while (rs.next()){
                airInfo.setId(rs.getInt(1));
                airInfo.setNumber(rs.getString(2));
                airInfo.setDestination(rs.getString(3));
                airInfo.setFlight_date(rs.getString(4));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            closeAll();
        }
        return airInfo;
    }

    /**
     * 删除航班
     * @param number
     * @return
     */
    @Override
    public boolean deleteFlight(int id) {
        String sql = "delete from airinfo where id = ?";
        List list = new ArrayList();
        list.add(id);
        int result = update(sql,list);
        if (result != 0){
            return true;
        }else
            return false;
    }

    /**
     * 更新航班
     * @param number
     * @param airInfo
     * @return
     */
    @Override
    public boolean updateFlight(int id, String newNumber, String newDestin, String newDate) {
        String sql = "update airinfo set number = ?, destination = ?, flight_date = ? where id = ?";
        List list = new ArrayList();
        list.add(newNumber);
        list.add(newDestin);
        list.add(newDate);
        list.add(id);
        int result = update(sql,list);
        if (result == 1){
            return true;
        }else
            return false;
    }

    @Override
    public AirInfo findById(int id) {
        AirInfo airInfo = new AirInfo();
        try {
            String sql = "select * from airinfo where id = ?";
            List list = new ArrayList();
            list.add(id);
            ResultSet rs = query(sql,list);
            while (rs.next()){
                airInfo.setId(rs.getInt(1));
                airInfo.setNumber(rs.getString(2));
                airInfo.setDestination(rs.getString(3));
                airInfo.setFlight_date(rs.getString(4));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            closeAll();
        }
        return airInfo;
    }
}

5. 自定义 Exception

OutNumberBoundException.java
public class OutNumberBoundException extends Throwable{
    public OutNumberBoundException(String s){
        super(s);
    }
}

6. View 类

AirView.java
/**
 * 视图
 */
public class AirView {
    private Scanner input = new Scanner(System.in);
    private AirInfoDao dao = new AirInfoDaoImpl();

    public void menu(){
        int num = 0;
        do {
            System.out.println("********** 欢迎使用航班信息管理系统 **********" + "\n");
            System.out.println("请选择操作（1. 列出所有航班，2. 按起飞时间查询，3. 按目的地查询，4. 按航班号查询" +
                    "，5. 删除航班，6." +
                    " 更新航班，7. 离开系统）：");
            String text = input.next();
            try{
                num = validateNum(text,1,7);
                break;
            } catch (OutNumberBoundException e) {
                System.err.println(e.getMessage());
            }
        } while (true);

        switch (num) {
            case 1:
                doFindAll();
                break;
            case 2:
                doFindByDate();
                break;
            case 3:
                doFindByDes();
                break;
            case 4:
                doFindByNumber();
                break;
            case 5:
                doDelete();
                break;
            case 6:
                doUpdate();
                break;
            case 7:
                System.out.println("欢迎下次使用～");
                System.exit(0);
                break;
        }
    }

    /**
     * 验证用户输入是否合法
     * @param strNum
     * @param begin
     * @param end
     * @return
     * @throws OutNumberBoundException
     */
    private int validateNum(String strNum, int begin, int end) throws OutNumberBoundException {
        try {
            int num = Integer.valueOf(strNum);
            if (num < begin || num > end){
                throw new OutNumberBoundException("数字的范围必须在" + begin + "和" + end + "之间！");
            }
            return num;
        } catch (NumberFormatException e){
            throw new NumberFormatException("输入的必须是数字！");
        }
    }

    /**
     * 展示所有航班信息的方法
     */
    public void doFindAll(){
        dao = new AirInfoDaoImpl();
        List<AirInfo> airInfos = dao.findAll();
        printAll(airInfos);
    }

    /**
     * 根据航班起飞日期寻找
     */
    public void doFindByDate(){
        System.out.println("请输入日期：");
        String day = input.next();
        List<AirInfo> airInfos = dao.findByDate(day);
        printAll(airInfos);
    }

    /**
     * 根据目的地查找
     */
    public void doFindByDes(){
        System.out.println("请输入目的地：");
        String des = input.next();
        List<AirInfo> airInfos = dao.findByDestination(des);
        printAll(airInfos);
    }

    /**
     * 根据航班号查找
     */
    public void doFindByNumber(){
        System.out.println("请输入航班号：");
        String number = input.next();
        AirInfo airInfo = dao.findByNumber(number);
        System.out.println("编号\t\t航班号\t\t\t目的地\t\t\t\t\t\t起飞日期");
        System.out.println(airInfo.getId()+"\t\t"+airInfo.getNumber()
                +"\t\t\t"+airInfo.getDestination()+"\t\t\t\t"+airInfo.getFlight_date());
    }

    /**
     * 打印信息
     * @param airInfos
     */
    public void printAll(List<AirInfo> airInfos){
        System.out.println("编号\t\t航班号\t\t\t目的地\t\t\t\t\t\t起飞日期");
        for (AirInfo airInfo : airInfos) {
            System.out.println(airInfo.getId()+"\t\t"+airInfo.getNumber()
                    +"\t\t\t"+airInfo.getDestination()+"\t\t\t\t"+airInfo.getFlight_date());
        }
    }

    /**
     * 执行删除操作
     */
    public void doDelete(){
        System.out.println("请输入需要删除的航班编号：");
        int id1 = input.nextInt();
        boolean flag = dao.deleteFlight(id1);
        if (flag == true){
            System.out.println("删除成功！");
        } else {
            System.out.println("不存在该航班信息！请检查您的输入");
        }
    }

    /**
     * 执行更新操作
     */
    public void doUpdate(){
        while (true) {
            System.out.println("请输入需要更新的航班编号：");
            int id2 = input.nextInt();
            if (doFindById(id2) == 0){
                System.out.println("不存在该航班信息！请检查您的输入");
                break;
            }
            System.out.println("请输入新的航班号：");
            String newNumber = input.next();
            System.out.println("请输入新的目的地：");
            String newDes = input.next();
            System.out.println("请输入新的起飞日期：");
            String newDate = input.next();
            boolean flag = dao.updateFlight(id2, newNumber, newDes, newDate);
            if (flag == true){
                System.out.println("更新成功！");
                break;
            } else {
                System.out.println("操作失败！请检查您的输入");
            }
            break;
        }
    }

    /**
     * 根据编号查找
     * @param id
     * @return
     */
    public int doFindById(int id){
        AirInfo airInfo = dao.findById(id);
        int num = airInfo.getId();
        return num;
    }
}

7. Main 类

Main.java
public class Main {
    /**
     * 主程序
     * @param args
     */
    public static void main(String[] args) {
        AirView airView = new AirView();
        while (true){
            airView.menu();
            System.out.println();
        }
    }
}

8. 小结

  • 至此，基本实现根据上文需求所述的基于Java的航班信息管理系统，若出现BUG，还请批评指正，谢谢！

标签：JDBC,return,String,getString,rs,航班,信息管理系统,public,airInfo
来源： https://blog.csdn.net/chrismurphy/article/details/116206220

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

关于我们 | 联系我们 | 留言反馈

专注分享技术，共同学习，共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有