并发问题 Grails

Question

我正在使用此代码更新一行。

SequenceNumber.withNewSession  {
   def hibSession = sessionFactory.getCurrentSession()
   Sql sql = new Sql(hibSession.connection())
   def rows = sql.rows("select for update query");
}

在此查询中，我正在更新数字，最初 sequenceNumber 是 1200。 并且每次运行此代码时，它都会增加 1。 我正在循环运行此代码 5 次。 但这并没有刷新休眠会话，因此每次我得到相同的数字 1201。

我也用过

hibSession.clear()
hibSession.flush()

但没有成功。

如果我使用以下代码，那么它可以正常工作。

SequenceNumber.withNewSession  {
   Sql sql = new Sql(dataSource)
   def rows = sql.rows("select for update query")
}

每次我收到一个新号码。

谁能告诉我上面的代码有什么问题

Answer 1

尝试使用事务，最后刷新它，例如：

SequenceNumber.withTransaction { TransactionStatus status ->
    ...
    status.flush()
}