use crate::{search::*, util::*};
#[derive(Debug, Clone, PartialEq, Deserialize, Serialize)]
#[serde(remote = "Self")]
pub struct NestedQuery {
path: String,
query: Box<Query>,
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
score_mode: Option<NestedQueryScoreMode>,
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
ignore_unmapped: Option<bool>,
#[serde(default, skip_serializing_if = "ShouldSkip::should_skip")]
inner_hits: Option<Box<InnerHits>>,
#[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 nested<T, U>(path: T, query: U) -> NestedQuery
where
T: ToString,
U: Into<Query>,
{
NestedQuery {
path: path.to_string(),
query: Box::new(query.into()),
score_mode: None,
ignore_unmapped: None,
inner_hits: None,
boost: None,
_name: None,
}
}
}
impl NestedQuery {
add_boost_and_name!();
pub fn score_mode(mut self, score_mode: NestedQueryScoreMode) -> Self {
self.score_mode = Some(score_mode);
self
}
pub fn ignore_unmapped(mut self, ignore_unmapped: bool) -> Self {
self.ignore_unmapped = Some(ignore_unmapped);
self
}
pub fn inner_hits(mut self, inner_hits: InnerHits) -> Self {
self.inner_hits = Some(Box::new(inner_hits));
self
}
}
impl ShouldSkip for NestedQuery {
fn should_skip(&self) -> bool {
self.query.should_skip()
}
}
serialize_with_root!("nested": NestedQuery);
deserialize_with_root!("nested": NestedQuery);
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn serialization() {
assert_serialize_query(
Query::nested("vehicles", Query::term("vehicles.license", "ABC123")),
json!({
"nested": {
"path": "vehicles",
"query": {
"term": {
"vehicles.license": {
"value": "ABC123"
}
}
}
}
}),
);
assert_serialize_query(
Query::nested("vehicles", Query::term("vehicles.license", "ABC123"))
.boost(3)
.name("test"),
json!({
"nested": {
"path": "vehicles",
"query": {
"term": {
"vehicles.license": {
"value": "ABC123"
}
}
},
"boost": 3.0,
"_name": "test",
}
}),
);
assert_serialize_query(
Query::nested(
"driver",
Query::nested(
"driver.vehicles",
Query::term("driver.vehicles.make.keyword", "toyota"),
),
),
json!({
"nested": {
"path": "driver",
"query": {
"nested": {
"path": "driver.vehicles",
"query": {
"term": {
"driver.vehicles.make.keyword": {
"value": "toyota"
}
}
}
}
}
}
}),
);
}
}