定义创建索引库的Json参数

:::tips 新建一个常量类，用来存储创建索引库的Json参数常量 :::

  1. public class XxxConstants {
  3.     //mapping映射的字段串常量
  4.     public static final String MAPPING_TEMPLATE = "{\n" +
  5.             "  \"mappings\": {\n" +
  6.             "    \"properties\": {\n" +
  7.             "      \"id\": {\n" +
  8.             "        \"type\": \"long\"\n" +
  9.             "      },\n" +
  10.             "      \"name\":{\n" +
  11.             "        \"type\": \"text\",\n" +
  12.             "        \"analyzer\": \"ik_max_word\",\n" +
  13.             "        \"copy_to\": \"all\"\n" +
  14.             "      },\n" +
  15.             "      \"address\":{\n" +
  16.             "        \"type\": \"keyword\",\n" +
  17.             "        \"index\": false\n" +
  18.             "      },\n" +
  19.             "      \"price\":{\n" +
  20.             "        \"type\": \"integer\"\n" +
  21.             "      },\n" +
  22.             "      \"score\":{\n" +
  23.             "        \"type\": \"integer\"\n" +
  24.             "      },\n" +
  25.             "      \"brand\":{\n" +
  26.             "        \"type\": \"keyword\",\n" +
  27.             "        \"copy_to\": \"all\"\n" +
  28.             "      },\n" +
  29.             "      \"city\":{\n" +
  30.             "        \"type\": \"keyword\",\n" +
  31.             "        \"copy_to\": \"all\"\n" +
  32.             "      },\n" +
  33.             "      \"starName\":{\n" +
  34.             "        \"type\": \"keyword\"\n" +
  35.             "      },\n" +
  36.             "      \"business\":{\n" +
  37.             "        \"type\": \"keyword\"\n" +
  38.             "      },\n" +
  39.             "      \"location\":{\n" +
  40.             "        \"type\": \"geo_point\"\n" +
  41.             "      },\n" +
  42.             "      \"pic\":{\n" +
  43.             "        \"type\": \"keyword\",\n" +
  44.             "        \"index\": false\n" +
  45.             "      },\n" +
  46.             "      \"all\":{\n" +
  47.             "        \"type\": \"text\",\n" +
  48.             "        \"analyzer\": \"ik_max_word\"\n" +
  49.             "      }\n" +
  50.             "    }\n" +
  51.             "  }\n" +
  52.             "}";
  54. }

创建索引库

  1. @SpringBootTest
  2. public class MyTest{
  3.     //注入RestHighLevelClient对象
  4.     @Autowired
  5.     private RestHighLevelClient restHighLevelClient;
  7.     @Test
  8.     public void test() throws IOException {
  9.         //创建CreateIndexRequest请求对象，并指定索引库名
  10.         CreateIndexRequest createIndexRequest = new CreateIndexRequest(索引库名);
  12.         //在CreateIndexRequest请求对象中放入创建索引库的Json参数，并指定参数类型为Json
  13.         createIndexRequest.source(MAPPING_TEMPLATE, XContentType.JSON);
  15.         //发送请求
  16.         restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);
  17.     }
  19. }