Elasticsearch#

1
PUT /索引库名称
2
{
3
  "mappings": {
4
    "properties": {
5
      "字段名":{
6
        "type": "text",
7
        "analyzer": "ik_smart"
8
      },
9
      "字段名2":{
10
        "type": "keyword",
11
        "index": "false"
12
      },
13
      "字段名3":{
14
        "properties": {
15
          "子字段": {
16
            "type": "keyword"
17
          }
18
        }
19
      },
20
      // ...略
21
    }
22
  }
23
}

1
PUT /heima
2
{
3
  "mappings": {
4
    "properties": {
5
      "info":{
6
        "type":"text",
7
        "analyzer": "ik_smart"
8
      },
9
      "age":{
10
        "type": "byte"
11
      },
12
      "email":{
13
        "type": "keyword",
14
        "index": false
15
      },
16
      "name":{
17
        "type": "object",
18
        "properties": {
19
          "firstName":{
20
            "type":"keyword"
21
          },
22
          "lastName":{
23
            "type":"keyword"
24
          }
25
        }
26
      }
27
    }
28
  }
29
}

1
{
2
  "acknowledged" : true,
3
  "shards_acknowledged" : true,
4
  "index" : "heima"
5
}

1
GET /索引库名

1
GET /heima

1
DELETE /索引库名

1
DELETE /heima

1
PUT /索引库名/_mapping
2
{
3
  "properties": {
4
    "新字段名":{
5
      "type": "integer"
6
    }
7
  }
8
}

1
PUT /heima/_mapping
2
{
3
  "properties": {
4
    "age":{
5
      "type": "integer"
6
    }
7
  }
8
}

1
PUT /heima/_mapping
2
{
3
  "properties":{
4
    "otherInfo":{
5
      "type":"text"
6
    }
7
  }
8
}

1
POST /索引库名/_doc/文档id
2
{
3
    "字段1": "值1",
4
    "字段2": "值2",
5
    "字段3": {
6
        "子属性1": "值3",
7
        "子属性2": "值4"
8
    },
9
}

1
POST /heima/_doc/1
2
{
3
  "info": "zxyang study java",
4
    "email": "zzyang.cn",
5
    "name": {
6
        "firstName": "云",
7
        "lastName": "赵"
8
    }
9
}

1
{
2
  "_index" : "heima",
3
  "_type" : "_doc",
4
  "_id" : "1",
5
  "_version" : 1,
6
  "result" : "created",
7
  "_shards" : {
8
    "total" : 2,
9
    "successful" : 1,
10
    "failed" : 0
11
  },
12
  "_seq_no" : 0,
13
  "_primary_term" : 2
14
}
15

16
// 下划线代表内置变量，跟Python类似

1
GET /{索引库名称}/_doc/{id}

1
GET /heima/_doc/1

1
{
2
  "_index" : "heima",
3
  "_type" : "_doc",
4
  "_id" : "1",
5
  "_version" : 1,
6
  "_seq_no" : 0,
7
  "_primary_term" : 2,
8
  "found" : true,
9
  "_source" : {
10
    "info" : "zxyang study java",
11
    "email" : "zzyang.cn",
12
    "name" : {
13
      "firstName" : "云",
14
      "lastName" : "赵"
15
    }
16
  }
17
}

1
DELETE /{索引库名}/_doc/id值

1
DELETE /heima/_doc/1

1
{
2
  "_index" : "heima",
3
  "_type" : "_doc",
4
  "_id" : "1",
5
  "_version" : 2,
6
  "result" : "deleted",
7
  "_shards" : {
8
    "total" : 2,
9
    "successful" : 1,
10
    "failed" : 0
11
  },
12
  "_seq_no" : 1,
13
  "_primary_term" : 2
14
}

1
POST _bulk
2
{ "index" : { "_index" : "test", "_id" : "1" } }
3
{ "field1" : "value1" }
4
{ "delete" : { "_index" : "test", "_id" : "2" } }
5
{ "create" : { "_index" : "test", "_id" : "3" } }
6
{ "field1" : "value3" }
7
{ "update" : {"_id" : "1", "_index" : "test"} }
8
{ "doc" : {"field2" : "value2"} }

1
POST /_bulk
2
{"index": {"_index":"heima", "_id": "3"}}
3
{"info": "黑马程序员C++讲师", "email": "ww@itcast.cn", "name":{"firstName": "五", "lastName":"王"}}
4
{"index": {"_index":"heima", "_id": "4"}}
5
{"info": "黑马程序员前端讲师", "email": "zhangsan@itcast.cn", "name":{"firstName": "三", "lastName":"张"}}

1
POST /_bulk
2
{"delete":{"_index":"heima", "_id": "3"}}
3
{"delete":{"_index":"heima", "_id": "4"}}

1
<dependency>
2
    <groupId>org.elasticsearch.client</groupId>
3
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
4
</dependency>

1
  <properties>
2
      <maven.compiler.source>11</maven.compiler.source>
3
      <maven.compiler.target>11</maven.compiler.target>
4
      <elasticsearch.version>7.12.1</elasticsearch.version>
5
  </properties>

1
RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(
2
        HttpHost.create("http://192.168.150.101:9200")
3
));

