WildFly未在MySQL中保持存储过程调用

Question

我正在开发一个运行在带有MySQL的WildFly 8上的EJB3应用程序。我需要更新实体(User)中的计数器(receiptCounter)，并决定使用存储过程调用来尝试它，以避免竞争条件。

下面是我创建存储过程的方式：

DELIMITER $$
CREATE PROCEDURE increment_receipt_counter
(
   IN userID_in INT
)
BEGIN
    UPDATE User SET receiptCounter = receiptCounter + 1 WHERE id = userID_in;
    SELECT receiptCounter AS receiptCounter_new FROM User WHERE id = userID_in;
END
$$
DELIMITER ;

我是这么称呼它的：

import javax.persistence.EntityManager;
import javax.persistence.StoredProcedureQuery;
...
public int incrementReceiptsCounter(int userID) throws InvalidEntityException, UnauthorizedException
{
    StoredProcedureQuery q = entityManager.createStoredProcedureQuery("increment_receipt_counter");
    q.registerStoredProcedureParameter("userID_in", Integer.class, ParameterMode.IN);
    q.setParameter("userID_in", userID);
    q.executeUpdate();
    return (Integer)q.getSingleResult();
}

奇怪的是:当从Java调用时，该过程返回正确的新计数器值，但新值不会持久保存在数据库中。例如，如果在调用该过程之前，数据库中的receiptCounter为1，则Java中的过程调用将返回2，但数据库中的User表仍然显示为1。当我直接从MySQL命令行调用该过程时，它工作得很好。我做错了什么？

Answer 1

在mysql命令行中，可能会启用auto commit，这意味着您的更新将自动持久化。

在java连接中，您可能禁用了auto commit，因此更新没有被提交，但是在与update相同的事务中运行的select仍然返回更新后的值。

但是，如果您希望处理并发性，则应该首先使用select ... for update来锁定计数器，然后再更新值。