航空管理系统数据库设计与实现 - Ticketdao和Userdao
1 数据库部分
1.1 Ticketdao部分
package Aviation.Mangerment.system.dao;
import Aviation.Mangerment.system.entity.Ticket;
import Aviation.Mangerment.system.utils.DBUtils;
import java.util.List;
public class Tiketdao {
public boolean insert(Ticket tick){
String sql='insert into ticket(id,aircraftid,time,from_location,to_location,seatCount,seatType,fare,vipfare)values(?,?,?,?,?,?,?,?,?)';
return DBUtils.insert(sql,
tick.getId(),
tick.getAircraftid(),
tick.getTime(),
tick.getFrom_location(),
tick.getTo_location(),
tick.getSeatCount(),
tick.getSeatType(),
tick.getFare(),
tick.getVipfare()
);
}
public boolean deleteById(String aircraftId){
String sql='delete from ticket where aircraftid=?';
return DBUtils.delete(sql,aircraftId);
}
public boolean update(Ticket tick){
String sql='update ticket set fare=?,vipfare=?,time=? where aircraftid=?';
return DBUtils.update(sql,tick.getFare(),tick.getVipfare(),tick.getTime(),tick.getAircraftid());
}
public List<Ticket> selectAll(){
String sql='select * from ticket';
return DBUtils.queryList(Ticket.class,sql);
}
public List<Ticket> selectSeatTybe(long SeatTybe){
String sql='select * from ticket where SeatType=?';
return DBUtils.queryList(Ticket.class,sql,SeatTybe);
}
public Ticket selectaircraftId(String aircraftId){
String sql='select *from ticket where aircraftid=?';
return DBUtils.queryOne(Ticket.class,sql,aircraftId);
}
public Ticket selectById(int id) {
String sql='select * from ticket where id=?';
return DBUtils.queryOne(Ticket.class,sql,id);
}
public boolean update(int id,int seatType){
String sql='update ticket set seatType=? where id=?';
return DBUtils.update(sql,seatType,id);
}
public List<Ticket> selectlocation(String to_location){
String sql='select * from ticket where to_location=?';
return DBUtils.queryList(Ticket.class,sql,to_location);
}
}
1.2 Userdao部分
package Aviation.Mangerment.system.dao;
import Aviation.Mangerment.system.entity.Ticket;
import Aviation.Mangerment.system.entity.User;
import Aviation.Mangerment.system.utils.DBUtils;
import java.util.List;
public class Userdao {
public User selectByUsername(String username){
String sql = 'select * from user where username=?';
User user = DBUtils.queryOne(User.class, sql, username);
return user;
}
public User selectById(int id){
String sql = 'select * from user where id=?';
return DBUtils.queryOne(User.class,sql,id);
}
public boolean insert(User user){
String sql = 'insert into user(username,password) values(?,?)';
return DBUtils.insert(sql,user.getUsername(),user.getPassword());
}
public boolean updatePwd(User user){
String sql = 'update user set password=? where id=?';
return DBUtils.update(sql,user.getPassword(),user.getId());
}
public boolean updateRole(User user){
String sql = 'update user set role=? where id=?';
return DBUtils.update(sql,user.getRole(),user.getId());
}
//查看所有航班
public List selectALl(){
String sql='select *from user';
return DBUtils.queryList(User.class,sql);
}
public List selectUsername(String username){
String sql = 'select * from user where username=?';
return DBUtils.queryList(User.class,sql,username);
}
}
2 Service部分
2.1 User部分
package Aviation.Mangerment.system.services;
import Aviation.Mangerment.system.dao.Tiketdao;
import Aviation.Mangerment.system.dao.Userdao;
import Aviation.Mangerment.system.entity.Result;
import Aviation.Mangerment.system.entity.Ticket;
import Aviation.Mangerment.system.entity.User;
import javax.management.relation.RelationSupport;
import java.util.List;
public class Tikenservices {
private Tiketdao tick1 = new Tiketdao();
//添加航班
public Result addticket(Ticket tick) {
Ticket t1 = tick1.selectaircraftId(tick.getAircraftid());
if (t1 != null) {
return Result.fail().msg('该飞机表已存在');
}
//执行添加
boolean b = tick1.insert(tick);
if (b) {
return Result.ok().msg('添加成功');
}
return Result.fail().msg('添加失败');
}
//查询所有航班
public Result listTicket() {
List<Ticket> list = tick1.selectAll();
if (list.size() < 1) {
return Result.fail().msg('没有该飞机票记录');
}
return Result.ok().data(list);
}
//查询特定的航班
public Result queryByaircraftId(String aircaraftId) {
Ticket t2 = tick1.selectaircraftId(aircaraftId);
if (t2 == null) {
return Result.fail().msg('没有该飞机航班');
}
return Result.ok().msg('有该飞机航班');
}
public Result queryBylocation(String to_Location){
List<Ticket> list=tick1.selectlocation(to_Location);
if(list.size()<1){
return Result.fail().msg('没有该地方');
}
return Result.ok().data(list);
}
//删除特定的航班
public Result deleteByaircraftId(String aircaraftId) {
boolean b = tick1.deleteById(aircaraftId);
if (b) {
return Result.ok().msg('删除成功');
}
return Result.fail().msg('删除失败');
}
//跟改座位等级
public Result changeseatType(int seatType, int id) {
Ticket t2 = tick1.selectById(id);
if (t2 == null) {
return Result.fail().msg('该人不存在');
}
boolean b = tick1.update(id, seatType);
if (b) {
return Result.ok().msg('修改成功');
}
return Result.fail().msg('修改失败');
}
public Result update(Ticket ticket) {
Ticket t3 = tick1.selectaircraftId(ticket.getAircraftid());
if (t3 == null) {
return Result.fail().msg('该航班不存在');
}
boolean b = tick1.update(ticket);
if (b) {
return Result.ok().msg('修改成功!');
}
return Result.fail().msg('修改失败');
}
}
2.2 Ticket部分
package Aviation.Mangerment.system.services;
import Aviation.Mangerment.system.entity.Ticket;
import Aviation.Mangerment.system.entity.User;
import Aviation.Mangerment.system.dao.Userdao;
import Aviation.Mangerment.system.entity.Result;
import java.util.List;
public class UserServices {
private Userdao userdao=new Userdao();
//用户登陆
public Result login(String name, String pwd){
User user = userdao.selectByUsername(name);
if(user == null){
return Result.fail().msg('用户不存在');
}
if(!user.getPassword().equals(pwd)){
return Result.fail().msg('密码错误');
}
return Result.ok().msg('登录成功').data(user);
}
//修改密码
public Result updatePwd(User user){
User u = userdao.selectByUsername(user.getUsername());
if(u == null){
return Result.fail().msg('用户不存在');
}
boolean b = userdao.updatePwd(user);
if(b){
return Result.ok().msg('修改成功!');
}
return Result.fail().msg('修改失败');
}
//添加用户
public Result add(String name,String pwd){
User user = userdao.selectByUsername(name);
if(user != null){
return Result.fail().msg('该用户已存在!');
}
//创建用户对象
user = new User();
user.setUsername(name);
user.setPassword(pwd);
boolean b = userdao.insert(user);
if(b){
return Result.ok().msg('添加成功');
}
return Result.fail().msg('添加失败');
}
public Result listUser(){
List<User> list=userdao.selectALl();
if(list.size()<1){
return Result.fail().msg('查询失败');
}
return Result.ok().data(list);
}
public Result querypersionsal(String username) {
List<User> list=userdao.selectUsername(username);
if (list == null) {
return Result.fail().msg('没有该用户');
}
return Result.ok().msg('有该用户').data(list);
}
}
原文地址: https://www.cveoy.top/t/topic/isxz 著作权归作者所有。请勿转载和采集!