JPA Hibernate调用Postgres函数无效返回MappingException：

小编典典

JPA Hibernate调用Postgres函数无效返回MappingException：

hibernate

我遇到一个问题： org.hibernate.MappingException：JDBC类型的No Dialect映射：1111
尝试使用JPA创建本机查询时调用postgres函数。

我在启动单例中创建了一个EJB计时器，以每6小时运行一次Postgres函数。该函数返回void并检查过期的记录，将其删除并更新某些状态。它不接受任何参数，并且返回void。

如果我使用PgAdmin查询工具（选择function（）;）调用postgres函数，则该函数可以完美运行，并返回void。
在Glassfish 3.1.1上部署应用程序时，出现异常和部署失败。

这是（缩短的）堆栈跟踪：

WARNING: A system exception occurred during an invocation on EJB UserQueryBean method public void com.mysoftwareco.entity.utility.UserQueryBean.runRequestCleanup()
javax.ejb.TransactionRolledbackLocalException: Exception thrown from bean
...STACK TRACE BLAH BLAH BLAH ...
Caused by: javax.persistence.PersistenceException: org.hibernate.MappingException: No Dialect mapping for JDBC type: 1111

这是代码：

首先是JPA的东西：

public void runRequestCleanup() {
    String queryString = "SELECT a_function_that_hibernate_chokes_on()";
    Query query = em.createNativeQuery(queryString);
    Object result = query.getSingleResult();
}

这是单例调用它：

@Startup
@Singleton
public class RequestCleanupTimer {
    @Resource
    TimerService timerService;
    @EJB
    UserQueryBean queryBean;

    @PostConstruct
    @Schedule(hour = "*/6")
    void runCleanupTimer() {
        queryBean.runRequestCleanup();
    }
}

和功能：

CREATE OR REPLACE FUNCTION a_function_that_hibernate_chokes_on()
  RETURNS void AS
$BODY$
    DECLARE 
        var_field_id myTable.field_id%TYPE;
    BEGIN
        FOR var_field_id IN
                select field_id from myTable 
                where status = 'some status'
                and disposition = 'some disposition'
                and valid_through < now()
        LOOP
            BEGIN
                -- Do Stuff
            END;
        END LOOP;
    END;
$BODY$
  LANGUAGE plpgsql VOLATILE
  COST 100;

阅读 340

2020-06-20

共1个答案

小编典典

我对JPA有足够的了解，试图使其运行存储过程。

我最终使用带准备好的语句的JDBC。在花了几个小时的徒劳尝试将方钉插入圆孔后，我在15分钟内做到了。我将持久性单元用来获取连接，创建准备好的语句并在完成后将其关闭的同一个jndi数据源称为。

因此，如果您需要从（现在主要是）JPA应用程序运行存储过程（或Postgres函数），这对我有用：

@Stateless
@LocalBean
public class UserQueryBean implements Serializable {

    @Resource(mappedName="jdbc/DatabasePool") 
    private javax.sql.DataSource ds;

    ...

    public void runRequestCleanup() {

        String queryString = "SELECT cleanup_function_that_hibernateJPA_choked_on()";
        Connection conn = null;
        PreparedStatement statement = null;
        try {
            conn = ds.getConnection();
            statement = conn.prepareCall(queryString);
            statement.executeQuery();
        } catch (SQLException ex) {
            Logger.getLogger(UserQueryBean.class.getName()).log(Level.SEVERE, null, ex);
        }finally{
            try {
                statement.close();
                conn.close();
            } catch (SQLException ex) {
                Logger.getLogger(UserQueryBean.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
        // bit of logging code here    
    }
    ...
}

忽略JPA在服务器上运行函数或存储过程的简单功能似乎令人恐惧。特别是除了void或受影响的行数以外不返回任何内容的代码。如果是故意的……则无可奉告。

编辑：添加了关闭连接。

2020-06-20