Lo que necesita es el $redact
operador en el marco de agregación que le permite procesar la condición lógica anterior con $cond
operador y utiliza las operaciones especiales $$KEEP
para "mantener" el documento donde la condición lógica es verdadera o $$PRUNE
para "eliminar" el documento donde la condición era falsa.
Esta operación es similar a tener un $project
tubería que selecciona los campos en la colección y crea un nuevo campo que contiene el resultado de la consulta de condición lógica y luego un subsiguiente $match
, excepto que $redact
utiliza una sola etapa de canalización que es más eficiente.
Considere el siguiente ejemplo que demuestra el concepto anterior:
db.collection.aggregate([
{
"$redact": {
"$cond": [
{
"$gte": [
{ "$divide": ["$Number1", "$Number2"] },
CONSTANT_VAR
]
},
"$$KEEP",
"$$PRUNE"
]
}
}
])
Dado que no hay soporte para $redact
operador todavía
(en el momento de escribir este artículo), una solución será implementar una AggregationOperation
interfaz que envuelve la operación de agregación con una clase para incluir un DBObject
:
public class RedactAggregationOperation implements AggregationOperation {
private DBObject operation;
public RedactAggregationOperation (DBObject operation) {
this.operation = operation;
}
@Override
public DBObject toDBObject(AggregationOperationContext context) {
return context.getMappedObject(operation);
}
}
que luego puede usar en TypeAggregation
:
Aggregation agg = newAggregation(
new RedactAggregationOperation(
new BasicDBObject(
"$redact",
new BasicDBObject(
"$cond", new BasicDBObject()
.append("if", new BasicDBObject(
"$gte", Arrays.asList(
new BasicDBObject(
"$divide", Arrays.asList( "$Number1", "$Number2" )
),
CONSTANT_VAR
)
)
)
.append("then", "$$KEEP")
.append("else", "$$PRUNE")
)
)
)
);
AggregationResults<Example> results = mongoTemplate.aggregate(
(TypedAggregation<Example>) agg, Example.class);
--ACTUALIZAR--
Seguimiento de los comentarios, para verificar si hay valores nulos o cero en el Number2
en la división, tendría que anidar un $cond
expresión con la lógica en su lugar.
El siguiente ejemplo asume que tiene un valor de marcador de posición de 1 si Number2
no existe/es nulo o tiene un valor de cero:
db.collection.aggregate([
{
"$redact": {
"$cond": [
{
"$gte": [
{
"$divide": [
"$Number1", {
"$cond": [
{
"$or": [
{ "$eq": ["$Number2", 0] },
{
"$eq": [
{ "$ifNull": ["$Number2", 0] }, 0
]
}
]
},
1, // placeholder value if Number2 is 0
"$Number2"
]
}
]
},
CONSTANT_VAR
]
},
"$$KEEP",
"$$PRUNE"
]
}
}
])
Agregación de datos Spring equivalente (no probado)
Aggregation agg = newAggregation(
new RedactAggregationOperation(
new BasicDBObject(
"$redact",
new BasicDBObject(
"$cond", Arrays.asList(
new BasicDBObject(
"$gte", Arrays.asList(
new BasicDBObject(
"$divide", Arrays.asList(
"$Number1",
new BasicDBObject(
"$cond", Arrays.asList(
new BasicDBObject( "$or": Arrays.asList(
new BasicDBObject("$eq", Arrays.asList("$Number2", 0)),
new BasicDBObject("$eq", Arrays.asList(
new BasicDBObject("$ifNull", Arrays.asList("$Number2", 0)), 0
)
)
)
),
1, // placeholder value if Number2 is 0
"$Number2"
)
)
)
),
CONSTANT_VAR
)
), "$$KEEP", "$$PRUNE"
)
)
)
)
);