Elastica PHP中如何实现Group by？是否存在相关聚合功能？

嘿，我来帮你搞定Elastica里的分组统计需求哈～首先明确说：Elastica完全支持类似SQL Group by的聚合功能，它对应Elasticsearch里的聚合机制（比如terms聚合实现单字段分组，composite聚合实现多字段分组），完全不需要单独写原生查询去拼接，直接就能和你现有的Bool过滤代码结合起来。

一、和现有过滤代码结合的基础示例（单字段分组） #

你现有的代码是用Bool查询做过滤，只需要在Query对象上添加聚合组件就行，举个具体的例子：

假设你要按category字段分组统计文档数量，结合你已有的过滤逻辑：

// 你的原有过滤逻辑
$bool_sub = new \Elastica\Query\Bool();
// 这里可以给bool_sub添加具体的过滤条件，比如match、range等
// $bool_sub->addMust(new \Elastica\Query\Match(['title' => 'xxx']));

$bool = new \Elastica\Query\Bool();
$bool->addMust($bool_sub);
$query = new \Elastica\Query();
$query->setFilter($bool);

// 添加Group by对应的terms聚合
$groupAgg = new \Elastica\Aggregation\Terms('group_by_category');
$groupAgg->setField('category'); // 指定分组字段，对应SQL GROUP BY category
$groupAgg->setOrder(['_count' => 'desc']); // 按分组数量降序排列
$groupAgg->setSize(100); // 设置返回的分组数量，默认是10

// 将聚合绑定到查询上
$query->addAggregation($groupAgg);

// 执行查询（假设你已经初始化了$client和$index实例）
$searchResult = $index->search($query);

// 解析聚合结果
$aggResults = $searchResult->getAggregation('group_by_category');
foreach ($aggResults['buckets'] as $bucket) {
    echo "分类名称：{$bucket['key']}，文档数量：{$bucket['doc_count']}\n";
}

二、实现多字段分组（类似SQL GROUP BY col1, col2） #

如果你的需求是像SQL那样按多个字段分组，就用Composite聚合，示例如下：

// 原有过滤逻辑不变，直接添加复合聚合
$compositeAgg = new \Elastica\Aggregation\Composite('group_by_multi_fields');
// 定义要分组的多个字段
$sources = [
    new \Elastica\Aggregation\Composite\TermsSource('category', 'category'),
    new \Elastica\Aggregation\Composite\TermsSource('brand', 'brand')
];
$compositeAgg->setSources($sources);
$compositeAgg->setSize(50); // 设置返回的分组数量

$query->addAggregation($compositeAgg);

// 解析结果
$aggResults = $searchResult->getAggregation('group_by_multi_fields');
foreach ($aggResults['buckets'] as $bucket) {
    echo "分类：{$bucket['key']['category']}，品牌：{$bucket['key']['brand']}，数量：{$bucket['doc_count']}\n";
}

三、更复杂的分组后计算（比如求和、平均值） #

如果分组后还需要计算统计值（类似SQL GROUP BY ... SUM()/AVG()），可以在分组聚合里嵌套子聚合：

// 原有过滤逻辑不变
$bool_sub = new \Elastica\Query\Bool();
$bool = new \Elastica\Query\Bool();
$bool->addMust($bool_sub);
$query = new \Elastica\Query();
$query->setFilter($bool);

// 分组聚合
$termsAgg = new \Elastica\Aggregation\Terms('group_by_category');
$termsAgg->setField('category');

// 嵌套求和聚合，计算每个分类的总销售额
$sumSalesAgg = new \Elastica\Aggregation\Sum('total_sales');
$sumSalesAgg->setField('sales_amount');
$termsAgg->addAggregation($sumSalesAgg);

$query->addAggregation($termsAgg);

// 解析结果时可以拿到每个分组的总销售额
$aggResults = $searchResult->getAggregation('group_by_category');
foreach ($aggResults['buckets'] as $bucket) {
    echo "分类：{$bucket['key']}，数量：{$bucket['doc_count']}，总销售额：{$bucket['total_sales']['value']}\n";
}

为什么不用原生查询拼接？ #

Elastica的Query对象本身就支持同时承载过滤条件和聚合逻辑，直接把聚合加到你现有的查询上即可，这样代码更统一，也避免了原生查询和Elastica对象模型冲突的问题，完全不需要额外去合并两种查询结果。

内容的提问来源于stack exchange，提问作者user9653591