1. 设置Mapping

  1. DELETE my_blogs
  3. # 设定 Parent/Child Mapping
  4. PUT my_blogs
  5. {
  6.   "settings": {
  7.     "number_of_shards": 2
  8.   },
  9.   "mappings": {
  10.     "properties": {
  11.       "blog_comments_relation": {
  12.         "type": "join",
  13.         "relations": {
  14.           "blog": "comment"
  15.         }
  16.       },
  17.       "content": {
  18.         "type": "text"
  19.       },
  20.       "title": {
  21.         "type": "keyword"
  22.       }
  23.     }
  24.   }
  25. }

2. 索引父文档

  1. #索引父文档
  2. PUT my_blogs/_doc/blog1
  3. {
  4.   "title":"Learning Elasticsearch",
  5.   "content":"learning ELK @ geektime",
  6.   "blog_comments_relation":{
  7.     "name":"blog"
  8.   }
  9. }
  11. #索引父文档
  12. PUT my_blogs/_doc/blog2
  13. {
  14.   "title":"Learning Hadoop",
  15.   "content":"learning Hadoop",
  16.     "blog_comments_relation":{
  17.     "name":"blog"
  18.   }
  19. }

3. 索引子文档

  1. #索引子文档
  2. PUT my_blogs/_doc/comment1?routing=blog1
  3. {
  4.   "comment":"I am learning ELK",
  5.   "username":"Jack",
  6.   "blog_comments_relation":{
  7.     "name":"comment",
  8.     "parent":"blog1"
  9.   }
  10. }
  12. #索引子文档
  13. PUT my_blogs/_doc/comment2?routing=blog2
  14. {
  15.   "comment":"I like Hadoop!!!!!",
  16.   "username":"Jack",
  17.   "blog_comments_relation":{
  18.     "name":"comment",
  19.     "parent":"blog2"
  20.   }
  21. }
  23. #索引子文档
  24. PUT my_blogs/_doc/comment3?routing=blog2
  25. {
  26.   "comment":"Hello Hadoop",
  27.   "username":"Bob",
  28.   "blog_comments_relation":{
  29.     "name":"comment",
  30.     "parent":"blog2"
  31.   }
  32. }

4. Parent/Child所支持的查询

4.1 查询所有文档

  1. # 查询所有文档
  2. POST my_blogs/_search
  3. {
  5. }
  7. #####返回结果部分内容，发现它们都是独立的文档
  8. "hits" : [
  9.       {
  10.         "_index" : "my_blogs",
  11.         "_type" : "_doc",
  12.         "_id" : "blog1",
  13.         "_score" : 1.0,
  14.         "_source" : {
  15.           "title" : "Learning Elasticsearch",
  16.           "content" : "learning ELK @ geektime",
  17.           "blog_comments_relation" : {
  18.             "name" : "blog"
  19.           }
  20.         }
  21.       },
  22.       {
  23.         "_index" : "my_blogs",
  24.         "_type" : "_doc",
  25.         "_id" : "blog2",
  26.         "_score" : 1.0,
  27.         "_source" : {
  28.           "title" : "Learning Hadoop",
  29.           "content" : "learning Hadoop",
  30.           "blog_comments_relation" : {
  31.             "name" : "blog"
  32.           }
  33.         }
  34.       },
  35.       {
  36.         "_index" : "my_blogs",
  37.         "_type" : "_doc",
  38.         "_id" : "comment1",
  39.         "_score" : 1.0,
  40.         "_routing" : "blog1",
  41.         "_source" : {
  42.           "comment" : "I am learning ELK",
  43.           "username" : "Jack",
  44.           "blog_comments_relation" : {
  45.             "name" : "comment",
  46.             "parent" : "blog1"
  47.           }
  48.         }
  49.       },
  50.       {
  51.         "_index" : "my_blogs",
  52.         "_type" : "_doc",
  53.         "_id" : "comment2",
  54.         "_score" : 1.0,
  55.         "_routing" : "blog2",
  56.         "_source" : {
  57.           "comment" : "I like Hadoop!!!!!",
  58.           "username" : "Jack",
  59.           "blog_comments_relation" : {
  60.             "name" : "comment",
  61.             "parent" : "blog2"
  62.           }
  63.         }
  64.       },
  65.       {
  66.         "_index" : "my_blogs",
  67.         "_type" : "_doc",
  68.         "_id" : "comment3",
  69.         "_score" : 1.0,
  70.         "_routing" : "blog2",
  71.         "_source" : {
  72.           "comment" : "Hello Hadoop",
  73.           "username" : "Bob",
  74.           "blog_comments_relation" : {
  75.             "name" : "comment",
  76.             "parent" : "blog2"
  77.           }
  78.         }
  79.       }
  80.     ]

