JPA 服务器管理会话中的自定义查询

Question

我正在尝试在 JTA 会话（服务器管理）中执行 不相关 查询（other_table），以便在使用 JPA 将 bean EJB 持久化到 DB 之前进行一些验证。 p>

这是我想做的（大约）：

@PersistenceUnit(unitName="DynamicDatabase")
EntityManagerFactory emf;

@TransactionAttribute(TransactionAttributeType.REQUIRED)
private long nextEntryid() {
    em = emf.createEntityManager();
    Query query = em.createQuery("select t from OTHER_TABLE t");
    // do some validation and checking
    MyTable bean = new MyTable();
    em.persist(bean);
}

但是我不断收到服务器错误，它不允许与其他未持久化的数据库项进行交互：

org.apache.openjpa.persistence.ArgumentException:
An error occurred while parsing the query filter (query): The name "OTHER_TABLE" is not a recognized entity (...) Perhaps you meant MyTable, which is a close match.

<persistence-unit name="DynamicDatabase" transaction-type="JTA">
    <jta-data-source>jdbc/DB2DynamicConnection</jta-data-source>
    <class>jorge.java.dynamicdatabase.db.MyTable</class>
    </properties>
</persistence-unit>

问题是：在同一个 JPA DB 连接和 JTA 事务中查询/更改另一个表的正确方法是什么？

对此我很陌生，请耐心等待。在这方面工作了很长时间。

编辑：我认为这无关，但仅供参考，我正在使用 WebSphere Liberty Profile 8.5.5.4、JSDK 8u31、EclipseEE Luna 4.4.2 for Web Dev .将其添加到标签中。

Answer 1

问题是您有一个引用实体OTHER_TABLE 的@NamedQuery，并且它不存在或未标记为实体（在Java 类和persistence.xml 中尝试）。

如果OtherTable Java 类不是实体并且它必须保持不变，那么您可以使用Constructors in JPQL-queries：

SELECT NEW com.domain.reports.MyReport(u.firstName, u.lastName, u.birthday) FROM User u

如果您需要编写普通的 SQL 查询，那么您可以使用 native queries 来完成，因为它们在 JPA 规范中是已知的。

Answer 2

根据 Andrei 的建议，JPQL（Java 持久性查询语言）对对象而不是表进行操作。这意味着em.createQuery() 不能用于通用数据库交互。

一般来说，执行任何 SQL 语句（在容器管理的事务 JTA 内部），都需要从实体管理器获取 DB 连接（它将返回持久性上下文单元 JPA）。

    // Get container's objects
    em = emf.createEntityManager();
    java.sql.Connection conn = em.unwrap(java.sql.Connection.class);

    // Run the query
    Statement sql = conn.createStatement();
    ResultSet rs = sql.executeQuery("select * from OTHER_TABLE");
    rs.next()
    (...)

    //Container-managed connection shouldn't be closed. 
    rs.close;
    sql.close;

请注意，unwrap 调用适用于 JPA，但不适用于 Hibernate（在这一点上已经存在其他问题）。请注意用于 SQL 语句 select * from 的语言与用于命名查询 JPQL select t from 的语言不同。异常处理也必须像往常一样使用} finally { 子句进行控制。

这样可以在不使用 JAVA 实体的情况下在服务器管理的事务中执行复杂的自定义语句，我终于可以睡觉了。