1. JAVA API

官网的资料才是最新的，最全的：https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/java-rest-overview.html

引入maven

  1. <dependency>
  2.     <groupId>org.elasticsearch.client</groupId>
  3.     <artifactId>elasticsearch-rest-high-level-client</artifactId>
  4.     <version>7.11.1</version>
  5. </dependency>
  7. <repositories>
  8.     <repository>
  9.         <id>es-snapshots</id>
  10.         <name>elasticsearch snapshot repo</name>
  11.         <url>https://snapshots.elastic.co/maven/</url>
  12.     </repository>
  13. </repositories>
  15. <repository>
  16.     <id>elastic-lucene-snapshots</id>
  17.     <name>Elastic Lucene Snapshots</name>
  18.     <url>https://s3.amazonaws.com/download.elasticsearch.org/lucenesnapshots/83f9835</url>
  19.     <releases><enabled>true</enabled></releases>
  20.     <snapshots><enabled>false</enabled></snapshots>
  21. </repository>

1.1 基本增删改查

  1. import org.apache.http.HttpHost;
  2. import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
  3. import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
  4. import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
  5. import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse;
  6. import org.elasticsearch.action.bulk.BulkRequest;
  7. import org.elasticsearch.action.bulk.BulkResponse;
  8. import org.elasticsearch.action.delete.DeleteRequest;
  9. import org.elasticsearch.action.delete.DeleteResponse;
  10. import org.elasticsearch.action.get.GetRequest;
  11. import org.elasticsearch.action.get.GetResponse;
  12. import org.elasticsearch.action.index.IndexRequest;
  13. import org.elasticsearch.action.index.IndexResponse;
  14. import org.elasticsearch.action.update.UpdateRequest;
  15. import org.elasticsearch.action.update.UpdateResponse;
  16. import org.elasticsearch.client.RequestOptions;
  17. import org.elasticsearch.client.RestClient;
  18. import org.elasticsearch.client.RestHighLevelClient;
  19. import org.elasticsearch.common.settings.Settings;
  20. import org.elasticsearch.common.xcontent.XContentType;
  22. import java.io.IOException;
  23. import java.util.HashMap;
  24. import java.util.Map;
  26. public class TestElasticsearch {
  28.     public static void main(String[] args) throws IOException {
  29.         RestHighLevelClient client = createClient();//创建链接，创建客户端
  30.         try {
  31. //        createIndex(client); //创建索引
  32. //        addData(client);     //添加数据
  33. //        queryData(client);   //查询数据
  34. //        updateData(client);  //修改数据
  35. //        queryData(client);   //查询数据
  36. //        deleteData(client);  //删除数据
  37. //        deleteIndex(client); //删除索引
  38.         bulk(client);        //批量操作
  39.         }catch (Exception e){
  40.             e.printStackTrace();
  41.         }finally {
  42.             if (client != null){
  43.                 closeClient(client); //关闭客户端
  44.             }
  45.         }
  46.     }
  49.     /**
  50.      * 创建链接，创建客户端
  51.      * @return
  52.      */
  53.     public static RestHighLevelClient createClient(){
  54.         //创建链接，创建客户端
  55.         HttpHost http9200 = new HttpHost("8.140.122.156", 9200, "http");
  56. //        HttpHost http9201 = new HttpHost("8.140.122.156", 9201, "http");
  57.         RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(http9200));
  58.         return client;
  59.     }
  62.     /**
  63.      * 关闭客户端
  64.      * @param client
  65.      * @throws IOException
  66.      */
  67.     public static void closeClient(RestHighLevelClient client) throws IOException {
  68.         client.close();
  69.     }
  72.     /**
  73.      * 创建索引
  74.      * PUT order1
  75.      * {
  76.      *   "settings": {
  77.      *     "number_of_shards": 3,
  78.      *     "number_of_replicas": 2
  79.      *   },
  80.      *   "mappings": {
  81.      *     "properties": {
  82.      *       "id":{
  83.      *         "type": "long"
  84.      *       },
  85.      *       "age":{
  86.      *         "type": "short"
  87.      *       },
  88.      *       "mail":{
  89.      *         "type": "text",
  90.      *         "fields": {
  91.      *           "keyword" : {
  92.      *             "type" : "keyword",
  93.      *             "ignore_above" : 64
  94.      *           }
  95.      *         }
  96.      *       },
  97.      *       "name":{
  98.      *         "type": "text",
  99.      *         "fields": {
  100.      *           "keyword" : {
  101.      *             "type" : "keyword",
  102.      *             "ignore_above" : 64
  103.      *           }
  104.      *         }
  105.      *       },
  106.      *       "createTime":{
  107.      *         "type": "date",
  108.      *         "format": ["yyyy-MM-dd HH:mm:ss"]
  109.      *       }
  110.      *     }
  111.      *   }
  112.      * }
  113.      * @param client
  114.      * @throws IOException
  115.      */
  116.     public static void createIndex(RestHighLevelClient client) throws IOException {
  117.         //设置3个分片，每个分片2副本
  118.         Settings settings = Settings.builder()
  119.                 .put("number_of_shards",3)
  120.                 .put("number_of_replicas",2)
  121.                 .build();
  123.         //新增索引
  124.         CreateIndexRequest createIndexRequest = new CreateIndexRequest("order1");
  125.         createIndexRequest.mapping("properties","{\"id\":{\"type\":\"long\"},\"age\":{\"type\":\"short\"},\"mail\":{\"type\":\"text\",\"fields\":{\"keyword\":{\"type\":\"keyword\",\"ignore_above\":64}}},\"name\":{\"type\":\"text\",\"fields\":{\"keyword\":{\"type\":\"keyword\",\"ignore_above\":64}}},\"createTime\":{\"type\":\"date\",\"format\":[\"yyyy-MM-dd HH:mm:ss\"]}}",XContentType.JSON);
  126.         createIndexRequest.settings(settings);
  127.         //执行
  128.         CreateIndexResponse createIndexResponse = client.indices().create(createIndexRequest, RequestOptions.DEFAULT);
  129.         System.out.println("创建索引结果: "+createIndexResponse.isAcknowledged());
  130.     }
  133.     /**
  134.      * 插入数据
  135.      *
  136.      * @param client
  137.      * @throws IOException
  138.      */
  139.     public static void addData(RestHighLevelClient client) throws IOException {
  140.         //数据
  141.         Map personMap = new HashMap();
  142.         personMap.put("id",1);
  143.         personMap.put("age",28);
  144.         personMap.put("name","王帆");
  145.         personMap.put("email","wangfan@yxinsur.com");
  146.         personMap.put("createTime","2020-02-02 12:00:00");
  148.         //新增索引
  149.         IndexRequest indexRequest = new IndexRequest("order1","_doc","1");
  150.         indexRequest.source(personMap);
  151.         //执行
  152.         IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
  153.         System.out.println("插入数据结果: "+indexResponse.toString());
  154.     }
  157.     /**
  158.      * 查询数据
  159.      * GET order1/_doc/1
  160.      * @param client
  161.      * @throws IOException
  162.      */
  163.     public static void queryData(RestHighLevelClient client) throws IOException {
  164.         //查询索引
  165.         GetRequest getRequest = new GetRequest("order1","_doc","1");
  167.         //执行
  168.         GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
  169.         System.out.println("查询数据结果: "+getResponse.toString());
  170.     }
  173.     /**
  174.      * 修改数据
  175.      * PUT order1/_doc/1
  176.      * {
  177.      *   "name": "王帆",
  178.      *   "age": 29,
  179.      *   "email": "wangfan@yxinsur.com"
  180.      * }
  181.      * @param client
  182.      * @throws IOException
  183.      */
  184.     public static void updateData(RestHighLevelClient client) throws IOException {
  186.         //实际数据
  187.         Map<String,Object> personMap = new HashMap<>();
  188.         personMap.put("id",1);
  189.         personMap.put("age",29);
  190.         personMap.put("name","王帆");
  191.         personMap.put("email","wangfan@yxinsur.com");
  192.         personMap.put("createTime","2020-02-02 12:00:00");
  194.         //修改索引
  195.         UpdateRequest updateRequest = new UpdateRequest("order1","_doc","1");
  196.         updateRequest.doc(personMap);
  198.         //或者是upsert
  199.         //updateRequest.upsert(person);
  201.         //执行
  202.         UpdateResponse updateResponse = client.update(updateRequest, RequestOptions.DEFAULT);
  203.         System.out.println("修改数据结果: "+updateResponse.toString());
  204.     }
  207.     /**
  208.      * 删除数据
  209.      * DELETE order1/_doc/1
  210.      * @param client
  211.      * @throws IOException
  212.      */
  213.     public static void deleteData(RestHighLevelClient client) throws IOException {
  214.         //删除数据
  215.         DeleteRequest deleteRequest = new DeleteRequest("order1","_doc","1");
  216.         //执行
  217.         DeleteResponse deleteResponse = client.delete(deleteRequest, RequestOptions.DEFAULT);
  218.         System.out.println("删除数据结果: "+deleteResponse.toString());
  219.     }
  222.     /**
  223.      * 删除索引
  224.      * DELETE order1/_doc/1
  225.      * @param client
  226.      * @throws IOException
  227.      */
  228.     public static void deleteIndex(RestHighLevelClient client) throws IOException {
  229.         //删除索引
  230.         DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest("order1");
  231.         //执行
  232.         DeleteIndexResponse deleteIndexResponse = client.indices().delete(deleteIndexRequest, RequestOptions.DEFAULT);
  233.         System.out.println("删除索引结果: "+deleteIndexResponse.isAcknowledged());
  234.     }
  237.     /**
  238.      * 批量操作
  239.      * @param client
  240.      */
  241.     public static void bulk(RestHighLevelClient client) throws IOException {
  242.         //准备数据
  243.         Map<String,Object> personMap = new HashMap<>();
  244.         personMap.put("id",2);
  245.         personMap.put("age",29);
  246.         personMap.put("name","王帆");
  247.         personMap.put("email","wangfan@yxinsur.com");
  248.         personMap.put("createTime","2020-02-02 12:00:00");
  250.         //插入数据操作
  251.         IndexRequest indexRequest2 = new IndexRequest("order1","_doc","2");
  252.         indexRequest2.source(personMap,XContentType.JSON);
  253.         IndexRequest indexRequest3 = new IndexRequest("order1","_doc","3");
  254.         indexRequest3.source(personMap,XContentType.JSON);
  256.         //修改数据操作
  257.         personMap.put("age",30);
  258.         UpdateRequest updateRequest = new UpdateRequest("order1","_doc","2");
  259.         updateRequest.doc(personMap,XContentType.JSON);
  261.         //删除数据操作
  262.         DeleteRequest deleteRequest = new DeleteRequest("order1","_doc","2");
  264.         //将操作都放入bulk里面
  265.         BulkRequest bulkRequest = new BulkRequest();
  266.         bulkRequest.add(indexRequest2);
  267.         bulkRequest.add(indexRequest3);
  268.         bulkRequest.add(updateRequest);
  269.         bulkRequest.add(deleteRequest);
  271.         //执行
  272.         BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
  273.         System.out.println("批量操作结果: "+bulkResponse.toString());
  274.     }
  276. }