4.2 根据父文档ID查看

  1. #根据父文档ID查看，返回要查看的父文档
  2. GET my_blogs/_doc/blog2
  4. # Parent Id 查询，其下所属的子文档
  5. POST my_blogs/_search
  6. {
  7.   "query": {
  8.     "parent_id": {
  9.       "type": "comment",
  10.       "id": "blog2"
  11.     }
  12.   }
  13. }
  14. #####返回结果的部分内容，返回父文档id对应下的子文档
  15. "hits" : [
  16.       {
  17.         "_index" : "my_blogs",
  18.         "_type" : "_doc",
  19.         "_id" : "comment2",
  20.         "_score" : 0.5389965,
  21.         "_routing" : "blog2",
  22.         "_source" : {
  23.           "comment" : "I like Hadoop!!!!!",
  24.           "username" : "Jack",
  25.           "blog_comments_relation" : {
  26.             "name" : "comment",
  27.             "parent" : "blog2"
  28.           }
  29.         }
  30.       },
  31.       {
  32.         "_index" : "my_blogs",
  33.         "_type" : "_doc",
  34.         "_id" : "comment3",
  35.         "_score" : 0.5389965,
  36.         "_routing" : "blog2",
  37.         "_source" : {
  38.           "comment" : "Hello Hadoop",
  39.           "username" : "Bob",
  40.           "blog_comments_relation" : {
  41.             "name" : "comment",
  42.             "parent" : "blog2"
  43.           }
  44.         }
  45.       }
  46.     ]

4.3 Has Child 查询，返回父文档

  1. # Has Child 查询,返回父文档
  2. POST my_blogs/_search
  3. {
  4.   "query": {
  5.     "has_child": {
  6.       "type": "comment",
  7.       "query" : {
  8.                 "match": {
  9.                     "username" : "Jack"
  10.                 }
  11.             }
  12.     }
  13.   }
  14. }
  15. #####返回结果部分内容
  16. "hits" : [
  17.       {
  18.         "_index" : "my_blogs",
  19.         "_type" : "_doc",
  20.         "_id" : "blog1",
  21.         "_score" : 1.0,
  22.         "_source" : {
  23.           "title" : "Learning Elasticsearch",
  24.           "content" : "learning ELK @ geektime",
  25.           "blog_comments_relation" : {
  26.             "name" : "blog"
  27.           }
  28.         }
  29.       },
  30.       {
  31.         "_index" : "my_blogs",
  32.         "_type" : "_doc",
  33.         "_id" : "blog2",
  34.         "_score" : 1.0,
  35.         "_source" : {
  36.           "title" : "Learning Hadoop",
  37.           "content" : "learning Hadoop",
  38.           "blog_comments_relation" : {
  39.             "name" : "blog"
  40.           }
  41.         }
  42.       }
  43.     ]

4.4 Has Parent 查询，返回相关的子文档

# Has Parent 查询，返回相关的子文档
POST my_blogs/_search
{
  "query": {
    "has_parent": {
      "parent_type": "blog",
      "query" : {
                "match": {
                    "title" : "Learning Hadoop"
                }
            }
    }
  }
}
#####返回结果部分内容
"hits" : [
      {
        "_index" : "my_blogs",
        "_type" : "_doc",
        "_id" : "comment2",
        "_score" : 1.0,
        "_routing" : "blog2",
        "_source" : {
          "comment" : "I like Hadoop!!!!!",
          "username" : "Jack",
          "blog_comments_relation" : {
            "name" : "comment",
            "parent" : "blog2"
          }
        }
      },
      {
        "_index" : "my_blogs",
        "_type" : "_doc",
        "_id" : "comment3",
        "_score" : 1.0,
        "_routing" : "blog2",
        "_source" : {
          "comment" : "Hello Hadoop",
          "username" : "Bob",
          "blog_comments_relation" : {
            "name" : "comment",
            "parent" : "blog2"
          }
        }
      }
    ]

5. 访问子文档

#通过ID ，访问不到子文档
GET my_blogs/_doc/comment3
#####找不到子文档
{
  "_index" : "my_blogs",
  "_type" : "_doc",
  "_id" : "comment3",
  "found" : false
}

#通过ID和routing ，访问子文档
GET my_blogs/_doc/comment3?routing=blog2
######返回结果
{
  "_index" : "my_blogs",
  "_type" : "_doc",
  "_id" : "comment3",
  "_version" : 1,
  "_seq_no" : 4,
  "_primary_term" : 1,
  "_routing" : "blog2",
  "found" : true,
  "_source" : {
    "comment" : "Hello Hadoop",
    "username" : "Bob",
    "blog_comments_relation" : {
      "name" : "comment",
      "parent" : "blog2"
    }
  }
}

6. 更新子文档

#更新子文档，Index方式全量替换修改document
PUT my_blogs/_doc/comment3?routing=blog2
{
    "comment": "Hello Hadoop??",
    "blog_comments_relation": {
      "name": "comment",
      "parent": "blog2"
    }
}
#更新子文档，partial update方式修改document
POST my_blogs/_update/comment3?routing=blog2
{
  "doc":{
    "comment":"Hello Hadoop==="
  }
}
######返回结果
{
  "_index" : "my_blogs",
  "_type" : "_doc",
  "_id" : "comment3",
  "_version" : 2,
  "result" : "updated",
  "_shards" : {
    "total" : 2,
    "successful" : 1,
    "failed" : 0
  },
  "_seq_no" : 5,
  "_primary_term" : 1
}