航班信息管理系统

项目背景：现在有一家航空公司为了提高用户体验，希望做一个航班信息系统，用户可以根据需求去对航班信息进行操作。组长把这个任务安排给了程序员赵丹，赵丹发现这里需要通过 java 代码操作数据库，并且用户是可以在控制台做对应的操作，JDBC 可以帮她解决这个问题。学习起来，试着把这个系统实现出来。

考察内容：sql语句的使用 + 使用 JDBC操作 MySQL + Dao模式

任务过程

创建数据库表 airinfo，添加测试数据不少于 4 条，要求主键自增。
创建实体类 AirInfo，根据业务提供需要的构造方法和 setter/getter方法。
创建 BaseDao 类，实现数据库连接和关闭功能。
创建 Dao 接口 AirInfoDao，定义查询所有航班，按日期和目的地查询航班，删除航班，更新航班的方法。
创建 Dao 实现类 AirInfoDaoImpl，继承BaseDao类，实现AirInfoDao接口，使用 JDBC 完成相应数据库操作。
创建 Main 类，完成在控制台显示留言信息和用户添加留言操作，启动和运行系统。

项目模块分析如图

1. db.properties文件配置

driver=com.mysql.cj.jdbc.Driver
uname=root
upass=root
url=jdbc:mysql://localhost:3306/kkb03

需要将文件放在src目录下

2. 导入jar包

这里用的是阿里出品，淘宝和支付宝专用数据库连接池——Druid(德鲁伊)连接池

数据库操作

1. 创建airinfo表

2. 插入数据

代码实现如下

1. AifInfo类

import java.util.Date;

// 航班实体类
public class AirInfo {private int id;private String number;private String destination;private Date 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 Date getDate() {return date;}public void setDate(Date date) {this.date = date;}
}

2. BaseDao工具类

import com.alibaba.druid.pool.DruidDataSource;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.ResourceBundle;

// 工具类
public class BaseDao {// 1.定义变量private Connection connection;private PreparedStatement pps;private ResultSet resultSet;private int count;// 储存受影响的行数private static String dirverName;private static String url;private static String userName;private static String userPass;private static DruidDataSource druidDataSource = new DruidDataSource();// 阿里Druid连接池// 2.加载驱动static {/*** 阿里的数据库连接池* 性能最好的* Druid* (博主是阿里忠实粉丝)*/ResourceBundle bundle = ResourceBundle.getBundle("db");// 参数只写属性文件名即可，不需要写后缀dirverName = bundle.getString("driver");url = bundle.getString("url");userName = bundle.getString("uname");userPass = bundle.getString("upass");druidDataSource.setUsername(userName);druidDataSource.setPassword(userPass);druidDataSource.setUrl(url);druidDataSource.setDriverClassName(dirverName);druidDataSource.setTestWhileIdle(false);}// 3.获得链接protected Connection getConnection(){try {connection = druidDataSource.getConnection();} catch (SQLException throwables) {throwables.printStackTrace();}return connection;}// 4.得到预状态通道protected PreparedStatement getPps(String sql){try {pps = getConnection().prepareStatement(sql);} catch (SQLException throwables) {throwables.printStackTrace();}return pps;}// 5.绑定参数 (List保存的是给占位符所赋的值)protected void param(List list){if (list != null && list.size() > 0) {for (int i = 0; i < list.size(); i++) {try {pps.setObject(i + 1, list.get(i));// 列的行数为i+1} catch (SQLException throwables) {throwables.printStackTrace();}}}}// 6.执行操作（增删改 + 查）public int update(String sql, List list){getPps(sql);param(list);try {count = pps.executeUpdate();} catch (SQLException throwables) {throwables.printStackTrace();}return count;}// 7.查询protected ResultSet query(String sql, List list){getPps(sql);param(list);try {resultSet = pps.executeQuery();} catch (SQLException throwables) {throwables.printStackTrace();}return resultSet;}// 8.关闭资源protected void closeAll(){try {if (resultSet != null) {resultSet.close();}if (pps != null) {pps.close();}if (connection != null) {connection.close();}} catch (SQLException throwables) {throwables.printStackTrace();}}
}

3. AirInfoDao接口

