来自JPA存储库的Java 8流

Question

我想从JPA存储库中创建一个流。目标是将来自回购的实体(可能超过一百万)映射到其他实体，这些实体将依次存储在另一个回购中。

到目前为止，我构建了一个收集器，它将收集给定数量（例如1000）实体，然后将其存储到目标存储库中。这将在并行流中工作。我现在需要的是一种从源存储库中提取实体并在需要时将它们馈送到流中的好方法。

到目前为止，最有希望的是实现供应商（http://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html）通过生成来构建流，但是当对源存储库的查询未提供另一个实体时，我没有找到终止该过程的方法。

有什么建议吗？

Answer 1

一个简单的例子可能是：

  @Repository
  public class MyEntityRepository extends CrudRepository<MyEntity, Long> {           
  }

  @Component
  public class MyEntityService {

       @Autowired
       private MyEntityRepository myEntityRepository;


       public void() {
            // if the findAll() method returns List
            Stream<MyEntity> streamFromList = myEntityRepository.findAll().stream();


            // if the findAll() method returns Iterable
            Stream<MyEntity> streamFromIterable = StreamSupport.stream(myEntityRepository.findAll().spliterator(), true);

       }
  } 

Answer 2

如果您能够将源代码表示为供应商实现，您还可以实现拆分器。而不是供应商。获取您将实现＜code＞布尔tryAdvance（Consumer），如果存在新项，它将不返回新值，而是在＜code＞consumert上调用＜code＞accept

您必须为< code>Spliterator实现更多的方法，但幸运的是，有直接的方法来实现它们。

public Spliterator<T> trySplit() {
    return null;// simple answer when splitting is not supported
}
public long estimateSize() {
    return Long.MAX_VALUE; // the value which should be used for UNKNOWN
}
public int characteristics() {
    return 0; // no flags but check out whether some flags fit
}

对于＜code＞characteristics

拥有＜code＞拆分器

Stream<T> s=StreamSupport.stream(sp, false);

如果您的源代码更适合hasNext/下一个模式，您可以实现一个普通的Iterator并让JRE创建一个Spliterator，就像“如何从迭代器创建Java8 Stream”中描述的那样？

Answer 3

我们最近在Spring Data Fowler发布系列的最新RC1版本中增加了对Spring Data JPA(和MongoDB)的支持。

委托默认方法返回的流示例“真实流”流示例