spring mongodb查询中指定单场投影

jos*_*des 3 mongodb spring-data-mongodb

我有一个正常工作的查询,它只返回我的实体(Prl)的一个属性:

@Query("{'recibido' : null ,'activo' : true}")
public List<EmpleadoIdDTO> findIdsEmpleadosPrlActivoRecibidoIsNull();
Run Code Online (Sandbox Code Playgroud)

班级:

public class EmpleadoIdDTO {
private Long empleadoId;

 public Long getEmpleadoId() {
   return empleadoId;
 }

public void setEmpleadoId(Long empleadoId) {
this.empleadoId = empleadoId;
 } 
}
Run Code Online (Sandbox Code Playgroud)

我需要将此查询传递给 Criteria,因为它会增长:

import java.util.ArrayList;
import java.util.List;

import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.query.BasicQuery;
import org.springframework.data.mongodb.core.query.Criteria;

import com.xxx.crm482.domain.Prl;
import com.xxxx.crm482.service.dto.FilterPrlDTO;

public class PrlRepositoryImpl implements PrlRepositoryCustom {


private final MongoOperations mongoOperations;

public PrlRepositoryImpl(MongoOperations mongoOperations) {
this.mongoOperations = mongoOperations;
}


@Override
public List<Prl> find(FilterPrlDTO filterPrlDTO) {
List<Criteria> andCriteria = new ArrayList<>();

andCriteria.add(Criteria.where("activo").is(true));
andCriteria.add(Criteria.where("recibido").is(null));
Criteria orCriteria = new Criteria().andOperator(andCriteria.toArray(new Criteria[andCriteria.size()]));
Document projection = new Document("empleadoId", 1);
return mongoOperations.find(new BasicQuery(orCriteria.getCriteriaObject(), projection), Prl.class);
}
}
Run Code Online (Sandbox Code Playgroud)

在这里我需要的不是返回实体“Prl”,而是返回实体的属性“empleadoId”

use*_*814 5

您可以通过链接查询条件来简化您的方法。将字段投影添加到 Query 类。

添加流以映射您投影的字段。

@Override
public List<Long> find(FilterPrlDTO filterPrlDTO) {
   Criteria criteria = Criteria.where("activo").is(true).and("recibido").is(null);
   Query query = new Query(criteria);
   query.fields().include("empleadoId");
   List<String> empleadoIds = mongoOperations.find(query, Prl.class).stream().map(Prl::getEmpleadoId).collect(Collectors.toList());
   return empleadoIds;
}
Run Code Online (Sandbox Code Playgroud)


pvp*_*ran 0

有几件事。不可能只获得一种属性。但是你可以得到只有一个属性的 Pr1 对象(所有其他字段将为空)。您可以为此使用投影。

andCriteria.add(Criteria.where("activo").is(true));
andCriteria.add(Criteria.where("recibido").is(null));
Criteria orCriteria = new Criteria().andOperator(andCriteria.toArray(new Criteria[andCriteria.size()]));
Document projection = new Document("empleadoId", 1);

return mongoOperations.find(new BasicQuery(orCriteria.getCriteriaObject(), projection), Prl.class);
Run Code Online (Sandbox Code Playgroud)