JDBC 随机获取 5 行数据，在 update 之前怎么防止并发的其他线程获取到重复的数据

select for update

然后 update 的时候检测版本号

锁表？

select 和 update 在同一个事务隔离级别为可重复读的事务中就 ok 了

简单点，获取出来，先删了，再插入？

前题数据库要支持行级锁。。。InnoDB 是没问题的

@zhaorunze 是 InnoDB

@gz911122 select for update 尝试过，还是会获取到相同的 ID

@meijoy 然后 update 判断版本号啊...

@zhaorunze 具体怎么使用？
conn.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);
stmt = conn.prepareStatement(sql);
stmt.executeQuery();

然后 update ?

缓存里加 redis 锁

防并发的话两个手段, 数据库自带版本号, 更新的时候只会有一个 update 成功; 把取出来的记录以 id 维度加分布式锁(redis), 拿锁失败表明已经有别人拿到了相同的记录.

还要考虑拿重复记录后失败怎么办的问题

其他线程获取之后的操作也是 set state = 1 ? 直接 replace into

repeatable read 考虑会不会出现锁升级导致死锁 ，Select for update 不知道 x 锁会不会保留到事务结束。

@gz911122 怎么判断，数据库接触的少啊

1L 的意思里面, 版本号得自己加的. db 自己的 MVVC 的版本号不是面向应用开发者的.
这是一个 cas 的概念

要么 select for update, transaction 结束后锁释放, 要么 cas 方式也可以.

锁释放前, 你其他 select 会阻塞

@meinjoy 是的，事务提交或者回滚之前 update 就可以了

sql 要改一下，有个子查询导致 for update 的行锁没加上
SELECT id,state FROM test_list
WHERE id >= ((SELECT MAX(id) FROM test_list )-(SELECT MIN(id) FROM test_list )) * RAND() + (SELECT MIN(id) FROM test_list )
AND state = 0
LIMIT 5 for UPDATE

sql 改一下加个 for update，其他不变就行了，并发查询的时候会阻塞到上一个事务提交，不会查到重复的 ID，jdbc 要 setAutoCommit(false)不然会自动提交

@zhaorunze 可重复读不加版本明显不行啊

@justRua

String sql = SELECT id,state FROM test_list
WHERE id >= ((SELECT MAX(id) FROM test_list )-(SELECT MIN(id) FROM test_list )) * RAND() + (SELECT MIN(id) FROM test_list )
AND state = 0
LIMIT 1 for UPDATE;

conn.setAutoCommit(false);
stmt = conn.prepareStatement(sql);
stmt.executeQuery();
stmt = conn.prepareStatement(updateId);
stmt.executeUpdate();
conn.commit();

这样就行了？

@meinjoy
#13
定义一个版本号字段 v ,select 的时候查出来 v,update 的时候判断 v=v, 符合则更新,update 的时候版本号+1

@petelin 加版本是啥意思，还有这么 low 的操作吗，可能我的事务被 spring 托管了

用悲观锁吧，别自旋了，感觉冲突的几率还不小（假设取值是完全随机的,获取每个值对地概率都一样，那么概率是((n-5)/n)^5?）