WildFly在MySQL中不存储存储过程调用
问题描述:
我正在开发一个运行在具有MySQL的WildFly 8上的EJB 3应用程序。我需要更新实体(User
)中的计数器(receiptCounter
),并决定尝试使用存储过程调用以避免竞争条件。WildFly在MySQL中不存储存储过程调用
这是我创建的存储过程:
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命令行调用过程时,它工作得很好。我究竟做错了什么?
答
在mysql命令行auto commit
可能启用意味着您的更新是自动保存的。
在java连接中,您可能禁用了auto commit
,因此更新未提交,但在与update
相同的事务中运行的select
仍然返回更新后的值。
但是,如果要处理并发性,则应首先使用select ... for update
锁定计数器,然后更新该值。
+0
只是关于交易的一个说明,如果他使用用户管理的交易,那么这种情况就会发生。如果他使用容器管理的事务,则应该自动调用自动提交,并且问题可能在其他地方 – maress
缺失的提交? – Shadow