使用reactivemongodb查询mongodb集合SpringWebFlux

Question

我正在使用reactive mongodb开发简单的spring webflux演示应用程序，我想按姓名读取员工的所有数据，但不包括姓名字段“joe”、“Sara”、“joe”、“Sara”，我有如下代码：

//仓库接口

public interface EmployeeRepository extends ReactiveMongoRepository<Employee, String>{
 Flux<Employee> findAllByName(String name);
}

//服务类

public class EmplyeeService
{

private EmployeeRepository employeeRepository;

public Flux<Employee> findAllByOrganizationName(String name)
 {

        return employeeRepository.findAllByName(name);

    }

 public Flux<String> getAllNameExceptSome(String name)
{
     Employee emp1=new Employee();
     List<Flux<Employee>> emp=Arrays.asList(employeeRepository.findAllByName(name));
     Flux<Flux<Employee>> emp2=Flux.fromIterable(emp)
             .filter(name->name.equalsIgnoreCase("joe"));
     return emp2;
  }
}

Answer 1

首先，除非出现某些特殊情况，否则应避免使用以下数据结构：

List<Flux<Employee>>
Flux<Flux<Employee>>

但是，您没有利用Spring数据。您只需将存储库更改为：

public interface EmployeeRepository extends ReactiveMongoRepository<Employee, String> {

   // this find all Employee except those matching names provided as param
   Flux<Employee> findAllByNameNotIn(List<String> nameList);

   // this find all Employee matching names provided as param
   Flux<Employee> findAllByNameIn(List<String> nameList);
}

调用此方法，您将获得已按名称筛选的员工列表。