ElasticSearch6.8 CRUD增刪改查的使用方法

本篇內容介紹了“ElasticSearch6.8 CRUD增刪改查的使用方法”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

pom.xml

<!-- elasticsearch的客戶端 --><dependency>    <groupId>org.elasticsearch.client</groupId>    <artifactId>transport</artifactId>    <version>6.8.8</version></dependency><dependency>    <groupId>org.elasticsearch</groupId>    <artifactId>elasticsearch</artifactId>    <version>6.8.8</version></dependency><!-- elasticsearch依賴2.x的log4j --><dependency>    <groupId>org.apache.logging.log4j</groupId>    <artifactId>log4j-api</artifactId>    <version>2.13.2</version></dependency><dependency>    <groupId>org.apache.logging.log4j</groupId>    <artifactId>log4j-core</artifactId>    <version>2.13.2</version></dependency><!-- junit單元測試 --><dependency>    <groupId>junit</groupId>    <artifactId>junit</artifactId>    <version>4.12</version></dependency>

創建連接

@Beforepublic void prepare() throws Exception{index = "neptune";    type = "doc";    Settings settings = Settings.builder().put("cluster.name","hysg-test-cluster").build();    //創建客戶端     client = new PreBuiltTransportClient(settings)
            .addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"),9300));}

獲取一條數據

@Testpublic void getOne()throws Exception{    GetResponse response = client.prepareGet(index, type,1).get();    System.out.println(response);}

根據查詢條件批量刪除數據

@Testpublic void deleteByQueryField()throws Exception{
    BulkByScrollResponse response =
            DeleteByQueryAction.INSTANCE.newRequestBuilder(client)
                    .filter(QueryBuilders.matchQuery("IP", "127.0.0.1"))
                    .source(index)
                    .get();    long deleted = response.getDeleted();    System.out.println(deleted);}

參考連接

https://blog.csdn.net/baidu_24545901/article/details/80153693

“ElasticSearch6.8 CRUD增刪改查的使用方法”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！