Java中如何使用mysql行级锁 加锁和解锁 代码示例

在Java中使用MySQL行级锁，可以通过以下步骤进行加锁和解锁：

1. 加锁：

// 获取数据库连接
Connection conn = DriverManager.getConnection(url, username, password);

// 开启事务
conn.setAutoCommit(false);

// 获取PreparedStatement对象
PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM table WHERE id = ? FOR UPDATE");

// 设置参数值
pstmt.setInt(1, id);

// 执行查询并获取ResultSet对象
ResultSet rs = pstmt.executeQuery();

// 处理查询结果
// ...

// 提交事务
conn.commit();

// 关闭连接
rs.close();
pstmt.close();
conn.close();

在上述代码中，我们使用了`SELECT ... FOR UPDATE`语句来获取行级锁。其中，`id`是需要加锁的行的唯一标识符。通过执行该语句，MySQL会将该行加锁，直到事务提交或者回滚。

2. 解锁：

MySQL行级锁无需手动解锁，在事务提交或者回滚时，MySQL会自动释放所有加锁的行。因此，我们只需要在提交或回滚事务时关闭连接即可。

// 提交事务
conn.commit();

// 关闭连接
rs.close();
pstmt.close();
conn.close();

需要注意的是，在使用行级锁时，应该尽量减小锁定的范围，以避免锁定过多的行导致性能下降。同时，应该尽量控制事务的时间，减少锁定时间，以提高并发性能。