java数据库乐观锁

乐观锁是一种并发控制策略，它假设多个事务在并发执行时不会相互影响，在Java数据库中，乐观锁通常通过版本号（version）来实现，当一个事务更新数据时，它会检查数据的版本号是否与自己持有的版本号一致，如果一致则更新成功，否则更新失败。

以下是使用乐观锁的详细步骤：

1、查询数据并获取版本号

2、更新数据前检查版本号是否一致

3、如果版本号一致，更新数据并增加版本号

4、如果版本号不一致，说明其他事务已经修改了数据，此时可以选择回滚事务或者重新查询数据并重试。

以下是一个使用乐观锁的Java代码示例：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class OptimisticLockExample {
    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            // 加载数据库驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 获取数据库连接
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
            // 开启事务
            connection.setAutoCommit(false);
            // 查询数据并获取版本号
            String sql = "SELECT id, name, version FROM user WHERE id = 1";
            preparedStatement = connection.prepareStatement(sql);
            resultSet = preparedStatement.executeQuery();
            if (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                int version = resultSet.getInt("version");
                // 模拟其他操作，例如读取数据到内存中进行计算等
                Thread.sleep(1000);
                // 更新数据前检查版本号是否一致
                if (version == getVersion(connection, id)) {
                    // 如果版本号一致，更新数据并增加版本号
                    sql = "UPDATE user SET name = '张三' WHERE id = 1 AND version = " + version;
                    preparedStatement = connection.prepareStatement(sql);
                    preparedStatement.executeUpdate();
                    // 提交事务
                    connection.commit();
                } else {
                    // 如果版本号不一致，回滚事务并重新查询数据重试
                    connection.rollback();
                    System.out.println("数据已被其他事务修改，回滚事务并重新查询数据重试");
                }
            } else {
                System.out.println("未查询到数据");
            }
        } catch (ClassNotFoundException | SQLException | InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 关闭资源
            if (resultSet != null) {
                try {
                    resultSet.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (preparedStatement != null) {
                try {
                    preparedStatement.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    // 获取指定ID的数据版本号的方法，可以根据实际业务需求实现，例如从缓存中获取等
    private static int getVersion(Connection connection, int id) throws SQLException {
        String sql = "SELECT version FROM user WHERE id = " + id;
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        ResultSet resultSet = preparedStatement.executeQuery();
        if (resultSet.next()) {
            return resultSet.getInt("version");
        } else {
            throw new SQLException("未查询到数据");
        }
    }
}

在这个示例中，我们首先查询数据并获取版本号，然后模拟其他操作（例如读取数据到内存中进行计算等），最后在更新数据前检查版本号是否一致，如果版本号一致，则更新数据并增加版本号；如果版本号不一致，则回滚事务并重新查询数据重试。