use serde::{Deserialize, Serialize};
use crate::{search::*, util::*};
#[derive(Debug, Default, Clone, PartialEq, Deserialize, Serialize)]
#[serde(remote = "Self")]
pub struct BoolQuery {
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
must: QueryCollection,
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
filter: QueryCollection,
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
should: QueryCollection,
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
must_not: QueryCollection,
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
minimum_should_match: Option<String>,
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
boost: Option<f32>,
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
_name: Option<String>,
}
impl Query {
pub fn bool() -> BoolQuery {
BoolQuery::default()
}
}
impl BoolQuery {
add_boost_and_name!();
pub fn must<T>(mut self, query: T) -> Self
where
T: IntoIterator,
T::Item: Into<Query>,
{
self.must.extend(query);
self
}
pub fn should<T>(mut self, query: T) -> Self
where
T: IntoIterator,
T::Item: Into<Query>,
{
self.should.extend(query);
self
}
pub fn filter<T>(mut self, query: T) -> Self
where
T: IntoIterator,
T::Item: Into<Query>,
{
self.filter.extend(query);
self
}
pub fn must_not<T>(mut self, query: T) -> Self
where
T: IntoIterator,
T::Item: Into<Query>,
{
self.must_not.extend(query);
self
}
pub fn minimum_should_match<T>(mut self, minimum_should_match: T) -> Self
where
T: ToString,
{
self.minimum_should_match = Some(minimum_should_match.to_string());
self
}
}
impl ShouldSkip for BoolQuery {
fn should_skip(&self) -> bool {
self.must.should_skip()
&& self.filter.should_skip()
&& self.should.should_skip()
&& self.must_not.should_skip()
}
}
serialize_with_root!("bool": BoolQuery);
deserialize_with_root!("bool": BoolQuery);
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn serialization() {
assert_serialize_query(Query::bool(), json!({ "bool": {} }));
assert_serialize_query(
Query::bool()
.must([Query::term("test1", 1), Query::term("test2", 2)])
.should([Query::term("test1", 3), Query::term("test2", 4)])
.filter([Query::term("test1", 5), Query::term("test2", 6)])
.must_not([Query::term("test1", 7), Query::term("test2", 8)])
.minimum_should_match("2")
.boost(1.3)
.name("test"),
json!({
"bool": {
"must":[
{ "term": { "test1": {"value": 1} } },
{ "term": { "test2": {"value": 2} } },
],
"should":[
{ "term": { "test1": {"value": 3} } },
{ "term": { "test2": {"value": 4} } },
],
"filter":[
{ "term": { "test1": {"value": 5} } },
{ "term": { "test2": {"value": 6} } },
],
"must_not":[
{ "term": { "test1": {"value": 7} } },
{ "term": { "test2": {"value": 8} } },
],
"minimum_should_match": "2",
"boost": 1.3,
"_name":"test"
}
}),
);
assert_serialize_query(
Query::bool()
.must(Query::term("test1", 1))
.must(Query::term("test2", 2))
.should(Query::term("test1", 3))
.should(Query::term("test2", 4))
.filter(Query::term("test1", 5))
.filter(Query::term("test2", 6))
.must_not(Query::term("test1", 7))
.must_not(Query::term("test2", 8))
.minimum_should_match("2")
.boost(1.3)
.name("test"),
json!({
"bool": {
"must":[
{ "term": { "test1": {"value": 1} } },
{ "term": { "test2": {"value": 2} } },
],
"should":[
{ "term": { "test1": {"value": 3} } },
{ "term": { "test2": {"value": 4} } },
],
"filter":[
{ "term": { "test1": {"value": 5} } },
{ "term": { "test2": {"value": 6} } },
],
"must_not":[
{ "term": { "test1": {"value": 7} } },
{ "term": { "test2": {"value": 8} } },
],
"minimum_should_match": "2",
"boost": 1.3,
"_name":"test"
}
}),
);
}
}