java mysql并发写入

// 使用事务保证数据一致性
try (Connection conn = DriverManager.getConnection(url, username, password)) {
    conn.setAutoCommit(false);
    try (PreparedStatement ps = conn.prepareStatement("UPDATE users SET balance = balance - ? WHERE id = ?")) {
        ps.setInt(1, amount);
        ps.setInt(2, userId);
        ps.executeUpdate();
        conn.commit();
    } catch (SQLException e) {
        conn.rollback();
        throw e;
    }
} catch (SQLException e) {
    e.printStackTrace();
}

// 设置锁的超时时间
try (Connection conn = DriverManager.getConnection(url, username, password)) {
    conn.setAutoCommit(false);
    try (PreparedStatement ps = conn.prepareStatement("SELECT * FROM users WHERE id = ? FOR UPDATE")) {
        ps.setInt(1, userId);
        ps.setQueryTimeout(5); // 设置查询超时时间为5秒
        ResultSet rs = ps.executeQuery();
        // 处理结果集
        conn.commit();
    } catch (SQLException e) {
        conn.rollback();
        throw e;
    }
} catch (SQLException e) {
    e.printStackTrace();
}

// 使用连接池管理数据库连接
HikariConfig config = new HikariConfig();
config.setJdbcUrl(url);
config.setUsername(username);
config.setPassword(password);
HikariDataSource dataSource = new HikariDataSource(config);

try (Connection conn = dataSource.getConnection()) {
    // 执行数据库操作
} catch (SQLException e) {
    e.printStackTrace();
}