如何使用JPA EntityManager调用数据库中已存在的MySQL存储过程

嘿，我看你遇到了用EntityManager调用MySQL存储过程的麻烦——代码执行后execute()返回false，但存储过程里的truncate和insert完全没生效，也没看到明确的报错信息对吧？咱们一步步排查解决：

1. 先确认数据库权限是否到位 #

首先得检查你的应用通过JNDI连接用的数据库账号，有没有执行这个存储过程的权限，还有操作相关表的权限：

• 执行TestReporting的权限
• 对report_controller_total_request表的TRUNCATE和INSERT权限
• 对log_request表的SELECT权限

可以在MySQL里跑这几条命令给账号赋权（替换成你的应用账号）：

GRANT EXECUTE ON PROCEDURE DEVDBA.TestReporting TO '你的应用账号'@'%';
GRANT TRUNCATE, INSERT ON DEVDBA.report_controller_total_request TO '你的应用账号'@'%';
GRANT SELECT ON DEVDBA.log_request TO '你的应用账号'@'%';
FLUSH PRIVILEGES;

2. 换个更可靠的调用方式：原生SQL调用 #

我个人推荐用原生SQL直接调用存储过程，比StoredProcedureQuery更适配MySQL的特性，不容易踩坑。修改后的代码还加了异常捕获和事务回滚逻辑，能帮你快速定位问题：

public void UpdateServer() { 
    System.out.println("Update Server Start"); 
    EntityManager entityManager = null; 
    try {
        entityManager = EntityManagerFactoryBuilder.createEntityManager(); 
        entityManager.getTransaction().begin(); 
        // 直接用CALL语句调用存储过程
        Query query = entityManager.createNativeQuery("CALL TestReporting()");
        int affectedRows = query.executeUpdate();
        System.out.println("Update Server Done: 影响行数=" + affectedRows); 
        entityManager.getTransaction().commit(); 
    } catch (Exception e) {
        // 出错时一定要回滚事务
        if (entityManager != null && entityManager.getTransaction().isActive()) {
            entityManager.getTransaction().rollback();
        }
        e.printStackTrace(); // 打印异常，这是排查问题的关键！
        System.out.println("Update Server Failed: " + e.getMessage());
    } finally {
        if (entityManager != null) {
            entityManager.close(); 
        }
    }
}

3. 如果非要用StoredProcedureQuery，得补全配置 #

要是你坚持用StoredProcedureQuery，有些JPA实现（比如Hibernate）需要显式注册参数，哪怕你的存储过程没有参数。试试这样修改：

public void UpdateServer() { 
    System.out.println("Update Server Start"); 
    EntityManager entityManager = null; 
    try {
        entityManager = EntityManagerFactoryBuilder.createEntityManager(); 
        entityManager.getTransaction().begin(); 
        StoredProcedureQuery storedProcedure = entityManager.createStoredProcedureQuery("TestReporting");
        // 注册一个空参数，适配MySQL存储过程的调用规范
        storedProcedure.registerStoredProcedureParameter(1, void.class, ParameterMode.REF_CURSOR);
        boolean isExecuted = storedProcedure.execute();
        System.out.println("Update Server Done: "+isExecuted); 
        entityManager.getTransaction().commit(); 
    } catch (Exception e) {
        if (entityManager != null && entityManager.getTransaction().isActive()) {
            entityManager.getTransaction().rollback();
        }
        e.printStackTrace();
        System.out.println("Update Server Failed: " + e.getMessage());
    } finally {
        if (entityManager != null) {
            entityManager.close(); 
        }
    }
}

4. 开启SQL日志，看清实际执行的语句 #

建议你在JPA配置里开启SQL日志，这样能看到程序到底发了什么SQL给数据库。比如用Hibernate的话，在persistence.xml里加这些配置：

<property name="hibernate.show_sql" value="true"/>
<property name="hibernate.format_sql" value="true"/>
<property name="hibernate.use_sql_comments" value="true"/>

之后控制台会输出所有执行的SQL，你就能确认CALL TestReporting()是不是真的被执行了，有没有隐藏的错误。

最后提醒：一定要捕获异常 #

你的原代码没加异常处理，就算执行过程中出了问题（比如权限不够、表不存在），也可能只返回false而不抛错。加上异常捕获后，能直接看到问题根源，这对排查太重要了！

内容的提问来源于stack exchange，提问作者Komal Prasad