Java大数据期末：银行管理系统(MySQL数据库)

package hello; import java.sql.SQLException; public class Customer { // 连接数据库并打印操作界面 static void displayMenu(hello.Main.Inter in) { // 定义循环变量 boolean isRunning = true; while (isRunning) { System.out.println("----- 操作界面 -----"); System.out.println("1. 存款"); System.out.println("2. 取款"); System.out.println("3. 转账"); System.out.println("4. 修改密码"); System.out.println("5. 退出"); System.out.println("--------------------"); System.out.print("请输入选项数字: "); int choice = in.scanner.nextInt(); in.scanner.nextLine(); switch (choice) { case 1: DepositMoney(in); break; case 2: WithdrawMoney(in); break; case 3: TransferAccounts(in); break; case 4: ChangePassword(in); break; case 5: System.out.println("退出功能："); isRunning = false; break; default: System.out.println("无效的选项，请重新输入。"); break; } } in.account=null; } // 存款函数 private static void DepositMoney(hello.Main.Inter in) { try { // 获取用户输入的存款金额 System.out.println("请输入存款金额："); double depositAmount = in.scanner.nextDouble(); // 查询顾客表中对应账号的数据 String selectSql = "SELECT * FROM customer WHERE account_number = ?"; in.preparedStatement = in.conn.prepareStatement(selectSql); in.preparedStatement.setString(1, in.account); in.resultSet = in.preparedStatement.executeQuery(); // 如果有匹配的账号 if (in.resultSet.next()) { // 获取当前余额 double currentBalance = in.resultSet.getDouble("balance"); // 更新余额 String updateSql = "UPDATE customer SET balance = ? WHERE account_number = ?"; in.preparedStatement = in.conn.prepareStatement(updateSql); in.preparedStatement.setDouble(1, currentBalance + depositAmount); in.preparedStatement.setString(2, in.account); // 执行更新 in.preparedStatement.executeUpdate(); // 输出更新后的行数 System.out.println("存款成功，当前余额：" + (currentBalance + depositAmount)); } else { System.out.println("未找到匹配的账号。"); } } catch (SQLException e) { e.printStackTrace(); } } // 取款函数 private static void WithdrawMoney(hello.Main.Inter in) { try { // 获取用户输入的存款金额 System.out.println("请输入取款金额："); double depositAmount = in.scanner.nextDouble(); // 查询顾客表中对应账号的数据 String selectSql = "SELECT * FROM customer WHERE account_number = ?"; in.preparedStatement = in.conn.prepareStatement(selectSql); in.preparedStatement.setString(1, in.account); in.resultSet = in.preparedStatement.executeQuery(); // 如果有匹配的账号 if (in.resultSet.next()) { // 获取当前余额 double currentBalance = in.resultSet.getDouble("balance"); // 更新余额 String updateSql = "UPDATE customer SET balance = ? WHERE account_number = ?"; in.preparedStatement = in.conn.prepareStatement(updateSql); in.preparedStatement.setDouble(1, currentBalance - depositAmount); in.preparedStatement.setString(2, in.account); // 执行更新 in.preparedStatement.executeUpdate(); // 输出更新后的行数 System.out.println("取款成功，当前余额：" + (currentBalance - depositAmount)); } else { System.out.println("未找到匹配的账号。"); } } catch (SQLException e) { e.printStackTrace(); } } // 转账函数 private static void TransferAccounts(hello.Main.Inter in) { try { // 获取用户输入的对方账号 System.out.println("请输入对方账号："); String targetAccount = in.scanner.nextLine(); // 获取用户输入的转账金额 System.out.println("请输入转账金额："); double transferAmount = in.scanner.nextDouble(); // 查询自己账号的当前余额 String selectSql = "SELECT * FROM customer WHERE account_number = ?"; in.preparedStatement = in.conn.prepareStatement(selectSql); in.preparedStatement.setString(1, in.account); in.resultSet = in.preparedStatement.executeQuery(); // 如果有匹配的账号 if (in.resultSet.next()) { // 获取自己账号当前余额 double currentBalanceSelf = in.resultSet.getDouble("balance"); // 如果自己账号余额足够进行转账 if (currentBalanceSelf >= transferAmount) { // 更新自己账号余额（减少） String updateSql1 = "UPDATE customer SET balance = balance - ? WHERE account_number = ?"; in.preparedStatement = in.conn.prepareStatement(updateSql1); in.preparedStatement.setDouble(1, transferAmount); in.preparedStatement.setString(2, in.account); in.preparedStatement.executeUpdate(); // 更新对方账号余额（增加） String updateSql2 = "UPDATE customer SET balance = balance + ? WHERE account_number = ?"; in.preparedStatement = in.conn.prepareStatement(updateSql2); in.preparedStatement.setDouble(1, transferAmount); in.preparedStatement.setString(2, targetAccount); in.preparedStatement.executeUpdate(); // 输出更新后的行数 System.out.println("转账成功，当前余额：" + (currentBalanceSelf-transferAmount) + "转账金额：, " + transferAmount); } else { System.out.println("自己账号余额不足，无法进行转账。"); } } else { System.out.println("未找到匹配的自己账号。"); } } catch (SQLException e) { e.printStackTrace(); } } // 修改密码函数 private static void ChangePassword(hello.Main.Inter in) { try { // 获取用户输入的原密码 System.out.println("请输入原密码："); String oldPassword = in.scanner.nextLine(); // 获取用户输入的新密码 System.out.println("请输入新密码："); String newPassword = in.scanner.nextLine(); // 查询账号对应的原密码 String selectSql = "SELECT * FROM customer WHERE account_number = ?"; in.preparedStatement = in.conn.prepareStatement(selectSql); in.preparedStatement.setString(1, in.account); in.resultSet = in.preparedStatement.executeQuery(); // 如果有匹配的账号 if (in.resultSet.next()) { // 获取账号对应的原密码 String storedPassword = in.resultSet.getString("password"); // 如果输入的原密码与存储的密码匹配 if (oldPassword.equals(storedPassword)) { // 更新密码