Elastic学习之旅 (12) .NET 6应用集成ES - 下 - 码农

2024-04-23码农

大家好，我是Edison。

写在开头

在.NET应用中集成ES一般涉及两个方面：

（1）将ES当存储用，类似于MongoDB，做文档的增删查改，这一类操作偏CRUD。

（2）对ES中的数据做查询分析，聚合统计、分组等等，这一类操作偏查询分析。

上一篇我们了解了CRUD，我们今天再来搞定查询和聚合作为本系列的结尾！

增加模型

为了进行今天的查询和聚合，我们在上一篇的demo项目中增加一个Product模型。都是常规字段，就不再解释了。

public classProduct : ElasticModelBase{publicstring Ean { get; set; }publicstring Name { get; set; }publicstring Description { get; set; }publicstring Brand { get; set; }publicstring Category { get; set; }publicdecimal Price { get; set; }publicint Quantity { get; set; }public DateTime ReleaseDate { get; set; }}

与此同时，新增一个ProductRepository：

public class ProductRepository : ElasticRepositoryBase<Product>, IProductRepository{public ProductRepository(IElasticProxy elasticProxy) : base(elasticProxy) { }protected override string IndexName => "products";}

分页查询

我们在上一篇的demo项目中其实已经做了分页查询的基础实现了：

publicvirtualasync Task<Tuple<int, IList<T>>> QueryAsync(int page, int limit){var query = awaitthis.Client.SearchAsync<T>(x => x.Index(this.IndexName) .From((page -1) * limit) .Size(limit));returnnew Tuple<int, IList<T>>(Convert.ToInt32(query.Total), query.Documents.ToList());}

但很多时候我们还想要根据某个字段排序，我们可以在上一篇的基类的基础上重写一下，在ProductRepository就可以实现：

public override async Task<Tuple<int, IList<Product>>> QueryAsync(int page, int limit){var query = awaitthis.Client.SearchAsync<Product>(x => x.Index(this.IndexName) .From((page - 1) * limit) .Size(limit) .Sort(x => x.Descending(v => v.ReleaseDate)));returnnew Tuple<int, IList<Product>>(Convert.ToInt32(query.Total), query.Documents.ToList());}

条件查询（基于Term）

我们在之前的学习中学习了结构化搜索主要是通过Term来进行查询，那么假如我们想要根据EAN字段来查询某个product，则可以在ProductRepository中新增一个方法来实现：

publicasync Task<IList<Product>> QueryByEanAsync(string ean){var result = awaitthis.Client.SearchAsync<Product>(x => x.Index(this.IndexName) .Query(q => q.Term(p => p.Ean, ean)));return result.Documents.ToList();}

一般来说，Query的结果默认是document集合。

这里我们测试结果如下：

那么，如果是多条件查询呢？比如：根据一个key查询EAN或Name，这就是多个Term的Or查询：

publicasync Task<IList<Product>> QueryByEanOrNameAsync(string key){var result = awaitthis.Client.SearchAsync<Product>(x => x.Index(this.IndexName) .Query(q => q.Term(p => p.Ean, key) || q.Term(p => p.Name, key)));return result.Documents.ToList();}

比如：根据一个key查询Name并只筛选 Status="Active"的product ，这就是多个Term的And查询：

publicasync Task<IList<Product>> GetActiveProductsByNameAsync(string key){var result = awaitthis.Client.SearchAsync<Product>(x => x.Index(this.IndexName) .Query(q => q.Term(p => p.Name, key) && q.Term(p => p.Status, "Active")));return result.Documents.ToList();}

聚合统计

我们在之前的学习中学习了聚合查询，那么这里我们通过聚合来统计一下Product数据中Price字段的最大值、最小值和平均值：

publicasync Task<Nest.AggregateDictionary> QueryPriceAggAsync(){var searchResult = awaitthis.Client.SearchAsync<Product>(x => x.Index(this.IndexName) .Size(0) // 代表不返回源数据 .Aggregations(agg => agg.Average("price_avg", avg => avg.Field("price")) .Max("price_max", max => max.Field("price")) .Min("price_min", min => min.Field("price"))) );return searchResult.Aggregations;}

聚合分组

如果我们想要根据某个字段分组查询product数据，那么可以使用聚合分组：

publicasync Task<Nest.AggregateDictionary> QueryBrandAggAsync(){var searchResult = awaitthis.Client.SearchAsync<Product>(x => x.Index(this.IndexName) .Size(0) // 代表不返回源数据 .Aggregations(agg => agg.Terms("brandgroup", group => group.Field("brand")) ));return searchResult.Aggregations;}