// 将同一包下的子包中的类导入进来，这行代码需自行导包，不能直接复制

import mission.demo03.bean.AirInfo;

import java.util.List;

// Dao接口
public interface AirInfoDao {/*** 1.列出所有航班* @return*/public List<AirInfo> getAll();/*** 2.按起飞时间查询* @param date* @return*/public List<AirInfo> getByDate(String date);/*** 3.按目的地查询* @param destination* @return*/public List<AirInfo> getByDestination(String destination);/*** 4.删除航班* @param id* @return*/public Boolean delete(int id);/*** 5.更新航班* @param id* @return*/public Boolean update(int id, String newNumber, String newDestination, String newDate);/*** 6.离开系统*/public void bye();/*** 根据编号查找航班* @param id* @return*/public AirInfo getById(int id);
}

4. AirInfoDaoImpl实现类

// 将同一包下的子包中的类导入进来，这三行代码需自行导包，不能直接复制

import mission.demo03.bean.AirInfo;
import mission.demo03.dao.AirInfoDao;
import mission.demo03.util.BaseDao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

// Dao实现类
public class AirInfoDaoImpl extends BaseDao implements AirInfoDao {/*** 1.列出所有航班* @return*/@Overridepublic List<AirInfo> getAll() {List<AirInfo> airInfoList = new ArrayList<>();try {String sql = "select * from airinfo";List list = new ArrayList();ResultSet rs = query(sql, list);while (rs.next()) {AirInfo airInfo = new AirInfo();airInfo.setId(rs.getInt("id"));airInfo.setNumber(rs.getString("number"));airInfo.setDestination(rs.getString("destination"));airInfo.setDate(rs.getDate("date"));airInfoList.add(airInfo);}return airInfoList;} catch (SQLException throwables) {throwables.printStackTrace();}finally {closeAll();}return null;}/*** 2.按起飞时间查询* @param date* @return*/@Overridepublic List<AirInfo> getByDate(String date) {try {String sql = "select * from airinfo where date = ?";List list = new ArrayList();list.add(date);List<AirInfo> airInfoList = new ArrayList<>();ResultSet rs = query(sql, list);while (rs.next()){AirInfo airInfo = new AirInfo();airInfo.setId(rs.getInt("id"));airInfo.setNumber(rs.getString("number"));airInfo.setDestination(rs.getString("destination"));airInfo.setDate(rs.getDate("date"));airInfoList.add(airInfo);}return airInfoList;} catch (SQLException throwables) {throwables.printStackTrace();} finally {closeAll();}return null;}/*** 3.按目的地查询* @param destination* @return*/@Overridepublic List<AirInfo> getByDestination(String destination) {try {String sql = "select * from airinfo where destination = ?";List list = new ArrayList();list.add(destination);List<AirInfo> airInfoList = new ArrayList<>();ResultSet rs = query(sql, list);while (rs.next()){AirInfo airInfo = new AirInfo();airInfo.setId(rs.getInt("id"));airInfo.setNumber(rs.getString("number"));airInfo.setDestination(rs.getString("destination"));airInfo.setDate(rs.getDate("date"));airInfoList.add(airInfo);}return airInfoList;} catch (SQLException throwables) {throwables.printStackTrace();} finally {closeAll();}return null;}/*** 4.删除航班* @param id* @return*/@Overridepublic Boolean delete(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;}elsereturn false;}/*** 5.更新航班* @param id* @param newNumber* @param newDestination* @param newDate* @return*/@Overridepublic Boolean update(int id, String newNumber, String newDestination, String newDate) {String sql = "update airinfo set number = ?, destination = ?, date = ? where id = ?";List list = new ArrayList();list.add(newNumber);list.add(newDestination);list.add(newDate);list.add(id);int result = update(sql,list);if (result == 1){return true;}elsereturn false;}/*** 6.离开系统*/@Overridepublic void bye() {System.out.println("--------感谢您的使用 再见！--------");System.exit(0);}/*** 根据编号查找航班* @param id* @return*/@Overridepublic AirInfo getById(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("id"));airInfo.setNumber(rs.getString("number"));airInfo.setDestination(rs.getString("destination"));airInfo.setDate(rs.getDate("date"));}} catch (Exception e) {e.printStackTrace();} finally {closeAll();}return airInfo;}
}

