我正在尝试在 Spring 应用程序中运行一些本机 SQL 查询。我没有实体或
JpaRepository
类。我知道这很奇怪,但这是一个微服务,只是收集两个计数查询并将其发送到 Kafka。
相信我,我所需要的只是查询中的这两个整数。我运行这些代码并且总是返回 0。我可以在日志中看到 Hikari 正在连接到数据库,所以我不知道该怎么办。搜索了很多,但所有答案都涉及
@Query
解决方案,这对我不起作用。
@Repository
@AllArgsConstructor
public class ReportRepository {
private final EntityManager em;
public int numberOfAccounts() {
String sql = "SELECT count(*) FROM account";
Query query = em.createNativeQuery(sql);
System.out.println(query.getFirstResult());
return query.getFirstResult();
}
public int numberOfSubscriptions() {
String sql = "SELECT count(*) FROM subscriptions";
Query query = em.createNativeQuery(sql);
System.out.println(query.getFirstResult());
return query.getFirstResult();
}
}
如果您有
EntityManager
,并且根据您的说法它可以连接到数据库,请尝试以下方式:
public int numberOfSubscriptions() {
// >> "subscriptions" has to be the exact name of your table
// if does not work, consider trying SUBSCRIPTIONS or Subscriptions
String sql = "SELECT count(*) FROM subscriptions";
Query query = em.createNativeQuery(sql);
// getSingleResult() instead :)
return ((Number) query.getSingleResult()).intValue();
}
有一个(有点旧的)JavaDoc for Query.getFirstResult() :
查询对象设置要检索的第一个结果的位置。如果 setFirstResult 未应用于查询对象,则返回 0
所以,我想说这不是适合您的情况的正确方法。
黑客快乐:)
您应该使用 JDBC 而不是实体管理器。在底层,JPA 使用 JDBC,但它需要定义的实体才能工作。 JDBC 允许您管理连接并运行原始 SQL 查询。
这里是如何在 Spring 中执行此操作的链接: https://spring.io/guides/gs/relational-data-access/#_store_and_retrieve_data