public class AggregateChainWrapper<T,Children> extends Object implements Aggregate<T,Children>
| 构造器和说明 |
|---|
AggregateChainWrapper() |
| 限定符和类型 | 方法和说明 |
|---|---|
Children |
addFields(AddFields... addFields)
向集合中添加新字段
|
Children |
addFields(com.mongodb.BasicDBObject basicDBObject)
向集合中添加新字段
|
Children |
addFields(org.bson.conversions.Bson bson)
向集合中添加新字段
|
Children |
addFields(List<AddFields> addFieldsList)
向集合中添加新字段
|
Children |
addFields(SFunction<T,Object> resultMappingField,
SFunction<T,Object> field)
向集合中添加新字段
|
Children |
addFields(SFunction<T,Object> resultMappingField,
String field)
向集合中添加新字段
|
Children |
addFields(String resultMappingField,
SFunction<T,Object> field)
向集合中添加新字段
|
Children |
addFields(String resultMappingField,
String field)
向集合中添加新字段
|
Children |
allowDiskUse(boolean allowDiskUse)
设置为 true,表示允许在磁盘上存储临时数据。
|
Children |
batchSize(Integer size)
设置每个批次大小
|
Children |
bypassDocumentValidation(boolean bypassDocumentValidation)
设置绕过文档级验证标志。
|
Children |
collation(com.mongodb.client.model.CollationStrength collationStrength)
用于指定排序规则、语言特性等。
|
Children |
comment(org.bson.BsonValue comment)
设置此操作的注释。
|
Children |
comment(String comment)
设置此操作的注释。
|
Children |
custom(com.mongodb.BasicDBObject basicDBObject)
自定义管道操作
|
Children |
custom(org.bson.conversions.Bson bson)
自定义管道操作
|
List<BaseAggregate> |
getBaseAggregateList() |
List<com.mongodb.BasicDBObject> |
getBasicDBObjectList() |
com.mongodb.BasicDBObject |
getOptionsBasicDBObject() |
Children |
group(Accumulator... _id)
对所有文档记录进行分组,然后计算聚合结果
这种情况最好使用map,因为返回值会是一个json,如:{"name": "超级管理员", "age": 100}
|
Children |
group(com.mongodb.BasicDBObject basicDBObject)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(org.bson.conversions.Bson bson)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(List<GroupField> _id) |
Children |
group(List<GroupField> _id,
Accumulator... accumulator) |
Children |
group(List<GroupField> _id,
Accumulator accumulator) |
Children |
group(List<GroupField> _id,
List<Accumulator> accumulatorList) |
Children |
group(List<GroupField> _id,
SFunction<T,Object> resultMappingField,
com.anwen.mongo.enums.GroupTypeEnum operator,
SFunction<T,Object> field) |
Children |
group(List<GroupField> _id,
SFunction<T,Object> resultMappingField,
String operator,
SFunction<T,Object> field) |
Children |
group(List<GroupField> _id,
String resultMappingField,
com.anwen.mongo.enums.GroupTypeEnum operator,
String field) |
Children |
group(List<GroupField> _id,
String resultMappingField,
String operator,
String field) |
Children |
group(SFunction<T,Object> _id)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(SFunction<T,Object> _id,
Accumulator... accumulator)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(SFunction<T,Object> _id,
Accumulator accumulator)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(SFunction<T,Object> _id,
List<Accumulator> accumulatorList)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(SFunction<T,Object> _id,
SFunction<T,Object> resultMappingField,
com.anwen.mongo.enums.GroupTypeEnum operator,
SFunction<T,Object> field)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(SFunction<T,Object> _id,
SFunction<T,Object> resultMappingField,
String operator,
SFunction<T,Object> field)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(SFunction<T,Object> _id,
String resultMappingField,
com.anwen.mongo.enums.GroupTypeEnum operator,
String field)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(SFunction<T,Object> _id,
String resultMappingField,
String operator,
String field)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(String _id)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(String _id,
Accumulator... accumulator)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(String _id,
Accumulator accumulator)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(String _id,
List<Accumulator> accumulatorList)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(String _id,
SFunction<T,Object> resultMappingField,
com.anwen.mongo.enums.GroupTypeEnum operator,
SFunction<T,Object> field)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(String _id,
SFunction<T,Object> resultMappingField,
String operator,
SFunction<T,Object> field)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(String _id,
String resultMappingField,
com.anwen.mongo.enums.GroupTypeEnum operator,
String field)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
group(String _id,
String resultMappingField,
String operator,
String field)
对所有文档记录进行分组,然后计算聚合结果
|
Children |
groupFunc(List<FuncGroupField<?>> _id) |
Children |
groupFunc(List<FuncGroupField<?>> _id,
Accumulator... accumulator) |
Children |
groupFunc(List<FuncGroupField<?>> _id,
Accumulator accumulator) |
Children |
groupFunc(List<FuncGroupField<?>> _id,
List<Accumulator> accumulatorList) |
Children |
groupFunc(List<FuncGroupField<?>> _id,
SFunction<T,Object> resultMappingField,
com.anwen.mongo.enums.GroupTypeEnum operator,
SFunction<T,Object> field) |
Children |
groupFunc(List<FuncGroupField<?>> _id,
SFunction<T,Object> resultMappingField,
String operator,
SFunction<T,Object> field) |
Children |
groupFunc(List<FuncGroupField<?>> _id,
String resultMappingField,
com.anwen.mongo.enums.GroupTypeEnum operator,
String field) |
Children |
groupFunc(List<FuncGroupField<?>> _id,
String resultMappingField,
String operator,
String field) |
Children |
hint(org.bson.conversions.Bson hint)
设置要使用的索引的提示。
|
Children |
hint(String hint)
设置要使用的索引的提示。
|
Children |
let(org.bson.conversions.Bson variables)
将顶级变量添加到聚合中。
|
Children |
limit(long limit)
限制管道中文档记录的数量(每页显示行数)
|
Children |
lookup(com.mongodb.BasicDBObject basicDBObject) |
Children |
lookup(org.bson.conversions.Bson bson) |
Children |
lookup(String from,
List<Let> letList,
AggregateChainWrapper<T,?> pipeline,
String as)
实现集合之间的join操作
|
Children |
lookup(String from,
String localField,
String foreignField,
String as)
实现集合之间的join操作
|
Children |
match(com.mongodb.BasicDBObject basicDBObject)
过滤文档记录,只将匹配的文档记录传递到管道中的下一个步骤
|
Children |
match(org.bson.conversions.Bson bson)
过滤文档记录,只将匹配的文档记录传递到管道中的下一个步骤
|
Children |
match(QueryChainWrapper<?,?> queryChainWrapper)
过滤文档记录,只将匹配的文档记录传递到管道中的下一个步骤
|
Children |
maxAwaitTimeMS(long maxAwaitTime)
服务器等待新文档以满足$changeStream聚合的最长时间。
|
Children |
maxTimeMS(long time)
设置查询的最大执行时间(以毫秒为单位)。
|
Children |
out(com.mongodb.BasicDBObject basicDBObject)
将管道中的文档记录输出到一个具体的集合中,不存在则自动创建
这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据 |
Children |
out(org.bson.conversions.Bson bson)
将管道中的文档记录输出到一个具体的集合中,不存在则自动创建
这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据 |
Children |
out(String coll)
将管道中的文档记录输出到一个具体的集合中,不存在则自动创建
这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据 |
Children |
out(String db,
String coll)
将管道中的文档记录输出到一个具体的集合中,不存在则自动创建
这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据 |
Children |
project(com.mongodb.BasicDBObject basicDBObject)
自定义project
|
Children |
project(boolean displayId,
Projection... projection)
要显示哪写字段或者不显示哪些字段
|
Children |
project(org.bson.conversions.Bson bson)
自定义project
|
Children |
project(List<Projection> projectionList)
要显示哪写字段或者不显示哪些字段
|
Children |
project(Projection... projection)
要显示哪写字段或者不显示哪些字段
|
Children |
projectDisplay(boolean displayId,
SFunction<T,Object>... column)
显示哪些字段
|
Children |
projectDisplay(boolean displayId,
String... column)
显示哪些字段
|
Children |
projectDisplay(SFunction<T,Object>... column)
显示哪些字段
|
Children |
projectDisplay(String... column)
显示哪些字段
|
Children |
projectNone(boolean displayId,
SFunction<T,Object>... column)
不显示哪些字段
|
Children |
projectNone(boolean displayId,
String... column)
不显示哪些字段
|
Children |
projectNone(SFunction<T,Object>... column)
不显示哪些字段
|
Children |
projectNone(String... column)
不显示哪些字段
|
Children |
replaceRoot(com.mongodb.BasicDBObject basicDBObject)
使用指定字段替换根文档
|
Children |
replaceRoot(Boolean reserveOriginalDocument,
SFunction<T,Object>... field)
使用指定字段替换根文档
|
Children |
replaceRoot(Boolean reserveOriginalDocument,
String... field)
使用指定字段替换根文档
|
Children |
replaceRoot(org.bson.conversions.Bson bson)
使用指定字段替换根文档
|
Children |
replaceRoot(List<ReplaceRoot> replaceRootList)
使用指定字段替换根文档
|
Children |
replaceRoot(ReplaceRoot... replaceRoot)
使用指定字段替换根文档
|
Children |
replaceRoot(SFunction<T,Object>... field)
使用指定字段替换根文档
|
Children |
replaceRoot(String... field)
使用指定字段替换根文档
|
Children |
sample(long size)
随机选择指定数量的文档
|
Children |
skip(long skip)
跳过指定数量的文档记录,返回剩下的文档记录(当前页)
|
Children |
sort(com.mongodb.BasicDBObject basicDBObject)
对所有输出的文档记录进行排序
|
Children |
sort(org.bson.conversions.Bson bson)
对所有输出的文档记录进行排序
|
Children |
sort(List<Order> orderList)
对所有输出的文档记录进行排序
|
Children |
sort(Order... orders)
对所有输出的文档记录进行排序
|
Children |
sortAsc(SFunction<T,Object>... field)
正序排序
|
Children |
sortAsc(String... field)
正序排序
|
Children |
sortDesc(SFunction<T,Object>... field)
倒序排序
|
Children |
sortDesc(String... field)
倒序排序
|
Children |
unionWith(com.mongodb.BasicDBObject basicDBObject)
unionAll
|
Children |
unionWith(org.bson.conversions.Bson bson)
unionAll
|
Children |
unionWith(String collectionName)
unionAll
|
Children |
unwind(com.mongodb.BasicDBObject basicDBObject)
展开数组字段,生成一个文档副本,每个副本只包含一个数组元素
|
Children |
unwind(Boolean preserveNullAndEmptyArrays,
SFunction<T,Object> field)
展开数组字段,生成一个文档副本,每个副本只包含一个数组元素
|
Children |
unwind(Boolean preserveNullAndEmptyArrays,
String field)
展开数组字段,生成一个文档副本,每个副本只包含一个数组元素
|
Children |
unwind(org.bson.conversions.Bson bson)
展开数组字段,生成一个文档副本,每个副本只包含一个数组元素
|
Children |
unwind(SFunction<T,Object> field)
展开数组字段,生成一个文档副本,每个副本只包含一个数组元素
|
Children |
unwind(String field)
展开数组字段,生成一个文档副本,每个副本只包含一个数组元素
|
protected final Children typedThis
public Children match(QueryChainWrapper<?,?> queryChainWrapper)
Aggregatepublic Children match(com.mongodb.BasicDBObject basicDBObject)
Aggregatepublic Children match(org.bson.conversions.Bson bson)
Aggregatepublic Children project(Projection... projection)
Projectpublic Children project(List<Projection> projectionList)
Project@SafeVarargs public final Children projectDisplay(SFunction<T,Object>... column)
ProjectprojectDisplay 在接口中 Project<T,Children>column - 列名,字段名public Children projectDisplay(String... column)
ProjectprojectDisplay 在接口中 Project<T,Children>column - 列名、字段名@SafeVarargs public final Children projectNone(SFunction<T,Object>... column)
ProjectprojectNone 在接口中 Project<T,Children>column - 列名、字段名public Children projectNone(String... column)
ProjectprojectNone 在接口中 Project<T,Children>column - 列名、字段名public Children project(boolean displayId, Projection... projection)
Project@SafeVarargs public final Children projectDisplay(boolean displayId, SFunction<T,Object>... column)
ProjectprojectDisplay 在接口中 Project<T,Children>displayId - 是否显示_idcolumn - 列名,字段名public Children projectDisplay(boolean displayId, String... column)
ProjectprojectDisplay 在接口中 Project<T,Children>displayId - 是否显示_idcolumn - 列名、字段名@SafeVarargs public final Children projectNone(boolean displayId, SFunction<T,Object>... column)
ProjectprojectNone 在接口中 Project<T,Children>displayId - 是否显示_idcolumn - 列名、字段名public Children projectNone(boolean displayId, String... column)
ProjectprojectNone 在接口中 Project<T,Children>displayId - 是否显示_idcolumn - 列名、字段名public Children project(com.mongodb.BasicDBObject basicDBObject)
Aggregate@SafeVarargs public final Children sortAsc(SFunction<T,Object>... field)
Aggregate@SafeVarargs public final Children sortDesc(SFunction<T,Object>... field)
Aggregatepublic Children sort(com.mongodb.BasicDBObject basicDBObject)
Aggregatepublic Children groupFunc(List<FuncGroupField<?>> _id)
public Children group(Accumulator... _id)
Aggregatepublic Children group(SFunction<T,Object> _id, Accumulator accumulator)
Aggregatepublic Children groupFunc(List<FuncGroupField<?>> _id, Accumulator accumulator)
public Children group(String _id, Accumulator accumulator)
Aggregatepublic Children group(List<GroupField> _id, Accumulator accumulator)
public Children group(SFunction<T,Object> _id, Accumulator... accumulator)
Aggregatepublic Children groupFunc(List<FuncGroupField<?>> _id, Accumulator... accumulator)
public Children group(String _id, Accumulator... accumulator)
Aggregatepublic Children group(List<GroupField> _id, Accumulator... accumulator)
public Children group(SFunction<T,Object> _id, List<Accumulator> accumulatorList)
Aggregatepublic Children groupFunc(List<FuncGroupField<?>> _id, List<Accumulator> accumulatorList)
public Children group(String _id, List<Accumulator> accumulatorList)
Aggregatepublic Children group(List<GroupField> _id, List<Accumulator> accumulatorList)
public Children group(SFunction<T,Object> _id, String resultMappingField, String operator, String field)
Aggregatepublic Children groupFunc(List<FuncGroupField<?>> _id, String resultMappingField, String operator, String field)
public Children group(String _id, String resultMappingField, String operator, String field)
Aggregatepublic Children group(List<GroupField> _id, String resultMappingField, String operator, String field)
public Children group(SFunction<T,Object> _id, String resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, String field)
Aggregatepublic Children groupFunc(List<FuncGroupField<?>> _id, String resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, String field)
public Children group(String _id, String resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, String field)
Aggregatepublic Children group(List<GroupField> _id, String resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, String field)
public Children group(SFunction<T,Object> _id, SFunction<T,Object> resultMappingField, String operator, SFunction<T,Object> field)
Aggregatepublic Children groupFunc(List<FuncGroupField<?>> _id, SFunction<T,Object> resultMappingField, String operator, SFunction<T,Object> field)
public Children group(String _id, SFunction<T,Object> resultMappingField, String operator, SFunction<T,Object> field)
Aggregatepublic Children group(List<GroupField> _id, SFunction<T,Object> resultMappingField, String operator, SFunction<T,Object> field)
public Children group(String _id, SFunction<T,Object> resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, SFunction<T,Object> field)
Aggregatepublic Children group(List<GroupField> _id, SFunction<T,Object> resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, SFunction<T,Object> field)
public Children group(SFunction<T,Object> _id, SFunction<T,Object> resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, SFunction<T,Object> field)
Aggregatepublic Children groupFunc(List<FuncGroupField<?>> _id, SFunction<T,Object> resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, SFunction<T,Object> field)
public Children group(com.mongodb.BasicDBObject basicDBObject)
Aggregatepublic Children group(org.bson.conversions.Bson bson)
Aggregatepublic Children lookup(String from, String localField, String foreignField, String as)
Aggregatepublic Children lookup(String from, List<Let> letList, AggregateChainWrapper<T,?> pipeline, String as)
Aggregatepublic Children lookup(com.mongodb.BasicDBObject basicDBObject)
public Children lookup(org.bson.conversions.Bson bson)
public Children addFields(String resultMappingField, SFunction<T,Object> field)
Aggregatepublic Children addFields(SFunction<T,Object> resultMappingField, SFunction<T,Object> field)
Aggregatepublic Children addFields(SFunction<T,Object> resultMappingField, String field)
Aggregatepublic Children addFields(String resultMappingField, String field)
Aggregatepublic Children addFields(com.mongodb.BasicDBObject basicDBObject)
Aggregatepublic Children unwind(SFunction<T,Object> field)
Aggregatepublic Children unwind(Boolean preserveNullAndEmptyArrays, SFunction<T,Object> field)
Aggregatepublic Children unwind(Boolean preserveNullAndEmptyArrays, String field)
Aggregatepublic Children unwind(com.mongodb.BasicDBObject basicDBObject)
Aggregatepublic Children unwind(org.bson.conversions.Bson bson)
Aggregate@SafeVarargs public final Children replaceRoot(SFunction<T,Object>... field)
AggregatereplaceRoot 在接口中 Aggregate<T,Children>field - 指定字段public Children replaceRoot(ReplaceRoot... replaceRoot)
AggregatereplaceRoot 在接口中 Aggregate<T,Children>replaceRoot - replaceRoot类,会使用mergeObjects操作符将值组合起来public Children replaceRoot(List<ReplaceRoot> replaceRootList)
AggregatereplaceRoot 在接口中 Aggregate<T,Children>replaceRootList - replaceRoot集合,会使用mergeObjects操作符将值组合起来public Children replaceRoot(String... field)
AggregatereplaceRoot 在接口中 Aggregate<T,Children>field - 指定字段,传递多个值时会使用mergeObjects操作符组合起来@SafeVarargs public final Children replaceRoot(Boolean reserveOriginalDocument, SFunction<T,Object>... field)
AggregatereplaceRoot 在接口中 Aggregate<T,Children>reserveOriginalDocument - 是否保留原始文档字段field - 指定字段,传递多个值时会使用mergeObjects操作符组合起来public Children replaceRoot(Boolean reserveOriginalDocument, String... field)
AggregatereplaceRoot 在接口中 Aggregate<T,Children>reserveOriginalDocument - 是否保留原始文档字段field - 指定字段,传递多个值时会使用mergeObjects操作符组合起来public Children replaceRoot(com.mongodb.BasicDBObject basicDBObject)
AggregatereplaceRoot 在接口中 Aggregate<T,Children>basicDBObject - 自定义public Children replaceRoot(org.bson.conversions.Bson bson)
AggregatereplaceRoot 在接口中 Aggregate<T,Children>bson - 自定义public Children unionWith(com.mongodb.BasicDBObject basicDBObject)
Aggregatepublic Children out(String coll)
Aggregate这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据
public Children out(String db, String coll)
Aggregate这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据
public Children out(com.mongodb.BasicDBObject basicDBObject)
Aggregate这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据
public Children out(org.bson.conversions.Bson bson)
Aggregate这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据
public Children allowDiskUse(boolean allowDiskUse)
AggregateallowDiskUse 在接口中 Aggregate<T,Children>public Children collation(com.mongodb.client.model.CollationStrength collationStrength)
Aggregatepublic Children maxTimeMS(long time)
Aggregatepublic Children maxAwaitTimeMS(long maxAwaitTime)
AggregatemaxAwaitTimeMS 在接口中 Aggregate<T,Children>maxAwaitTime - 最大等待时间public Children bypassDocumentValidation(boolean bypassDocumentValidation)
AggregatebypassDocumentValidation 在接口中 Aggregate<T,Children>bypassDocumentValidation - 如果为true,则允许写入选择退出文档级验证。public Children hint(org.bson.conversions.Bson hint)
Aggregatepublic Children let(org.bson.conversions.Bson variables)
Aggregatepublic List<BaseAggregate> getBaseAggregateList()
public List<com.mongodb.BasicDBObject> getBasicDBObjectList()
public com.mongodb.BasicDBObject getOptionsBasicDBObject()
Copyright © 2023. All rights reserved.