5. AirView类

// 将同一包下的子包中的类导入进来，这三行代码需自行导包，不能直接复制

import mission.demo03.bean.AirInfo;
import mission.demo03.dao.impl.AirInfoDaoImpl;
import mission.demo03.exception.OutNumberBoundException;

import java.util.List;
import java.util.Scanner;

//视图展示的view
public class AirView {private Scanner sc = new Scanner(System.in);private AirInfoDaoImpl airInfoDao = new AirInfoDaoImpl();private AirInfo airInfo = new AirInfo();public int menu(){welcome();int num = 0;system:while (true) {System.out.println("请选择操作(1.列出所有航班,2.按起飞时间查询,3.按目的地查询,4.删除航班,5.更新航班,6.离开系统):");String input = sc.next();try {num = validNum(input, 1, 6);switch (num) {case 1:doGetAll();break;case 2:doGetByDate();break;case 3:doGetByDestination();break;case 4:doDelete();break;case 5:doUpdate();break;case 6:doBye();break system;}} catch (NumberFormatException | OutNumberBoundException e) {System.out.println(e.getMessage());}}return num;}/*** 欢迎界面*/private void welcome(){System.out.println("--------欢迎使用航班信息管理系统--------");}/*** 判断输入的数字是否正确* @param s* @param begin* @param end* @return* @throws NumberFormatException* @throws OutNumberBoundException*/private static int validNum(String s,int begin,int end) throws NumberFormatException, OutNumberBoundException {try{int num = Integer.parseInt(s);if (num < begin || num > end){throw new OutNumberBoundException("数字的范围必须在" + begin + "和" + end +"之间");}return num;}catch(NumberFormatException e){throw new NumberFormatException("输入的必须是数字！");}}/*** 根据编号查找航班* @param id* @return*/private int doGetById(int id){AirInfo airInfo = airInfoDao.getById(id);int num = airInfo.getId();return num;}/*** 打印信息* @param airInfoList*/private void printAll(List<AirInfo> airInfoList){if (airInfoList != null && airInfoList.size() != 0) {System.out.println("编号\t\t航班号\t\t目的地\t\t起飞日期");for (AirInfo airInfo : airInfoList) {System.out.println(airInfo.getId() + "\t\t" + airInfo.getNumber()+ "\t\t\t" + airInfo.getDestination() + "\t\t\t" + airInfo.getDate());}}else {System.out.println("暂无相关航班信息!");}}/*** 列出所有航班*/private void doGetAll() {List<AirInfo> airInfoList = airInfoDao.getAll();printAll(airInfoList);}/*** 按起飞时间查询*/private void doGetByDate() {System.out.print("请输入日期:");String input = sc.next();List<AirInfo> airInfoList = airInfoDao.getByDate(input);printAll(airInfoList);}/*** 按目的地查询*/private void doGetByDestination() {System.out.print("请输入目的地:");String input = sc.next();List<AirInfo> airInfos = airInfoDao.getByDestination(input);printAll(airInfos);}/*** 删除航班*/private void doDelete() {System.out.print("请输入需要删除的航班编号:");int input = sc.nextInt();boolean flag = airInfoDao.delete(input);if (flag == true){System.out.println("删除成功！");} else {System.out.println("该航班信息不存在！");}}/*** 更新航班*/private void doUpdate() {while (true) {System.out.print("请输入需要更新的航班编号:");int input = sc.nextInt();if (doGetById(input) == 0){System.out.println("不存在该航班信息！");break;}System.out.print("请输入新的航班号:");String newNumber = sc.next();System.out.print("请输入新的目的地:");String newDes = sc.next();System.out.print("请输入新的起飞日期:");String newDate = sc.next();boolean flag = airInfoDao.update(input, newNumber, newDes, newDate);if (flag == true){System.out.println("更新成功！");break;} else {System.out.println("操作失败！请检查您的输入");}break;}}/*** 离开系统*/private void doBye() {airInfoDao.bye();}
}

6. Exception自定义异常类

// 自定义异常类
public class OutNumberBoundException extends RuntimeException{public OutNumberBoundException(String s) {super(s);}
}

7. Main类