aggregate<T extends DbBaseModel> method

@override Future<DbResult<T>> aggregate<T extends DbBaseModel>(String table, List<DbPipeline> pipeline, { DbAggregateOptions? aggregateOptions, required T converter(Map<String, dynamic> map), })

聚合管道操作

• DbResult.success 当 DbResult.resultList!=null 时为true
• DbResult.rescode 返回结果的数量 或 异常标识-1
• DbResult.resultList 类型T的实例数组 或 null

Implementation

@override
Future<DbResult<T>> aggregate<T extends DbBaseModel>(String table, List<DbPipeline> pipeline, {DbAggregateOptions? aggregateOptions, required T Function(Map<String, dynamic> map) converter}) async {
  try {
    final result = await _handle.aggregate(table, pipeline, aggregateOptions: aggregateOptions, converter: converter);
    (result.success ? logDebug : logWarn)(['aggregate =>', table, pipeline, aggregateOptions, result]);
    return result;
  } catch (error, stack) {
    logError(['aggregate =>', table, pipeline, aggregateOptions, error, '\n', stack]);
    return DbResult(success: false, rescode: -1, message: error.toString());
  }
}