我在 C# 中使用 elasticsearch.net 库,并尝试查询与指定过滤器匹配的对象。
我希望查询返回对象的名称集合中至少存在一个来自过滤器的输入名称的对象。
问题是这个查询的结果总是 0 次命中,即使我确定数据库中确实存在与指定过滤器匹配的数据,我很想找出我的查询有什么问题......
该模型:
public class A
{
public int AId { get; set; }
public IEnumerable<string> Names { get; set; }
}
过滤对象:
public class Filter
{
public IEnumerable<string> NamesToSearch { get; set; }
}
查询数据的方法:
public async Task<IEnumerable<A>> GetFilteredData(Filter filter)
{
var query = await _elasticClient.SearchAsync<A>(x => x.Query(q => q.Terms(a => a.Names, filter.NamesToSearch))
.Fields(a => a.AId, a => a.Names));
return query.Hits
.Select(x => new A
{
AId = x.Fields.FieldValues<A, int>(a => a.AId)[0]
})
.ToList();
}
我也尝试过以下查询,但也没有产生预期的结果:
var query = await _elasticClient.SearchAsync<A>(x => x.Query(q => q.Nested(n => n.Filter(f => f.Terms(y => y.Names, filter.NamesToSearch))))
.Fields(a => a.AId, a => a.Names));
对我有用的解决方案:
我已经从Sławomir Rosiek 的答案中升级了一些代码,以使用 ElasticSearch.net 1.7.1 实际编译并且是类型安全的(没有通过字符串引用字段名称)并最终得到以下扩展方法,这对我的场景来说就像一个魅力:
public static QueryContainer MatchAnyTerm<T>(this QueryDescriptor<T> descriptor, Expression<Func<T, object>> field, object[] values) where T : class, new()
{
var queryContainer = new QueryContainer();
foreach (var value in values)
{
queryContainer |= descriptor.Term(t => t.OnField(field).Value(value));
}
return queryContainer;
}
和用法:
var query = await _elasticClient.SearchAsync<A>(x => x.Query(q =>
q.Bool(b =>
b.Should(s => s.MatchAnyTerm(a => a.Names, filter.NamesToSearch.ToArray()))
.Fields(a => a.AId, a => a.Names));