当前位置：首页 > Java

如何用java转账

2026-03-25 03:50:36Java

使用Java实现转账功能

转账功能通常涉及数据库操作和事务管理，确保数据一致性和安全性。以下是一个基于Java的简单转账实现示例，使用JDBC和MySQL数据库。

数据库表设计

创建一个简单的银行账户表：

CREATE TABLE accounts (
    id INT PRIMARY KEY AUTO_INCREMENT,
    account_number VARCHAR(20) UNIQUE NOT NULL,
    balance DECIMAL(15,2) NOT NULL
);

Java转账实现

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class BankTransfer {
    private static final String DB_URL = "jdbc:mysql://localhost:3306/bank";
    private static final String DB_USER = "username";
    private static final String DB_PASSWORD = "password";

    public static void transfer(String fromAccount, String toAccount, double amount) {
        Connection conn = null;
        try {
            conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);
            conn.setAutoCommit(false); // 开始事务

            // 检查转出账户余额是否充足
            double fromBalance = getBalance(conn, fromAccount);
            if (fromBalance < amount) {
                throw new RuntimeException("Insufficient balance");
            }

            // 执行转账操作
            updateBalance(conn, fromAccount, -amount);
            updateBalance(conn, toAccount, amount);

            conn.commit(); // 提交事务
            System.out.println("Transfer successful");
        } catch (SQLException e) {
            try {
                if (conn != null) conn.rollback(); // 回滚事务
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            try {
                if (conn != null) conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    private static double getBalance(Connection conn, String accountNumber) throws SQLException {
        String sql = "SELECT balance FROM accounts WHERE account_number = ?";
        try (PreparedStatement stmt = conn.prepareStatement(sql)) {
            stmt.setString(1, accountNumber);
            var rs = stmt.executeQuery();
            if (rs.next()) {
                return rs.getDouble("balance");
            }
            throw new RuntimeException("Account not found");
        }
    }

    private static void updateBalance(Connection conn, String accountNumber, double amount) throws SQLException {
        String sql = "UPDATE accounts SET balance = balance + ? WHERE account_number = ?";
        try (PreparedStatement stmt = conn.prepareStatement(sql)) {
            stmt.setDouble(1, amount);
            stmt.setString(2, accountNumber);
            int rows = stmt.executeUpdate();
            if (rows == 0) {
                throw new RuntimeException("Account not found");
            }
        }
    }
}

使用Spring框架实现转账

对于企业级应用，推荐使用Spring框架的声明式事务管理：

@Service
public class BankService {
    @Autowired
    private AccountRepository accountRepository;

    @Transactional
    public void transfer(String fromAccount, String toAccount, double amount) {
        Account from = accountRepository.findByAccountNumber(fromAccount);
        Account to = accountRepository.findByAccountNumber(toAccount);

        if (from.getBalance() < amount) {
            throw new InsufficientBalanceException("Insufficient balance");
        }

        from.setBalance(from.getBalance() - amount);
        to.setBalance(to.getBalance() + amount);

        accountRepository.save(from);
        accountRepository.save(to);
    }
}