1
public class ElasticSearchTest {
2

3
    private RestHighLevelClient restHighLevelClient;
4

5
    @Test
6
    void testConnection() {
7
        System.out.println(restHighLevelClient);
8
    }
9

10
    @BeforeEach
11
    void setUp() {
12
        restHighLevelClient = new RestHighLevelClient(RestClient.builder(
13
                HttpHost.create("http://192.168.146.131:9200")
14
        ));
15
    }
16

17
    @AfterEach
18
    void tearDown() throws IOException {
19
        if (restHighLevelClient != null) {
20
            restHighLevelClient.close();
21
        }
22
    }
23
}

1
restHighLevelClient = new RestHighLevelClient(
2
    RestClient.builder(
3
        new HttpHost("192.168.146.131", 9200, "http"),
4
        new HttpHost("192.168.146.132", 9200, "http")
5
    )
6
);

1
PUT /items
2
{
3
  "mappings": {
4
    "properties": {
5
      "id": {
6
        "type": "keyword"
7
      },
8
      "name":{
9
        "type": "text",
10
        "analyzer": "ik_max_word"
11
      },
12
      "price":{
13
        "type": "integer"
14
      },
15
      "image":{
16
        "type": "keyword",
17
        "index": false
18
      },
19
      "category":{
20
        "type": "keyword"
21
      },
22
      "brand":{
23
        "type": "keyword"
24
      },
25
      "sold":{
26
        "type": "integer"
27
      },
28
      "commentCount":{
29
        "type": "integer",
30
        "index": false
31
      },
32
      "isAD":{
33
        "type": "boolean"
34
      },
35
      "updateTime":{
36
        "type": "date"
37
      }
38
    }
39
  }
40
}

1
public class ElasticSearchTest {
2

3
    private RestHighLevelClient restHighLevelClient;
4

5
    @Test
6
    void testConnection() {
7
        System.out.println(restHighLevelClient);
8
    }
9

10
    @BeforeEach
11
    void setUp() {
12
        restHighLevelClient = new RestHighLevelClient(RestClient.builder(
13
                HttpHost.create("http://192.168.146.131:9200")
14
        ));
15
    }
16

17
    @AfterEach
18
    void tearDown() throws IOException {
19
        if (restHighLevelClient != null) {
20
            restHighLevelClient.close();
21
        }
22
    }
23

24
    @Test
25
    void testCreateIndex() throws IOException {
26
        // 1.准备request对象
27
        CreateIndexRequest request = new CreateIndexRequest("items");
28
        // 2.准备请求参数
29
        request.source(MAPPING_TEMPLATE, XContentType.JSON);
30
        // 3.发送请求
31
        restHighLevelClient.indices().create(request, RequestOptions.DEFAULT);
32
    }
33

34
    private final static String MAPPING_TEMPLATE = "{\n" +
35
            "  \"mappings\": {\n" +
36
            "    \"properties\": {\n" +
37
            "      \"id\": {\n" +
38
            "        \"type\": \"keyword\"\n" +
39
            "      },\n" +
40
            "      \"name\":{\n" +
41
            "        \"type\": \"text\",\n" +
42
            "        \"analyzer\": \"ik_max_word\"\n" +
43
            "      },\n" +
44
            "      \"price\":{\n" +
45
            "        \"type\": \"integer\"\n" +
46
            "      },\n" +
47
            "      \"image\":{\n" +
48
            "        \"type\": \"keyword\",\n" +
49
            "        \"index\": false\n" +
50
            "      },\n" +
51
            "      \"category\":{\n" +
52
            "        \"type\": \"keyword\"\n" +
53
            "      },\n" +
54
            "      \"brand\":{\n" +
55
            "        \"type\": \"keyword\"\n" +
56
            "      },\n" +
57
            "      \"sold\":{\n" +
58
            "        \"type\": \"integer\"\n" +
59
            "      },\n" +
60
            "      \"commentCount\":{\n" +
61
            "        \"type\": \"integer\",\n" +
62
            "        \"index\": false\n" +
63
            "      },\n" +
64
            "      \"isAD\":{\n" +
65
            "        \"type\": \"boolean\"\n" +
66
            "      },\n" +
67
            "      \"updateTime\":{\n" +
68
            "        \"type\": \"date\"\n" +
69
            "      }\n" +
70
            "    }\n" +
71
            "  }\n" +
72
            "}";
73
}

1
    @Test
2
    void testGetIndex() throws IOException {
3
        // 1.准备request对象
4
        GetIndexRequest request = new GetIndexRequest("items");
5
        // 3.发送请求
6
        GetIndexResponse getIndexResponse = restHighLevelClient.indices().get(request, RequestOptions.DEFAULT);
7
        System.out.println(getIndexResponse);
8
    }

1
    @Test
2
    void testGetIndex() throws IOException {
3
        // 1.准备request对象
4
        GetIndexRequest request = new GetIndexRequest("items");
5
        // 3.发送请求
6
        boolean exists = restHighLevelClient.indices().exists(request, RequestOptions.DEFAULT);
7
        System.out.println(exists);
8
    }

1
    @Test
2
    void testDeleteIndex() throws IOException {
3
        // 1.准备request对象
4
        DeleteIndexRequest request = new DeleteIndexRequest("items");
5
        // 3.发送请求
6
        restHighLevelClient.indices().delete(request, RequestOptions.DEFAULT);
7
    }