public interface Aggregate<T,Children> extends Project<T,Children>
| 限定符和类型 | 方法和说明 |
|---|---|
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)
自定义管道操作
|
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 maxTime)
设置查询的最大执行时间(以毫秒为单位)。
|
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(org.bson.conversions.Bson bson)
自定义project
|
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)
展开数组字段,生成一个文档副本,每个副本只包含一个数组元素
|
project, project, project, projectDisplay, projectDisplay, projectDisplay, projectDisplay, projectNone, projectNone, projectNone, projectNoneChildren match(QueryChainWrapper<?,?> queryChainWrapper)
queryChainWrapper - 条件Children match(com.mongodb.BasicDBObject basicDBObject)
basicDBObject - 条件Children match(org.bson.conversions.Bson bson)
bson - 条件Children sort(com.mongodb.BasicDBObject basicDBObject)
basicDBObject - 排序条件Children sort(org.bson.conversions.Bson bson)
bson - 排序条件Children limit(long limit)
limit - 数量Children skip(long skip)
skip - 数量Children groupFunc(List<FuncGroupField<?>> _id)
Children group(List<GroupField> _id)
Children group(Accumulator... _id)
_id - 累加器类Children group(SFunction<T,Object> _id, Accumulator accumulator)
_id - 分组依据字段accumulator - 累加器类Children groupFunc(List<FuncGroupField<?>> _id, Accumulator accumulator)
Children group(String _id, Accumulator accumulator)
_id - 分组依据字段accumulator - 累加器类Children group(List<GroupField> _id, Accumulator accumulator)
Children group(SFunction<T,Object> _id, Accumulator... accumulator)
_id - 分组依据字段accumulator - 累加器类Children groupFunc(List<FuncGroupField<?>> _id, Accumulator... accumulator)
Children group(String _id, Accumulator... accumulator)
_id - 分组依据字段accumulator - 累加器类Children group(List<GroupField> _id, Accumulator... accumulator)
Children group(SFunction<T,Object> _id, List<Accumulator> accumulatorList)
accumulatorList - 累加器集合Children groupFunc(List<FuncGroupField<?>> _id, List<Accumulator> accumulatorList)
Children group(String _id, List<Accumulator> accumulatorList)
_id - 分组依据字段accumulatorList - 累加器集合Children group(List<GroupField> _id, List<Accumulator> accumulatorList)
Children group(SFunction<T,Object> _id, String resultMappingField, String operator, String field)
_id - 分组依据字段resultMappingField - 结果映射字段operator - 操作,参考GroupTypeEnum枚举field - 列名、字段名Children groupFunc(List<FuncGroupField<?>> _id, String resultMappingField, String operator, String field)
Children group(String _id, String resultMappingField, String operator, String field)
_id - 分组依据字段resultMappingField - 结果映射字段operator - 操作,参考GroupTypeEnum枚举field - 列名、字段名Children group(List<GroupField> _id, String resultMappingField, String operator, String field)
Children group(SFunction<T,Object> _id, String resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, String field)
_id - 分组依据字段resultMappingField - 结果映射字段operator - Group条件枚举field - 列名、字段名Children groupFunc(List<FuncGroupField<?>> _id, String resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, String field)
Children group(String _id, String resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, String field)
_id - 分组依据字段resultMappingField - 结果映射字段operator - Group条件枚举field - 列名、字段名Children group(List<GroupField> _id, String resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, String field)
Children group(SFunction<T,Object> _id, SFunction<T,Object> resultMappingField, String operator, SFunction<T,Object> field)
_id - 分组依据字段resultMappingField - 结果映射字段operator - 操作,参考GroupTypeEnum枚举field - 列名、字段名Children groupFunc(List<FuncGroupField<?>> _id, SFunction<T,Object> resultMappingField, String operator, SFunction<T,Object> field)
Children group(String _id, SFunction<T,Object> resultMappingField, String operator, SFunction<T,Object> field)
_id - 分组依据字段resultMappingField - 结果映射字段operator - 操作,参考GroupTypeEnum枚举field - 列名、字段名Children group(List<GroupField> _id, SFunction<T,Object> resultMappingField, String operator, SFunction<T,Object> field)
Children group(String _id, SFunction<T,Object> resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, SFunction<T,Object> field)
_id - 分组依据字段resultMappingField - 结果映射字段operator - Group条件枚举field - 列名、字段名Children group(List<GroupField> _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, com.anwen.mongo.enums.GroupTypeEnum operator, SFunction<T,Object> field)
_id - 分组依据字段resultMappingField - 结果映射字段operator - Group条件枚举field - 列名、字段名Children groupFunc(List<FuncGroupField<?>> _id, SFunction<T,Object> resultMappingField, com.anwen.mongo.enums.GroupTypeEnum operator, SFunction<T,Object> field)
Children group(com.mongodb.BasicDBObject basicDBObject)
basicDBObject - 分组依据Children group(org.bson.conversions.Bson bson)
bson - 分组依据Children lookup(String from, String localField, String foreignField, String as)
from - 目标集合名称localField - 当前集合用于关联的字段foreignField - 指定目标集合用于关联的字段as - 输出结果中保存关联值的字段名Children lookup(String from, List<Let> letList, AggregateChainWrapper<T,?> pipeline, String as)
from - 目标集合名称as - 输出结果中保存关联值的字段名Children lookup(com.mongodb.BasicDBObject basicDBObject)
Children lookup(org.bson.conversions.Bson bson)
Children addFields(String resultMappingField, SFunction<T,Object> field)
resultMappingField - 结果映射字段field - 字段值、取值字段Children addFields(SFunction<T,Object> resultMappingField, SFunction<T,Object> field)
resultMappingField - 结果映射字段field - 字段值、取值字段Children addFields(SFunction<T,Object> resultMappingField, String field)
resultMappingField - 结果映射字段field - 字段值、取值字段Children addFields(String resultMappingField, String field)
resultMappingField - 结果映射字段field - 字段值、取值字段Children addFields(List<AddFields> addFieldsList)
addFieldsList - 新字段类集合Children addFields(com.mongodb.BasicDBObject basicDBObject)
basicDBObject - 自定义Children addFields(org.bson.conversions.Bson bson)
bson - 自定义Children unwind(SFunction<T,Object> field)
field - 需要展开的字段Children unwind(Boolean preserveNullAndEmptyArrays, SFunction<T,Object> field)
preserveNullAndEmptyArrays - 是否保留空数组或包含 null 值的数组字段field - 需要展开的字段Children unwind(String field)
field - 需要展开的字段Children unwind(Boolean preserveNullAndEmptyArrays, String field)
preserveNullAndEmptyArrays - 是否保留空数组或包含 null 值的数组字段field - 需要展开的字段Children unwind(com.mongodb.BasicDBObject basicDBObject)
basicDBObject - 自定义Children unwind(org.bson.conversions.Bson bson)
bson - 自定义Children sample(long size)
size - 数量Children replaceRoot(ReplaceRoot... replaceRoot)
replaceRoot - replaceRoot类,会使用mergeObjects操作符将值组合起来Children replaceRoot(List<ReplaceRoot> replaceRootList)
replaceRootList - replaceRoot集合,会使用mergeObjects操作符将值组合起来Children replaceRoot(String... field)
field - 指定字段,传递多个值时会使用mergeObjects操作符组合起来Children replaceRoot(Boolean reserveOriginalDocument, SFunction<T,Object>... field)
reserveOriginalDocument - 是否保留原始文档字段field - 指定字段,传递多个值时会使用mergeObjects操作符组合起来Children replaceRoot(Boolean reserveOriginalDocument, String... field)
reserveOriginalDocument - 是否保留原始文档字段field - 指定字段,传递多个值时会使用mergeObjects操作符组合起来Children replaceRoot(com.mongodb.BasicDBObject basicDBObject)
basicDBObject - 自定义Children replaceRoot(org.bson.conversions.Bson bson)
bson - 自定义Children unionWith(com.mongodb.BasicDBObject basicDBObject)
basicDBObject - 自定义Children unionWith(org.bson.conversions.Bson bson)
bson - 自定义@Deprecated Children out(String coll)
这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据
coll - 集合名Children out(String db, String coll)
这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据
db - 库coll - 集合名Children out(com.mongodb.BasicDBObject basicDBObject)
这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据
basicDBObject - 自定义Children out(org.bson.conversions.Bson bson)
这个必须是管道操作中的最后一步,如果输出到现有集合,会覆盖原数据
bson - 自定义Children custom(com.mongodb.BasicDBObject basicDBObject)
Children custom(org.bson.conversions.Bson bson)
Children allowDiskUse(boolean allowDiskUse)
Children collation(com.mongodb.client.model.CollationStrength collationStrength)
collationStrength - 枚举Children maxTimeMS(long maxTime)
maxTime - 执行时间Children maxAwaitTimeMS(long maxAwaitTime)
maxAwaitTime - 最大等待时间Children bypassDocumentValidation(boolean bypassDocumentValidation)
bypassDocumentValidation - 如果为true,则允许写入选择退出文档级验证。Children comment(org.bson.BsonValue comment)
comment - 注释Children hint(org.bson.conversions.Bson hint)
hint - 提示Children let(org.bson.conversions.Bson variables)
variables - 变量Children project(com.mongodb.BasicDBObject basicDBObject)
basicDBObject - project值Children project(org.bson.conversions.Bson bson)
bson - project值Copyright © 2023. All rights reserved.