本文实例为大家分享了java实现航空航班管理系统的具体代码，供大家参考，具体内容如下
plane对象：
在plane对象里定义了飞机的编号id、航班号、目的地、起飞日期。生成了构造方法和tostring()方法；以及getting()和setting()方法，但在程序里没用到。
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;
}
}
mysql数据库：
数据库名字是fly，数据表是plane；在getcon()函数中注册驱动、获取连接
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');
主程序testfly:
testfly类中有实现各种功能的函数，包括 1.列出所有航班，2.按起飞时间查询，3.按目的地查询，4.删除航班，5.更新航班，6.增加航班，7.退出系统。
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);
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持www.887551.com。
黄山市民网：https://www.huangshanshimin.com/
