2017-09-24 67 views
0

我正在开发一个运行在具有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命令行调用过程时,它工作得很好。我究竟做错了什么?

+0

缺失的提交? – Shadow

回答

0

在mysql命令行auto commit可能启用意味着您的更新是自动保存的。

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

但是,如果要处理并发性,则应首先使用select ... for update锁定计数器,然后更新该值。

+0

只是关于交易的一个说明,如果他使用用户管理的交易,那么这种情况就会发生。如果他使用容器管理的事务,则应该自动调用自动提交,并且问题可能在其他地方 – maress