JAVA GUI火车票管理系统（JAVA+MySQL）

package dao; import bean.*; import java.sql.ResultSet; import java.sql.SQLException; import java.util.*; public class MySQLDAO implements CustomerDAO, ManagerDAO, StationDAO, TicketPointDAO, TrainDAO, TrainOrderDAO, TrainScheduleDAO { @SuppressWarnings("WeakerAccess") public ResultSet query(String sql){ return MySQLManager.getInstance().execute(sql).query(); } @SuppressWarnings("WeakerAccess") public int[] update(String sql){ return MySQLManager.getInstance().execute(sql).update(); } @SuppressWarnings("WeakerAccess") public ResultSet query(String sql, Object ... params){ if(params == null || params.length == 0) return query(sql); return MySQLManager.getInstance().prepare(sql, params).query(); } @SuppressWarnings("WeakerAccess") public int[] update(String sql, Object ... params){ if(params == null || params.length == 0) return update(sql); return MySQLManager.getInstance().prepare(sql, params).update(); } private interface Parser<T> { T parse(ResultSet res) throws SQLException; } private class Loader<T> { private Parser<T> parser; Loader(Parser<T> parser) { this.parser = parser; } List<T> load(String sql, Object... params) { List<T> rows = new ArrayList<>(); try { try (ResultSet res = query(sql, params)) { while (res.next()) { rows.add(parser.parse(res)); } } return rows; } catch (SQLException e) { e.printStackTrace(); return rows; } } T loadOne(String sql, Object... params) { T row = null; try { try (ResultSet res = query(sql, params)) { if (res.next()) { row = parser.parse(res); } } return row; } catch (SQLException e) { e.printStackTrace(); return row; } } } @Override public void insertManager(Manager manager) { update("insert into manager " + "(point_id, username, password, name, sex, manager_type) values " + "(?, ?, ?, ?, ?, ?)", manager.getPointId(), manager.getUsername(), manager.getPassword(), manager.getName(), manager.getSex(), manager.getManagerType() ); } @Override public void deleteManager(Manager manager) { update("delete from manager where manager_id = ?", manager.getManagerId()); } @Override public void updateManager(Manager manager) { update("update manager set point_id = ?, username = ?, password = ?, name = ?, sex = ?, manager_type = ?" + " where manager_id = ?", manager.getPointId(), manager.getUsername(), manager.getPassword(), manager.getName(), manager.getSex(), manager.getManagerType(), manager.getManagerId()); } public void modifyPassword(Manager manager, String password) { manager.setPassword(password); updateManager(manager); } private Manager getManagerFromResult(ResultSet res) throws SQLException { Manager manager = new Manager(); manager.setManagerId(res.getInt("manager_id")); manager.setManagerType(res.getInt("manager_type")); manager.setName(res.getString("name")); manager.setPassword(res.getString("password")); manager.setPointId(res.getInt("point_id")); manager.setSex(res.getInt("sex")); manager.setUsername(res.getString("username")); return manager; } @Override public Manager getManagerById(String manager_id) { return new Loader<>(this::getManagerFromResult) .loadOne("select * from manager where manager_id = ?", manager_id); } @Override public List<Manager> getAllManagers() { return new Loader<>(this::getManagerFromResult) .load("select * from manager"); } @Override public List<Manager> searchManagers(String key) { key = '%' + key + '%'; return new Loader<>(this::getManagerFromResult) .load("select * from manager where manager_id = ? or name like ? or username like ?" + " or point_id = ?", key, key, key, key); } @SuppressWarnings("WeakerAccess") public Manager getManagerByUsername(String username) { return new Loader<>(this::getManagerFromResult) .loadOne("select * from manager where username = ?", username); } @Override public Manager login(String username, String password) { Manager manager = getManagerByUsername(username); if(manager != null && manager.getPassword().equals(password)){ return manager; } return null; } @Override public void insertCustomer(Customer customer) { update("insert into customer " + "(name, sex, id_num, tel, customer_type) values " + "(?, ?, ?, ?, ?)", customer.getName(), customer.getSex(), customer.getIdNum(), customer.getTel(), customer.getCustomerType() ); } @Override public void deleteCustomer(Customer customer) { update("delete from customer where id_num = ?", customer.getIdNum()); } @Override public void updateCustomer(Customer customer) { update("update customer set name = ?, sex = ?, tel = ?, customer_type = ?" + " where id_num = ?", customer.getName(), customer.getSex(), customer.getTel(), customer.getCustomerType(), customer.getIdNum()); } @Override public void upsertCustomer(Customer customer) { Customer c = getCustomerByIdNum(customer.getIdNum()); if (c == null) { insertCustomer(customer); } else { updateCustomer(customer); } } private Customer getCustomerFromResult(ResultSet res) throws SQLException { Customer customer = new Customer(); customer.setIdNum(res.getString("id_num")); customer.setName(res.getString("name")); customer.setTel(res.getString("tel")); customer.setSex(res.getInt("sex")); customer.setCustomerType(res.getInt("customer_type")); return customer; } @Override public Customer getCustomerByIdNum(String id_num) { return new Loader<>(this::getCustomerFromResult) .loadOne("select * from customer where id_num = ?", id_num); } @Override public List<Customer> searchCustomers(String key) { key = '%' + key + '%'; return new Loader<>(this::getCustomerFromResult) .load("select * from customer where id_num like ? or name like ? or tel = ?", key, key, key); } @Override public List<Customer> getAllCustomers() { return new Loader<>(this::getCustomerFromResult) .load("select * from customer"); } public int getSexFromIdNum(String idNum) { if (idNum.length() == 18) { return (idNum.charAt(16) - '0') % 2; } return 0; } @Override public void insertStation(Station station) { update("insert into station " + "(station_name) values " +