如何在 Spring Boot 中使用 Stream 和 Mongo db

问题描述

我想在 Mongodb 中查询大型集合并尝试使用 Stream com.mongodb.connection.Stream 。我在 Spring Boot 中使用 MongoRepository 执行此操作。我收到方法 Type 'com.mongodb.connection.Stream' does not have type parameters 的错误 Stream<Population> findAllStates(String state);。不确定它抱怨的类型是什么。

我在 mongodb 中有集合 Population。

我的存储库类是

package com.krk.samplemongodb;

import com.mongodb.connection.Stream;
import org.springframework.data.mongodb.repository.Aggregation;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.data.mongodb.repository.Query;
import org.springframework.stereotype.Repository;

import java.util.List;

@Repository
public interface PopulationRepository extends MongoRepository<Population,String> {


    @Query(value = "{'state' :?0}")
    Stream<Population> findAllStates(String state);

    List<Population> findAll();
    
}

谢谢

解决方法

您应该将导入更改为

import java.util.stream.Stream;

另外，请确保至少使用 1.7 版的 Spring Data MongoDB，如 this answer

中所述