创建索引结果: true插入数据结果: IndexResponse[index=order1,type=_doc,id=1,version=1,result=created,seqNo=0,primaryTerm=1,shards={“total”:3,”successful”:1,”failed”:0}] 查询数据结果: {“_index”:”order1”,”_type”:”_doc”,”_id”:”1”,”_version”:1,”found”:true,”_source”:{“createTime”:”2020-02-02 12:00:00”,”name”:”王帆”,”id”:1,”age”:28,”email”:”wangfan@yxinsur.com”},”fields”:{“_seq_no”:[0],”_primary_term”:[1]}}修改数据结果: UpdateResponse[index=order1,type=_doc,id=1,version=2,seqNo=1,primaryTerm=1,result=updated,shards=ShardInfo{total=3, successful=1, failures=[]}]

查询数据结果: {“_index”:”order1”,”_type”:”_doc”,”_id”:”1”,”_version”:2,”found”:true,”_source”:{“createTime”:”2020-02-02 12:00:00”,”name”:”王帆”,”id”:1,”age”:29,”email”:”wangfan@yxinsur.com”},”fields”:{“_seq_no”:[1],”_primary_term”:[1]}}

删除数据结果: DeleteResponse[index=order1,type=_doc,id=1,version=3,result=deleted,shards=ShardInfo{total=3, successful=1, failures=[]}]

删除索引结果: true

批量操作结果: org.elasticsearch.action.bulk.BulkResponse@793be5ca