spring data jpa使用流式查询

路过君

发布于 2023-03-08 14:39:50

1.8K0

发布于 2023-03-08 14:39:50

文章被收录于专栏：路过君BLOG from CSDN路过君BLOG from CSDN

思路

调用org.hibernate.query.Query.stream方法查询数据

代码样例

import static org.hibernate.annotations.QueryHints.READ_ONLY;
import static org.hibernate.jpa.QueryHints.HINT_FETCH_SIZE;
import org.hibernate.query.Query;

使用HQL查询

Query<MyEntity> q = entityManager.createQuery(
	"select e from MyEntity e where field1 = :field1",
	MyEntity.class
)
.setParameter("field1", "test")
.setHint(HINT_FETCH_SIZE, Integer.MIN_VALUE) // 根据数据库实现设置，这里是MYSQL
.setHint(READ_ONLY, true)
.unwrap(Query.class);
Stream<MyEntity> stream= q.stream();
stream.close(); // 释放

使用动态查询

CriteriaBuilder builder = entityManager.getCriteriaBuilder();
CriteriaQuery<MyEntity> query = builder.createQuery(MyEntity.class);
Root<MyEntity> root = query.from(MyEntity.class);
query.where(builder .equal(root.get("field1"), "test"));
query.select(root);
Query<MyEntity> q = entityManager.createQuery(query)
	.setHint(HINT_FETCH_SIZE, Integer.MIN_VALUE)
	.setHint(READ_ONLY, true)
	.unwrap(Query.class);  
Stream<MyEntity> stream= q.stream();
stream.close(); // 释放

直接使用jdbc

jdbcTemplate.query(con -> {
    String sql = "select * from t_my_entity where fd_field1 = ?";
    PreparedStatement preparedStatement = this.createPreparedStatement(con, sql, context);
    statement.setString(1, "test");
    statement.setFetchSize(Integer.MIN_VALUE);
    statement.setFetchDirection(ResultSet.FETCH_FORWARD);
    return preparedStatement;
}, resultSet -> {
    // 遍历处理结果
});

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2023-02-28，如有侵权请联系 cloudcommunity@tencent.com 删除

jdbc