ElasticSearch学习（五）—— Java写入数据

超、凢脫俗 2023-02-27 05:44 12阅读 0赞

*  7.2.0版本
 *  获取客户端连接

private static int port = 9200;
    private static String host = "192.168.1.105";
    
    private static RestHighLevelClient getClient() {
        RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder(new HttpHost(host, port, "http")));
        return client;
    }

*  批量添加数据

/**
         * bulk批量添加
          */
        public static void batchAddDocuments(){
            try {
                RestHighLevelClient client = getClient();
    
                Map<String, Object> jsonMap = new HashMap<String, Object>();
                jsonMap.put("id", "01209");
                jsonMap.put("title", "紅樓夢");
                jsonMap.put("author", "曹雪芹");
                jsonMap.put("classification", "小說");
                IndexRequest request = new IndexRequest("book")
                        .id("2").source(jsonMap);
    
                jsonMap.put("id", "01210");
                jsonMap.put("title", "水滸傳");
                jsonMap.put("author", "施耐庵");
                jsonMap.put("classification", "小說");
                IndexRequest request1 = new IndexRequest("book")
                        .id("3").source(jsonMap);
    
                BulkRequest bulkRequest = new BulkRequest();
                bulkRequest.add(request);
                bulkRequest.add(request1);
    
                BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
                for (BulkItemResponse bulkItemResponse : bulkResponse) {
                    DocWriteResponse itemResponse = bulkItemResponse.getResponse();
                    switch (bulkItemResponse.getOpType()) {
                        case INDEX:
                            break;
                        case CREATE:
                            IndexResponse indexResponse = (IndexResponse) itemResponse;
                            System.out.println("新增文档成功!");
                            break;
                        case UPDATE:
                            UpdateResponse updateResponse = (UpdateResponse) itemResponse;
                            System.out.println("更新文档成功!");
                            break;
                        case DELETE:
                            DeleteResponse deleteResponse = (DeleteResponse) itemResponse;
                            System.out.println("删除文档成功!");
                            break;
                        default:
                    }
                }
                client.close();
            }catch (Exception e){
                e.printStackTrace();
            }
        }

*  根据索引id删除

/**
         * 根据索引id删除
         */
        public static void deleteDocument(){
            try {
                RestHighLevelClient client = getClient();
                DeleteRequest request = new DeleteRequest(
                        "ancientbook",
                        "2607");
                DeleteResponse deleteResponse = client.delete(
                        request, RequestOptions.DEFAULT);
                System.out.println(deleteResponse.getResult());
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

*  根据索引id获取

/**
         * 根据索引id获取
         */
        public static void getIndex() {
            try {
                RestHighLevelClient client = getClient();
                GetRequest getRequest = new GetRequest(
                        "ancientbook",
                        "2607");
                GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
                String index = getResponse.getIndex();
                String id = getResponse.getId();
                if (getResponse.isExists()) {
                    long version = getResponse.getVersion();
                    String sourceAsString = getResponse.getSourceAsString();
                    Map<String, Object> sourceAsMap = getResponse.getSourceAsMap();
                    byte[] sourceAsBytes = getResponse.getSourceAsBytes();
                    System.out.println("index:" + index);
                    System.out.println("id:" + id);
                    System.out.println("version:" + version);
                    System.out.println("sourceAsString:" + sourceAsString);
                    System.out.println("sourceAsMap:" + sourceAsMap);
                    System.out.println("sourceAsBytes:" + sourceAsBytes);
                } else {
    
                }
                client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }