使用 Hibernate 5.2 以流形式查询结果

Question

从 Hibernate 5.2 开始，如果我们想要获取大量数据，我们可以使用 stream() 方法而不是 scroll()。

但是，当使用 scroll() 和 ScrollableResults 时，我们可以挂钩到检索过程并通过在处理对象后从持久上下文中逐出对象和/或每隔一段时间清除整个会话来释放内存然后。

我的问题：

1. 现在，如果我们使用stream() 方法，幕后会发生什么？
2. 是否可以从持久上下文中逐出对象？
3. 会话是否定期清除？
4. 如何实现最佳内存消耗？
5. 可以使用例如无状态会话？
6. 另外，如果我们在 JPA 属性中将 hibernate.jdbc.fetch_size 设置为某个数字（例如 1000），那么这如何与可滚动结果很好地结合？

Answer 1

以下对我有用：

DataSourceConfig.java

@Bean
public LocalSessionFactoryBean sessionFactory() {
    // Link your data source to your session factory
    ...
}

@Bean("hibernateTxManager")
public HibernateTransactionManager hibernateTxManager(@Qualifier("sessionFactory") SessionFactory sessionFactory) {
    // Link your session factory to your transaction manager
    ...
}

MyServiceImpl.java

@Service
@Transactional(propagation = Propagation.REQUIRES_NEW, transactionManager = "hibernateTxManager", readOnly = true)
public class MyServiceImpl implements MyService {

    @Autowired
    private MyRepo myRepo;
    ...
    Stream<MyEntity> stream = myRepo.getStream();
    // Do your streaming and CLOSE the steam afterwards
    ...

MyRepoImpl.java

@Repository
@Transactional(propagation = Propagation.MANDATORY, transactionManager = "hibernateTxManager", readOnly = true)
public class MyRepoImpl implements MyRepo {

    @Autowired
    private SessionFactory sessionFactory;

    @Autowired
    private MyDataSource myDataSource;

    public Stream<MyEntity> getStream() {

        return sessionFactory.openStatelessSession(DataSourceUtils.getConnection(myDataSource))
            .createNativeQuery("my_query", MyEntity.class)
            .setReadOnly(true)
            .setFetchSize(1000)
            .stream();
    }
    ...

请记住，当您进行流式传输时，您实际上只需要在对象具体化时注意内存。这确实是操作中唯一容易受到内存问题影响的部分。就我而言，我一次将流分块为 1000 个对象，使用 gson 将它们序列化并立即将它们发送到 JMS 代理。垃圾收集器完成其余的工作。

值得注意的是，Spring 的事务边界感知在最后关闭了与 dB 的连接，而无需明确告知。

Answer 2

Hibernate ORM 用户指南states that

在内部，stream() 的行为类似于 Query#scroll，底层结果由 ScrollableResults 支持。

您可以检查 the source code 或 org.hibernate.query.internal.AbstractProducedQuery 以确保您有责任定期清除会话或从持久上下文中逐出对象。

据我从 cmets 了解到，StatelessSession 不适合您。我认为解决您的案例的干净方法是实现您自己的 stream() 方法。它可能与原始方法非常相似，只需将 ScrollableResultsIterator 替换为您自己的方法即可在迭代期间执行您需要的操作（驱逐对象或清除会话）。