Added Ingest, delete services

Author: Satendra kumar

pom.xml

@@ -2,10 +2,10 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.es.app</groupId>
-    <artifactId>es-java-client-tutorial</artifactId>
+    <artifactId>es-java-client-sample</artifactId>
     <packaging>jar</packaging>
-    <version>1.0-SNAPSHOT</version>
-    <name>my-app</name>
+    <version>1.0</version>
+    <name>es-java-client-sample</name>
     <url>http://maven.apache.org</url>
     <dependencies>
         <dependency>
@@ -19,6 +19,11 @@
             <version>3.8.1</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.elasticsearch.plugin</groupId>
+            <artifactId>delete-by-query</artifactId>
+            <version>2.3.2</version>
+        </dependency>
     </dependencies>
     <build>
     <plugins>

src/main/java/com/es/app/App.java

@@ -1,9 +1,11 @@
 package com.es.app;
 
 
-import com.es.util.ESManager;
 import com.es.service.CountService;
 import com.es.service.DataService;
+import com.es.service.DeleteService;
+import com.es.service.IngestService;
+import com.es.util.ESManager;
 import org.elasticsearch.client.Client;
 
 
@@ -15,6 +17,8 @@ public static void main(String[] args) {
 
         CountService countService = new CountService(client);
         DataService dataService = new DataService(client);
+        IngestService ingestService = new IngestService(client);
+        DeleteService deleteService = new DeleteService(client);
 
         //count
         System.out.println("\ngetMatchAllQueryCount from ES::: " + countService.getMatchAllQueryCount());
@@ -23,21 +27,41 @@ public static void main(String[] args) {
 
 
         // Data
-        System.out.println("\ngetMatchAllQueryData from ES::: " );
-        dataService.getMatchAllQueryData().forEach(item->System.out.println(item));
-
-        System.out.println("\ngetBoolQueryData from ES::: " );
-        dataService.getBoolQueryData().forEach(item->System.out.println(item));
-
-        System.out.println("\ngetPhraseQueryData from ES::: " );
-        dataService.getPhraseQueryData().forEach(item->System.out.println(item));
-
+        System.out.println("\ngetMatchAllQueryData from ES::: ");
+        dataService.getMatchAllQueryData().forEach(item -> System.out.println(item));
+
+        System.out.println("\ngetBoolQueryData from ES::: ");
+        dataService.getBoolQueryData().forEach(item -> System.out.println(item));
+
+        System.out.println("\ngetPhraseQueryData from ES::: ");
+        dataService.getPhraseQueryData().forEach(item -> System.out.println(item));
+
+        //Ingest
+        String json1 = "{" +
+                "\"name\":\"skyji\"," +
+                "\"job\":\"Admin\"," +
+                "\"location\":\"India\"" +
+                "}";
+
+        String json2 = "{" +
+                "\"name\":\"jom\"," +
+                "\"job\":\"assiant\"," +
+                "\"location\":\"Meana\"" +
+                "}";
+        // ingest single record
+        // System.out.println("\nIngestService response::: " +ingestService.ingest("tweet",json) );
+
+        // ingest batch of records
+        //  System.out.println("\nIngestService response::: " + ingestService.ingest("tweet", Arrays.asList(json1, json2)));
+
+
+        // Delete
+        // delete one record by id
+        //System.out.println("delete by id " + deleteService.delete("AVSMh1LBWlqOklhqtVNs"));
+        //delete record by query
+        System.out.println("delete by query " + deleteService.deleteByQuery("satendra"));
         client.close();
 
-
-
-
     }
 
-
 }

src/main/java/com/es/service/DeleteService.java

@@ -0,0 +1,31 @@
+package com.es.service;
+
+
+import org.elasticsearch.action.deletebyquery.DeleteByQueryAction;
+import org.elasticsearch.action.deletebyquery.DeleteByQueryRequestBuilder;
+import org.elasticsearch.client.Client;
+import org.elasticsearch.index.query.QueryBuilders;
+
+/***
+ * add delete by query plugin to Elastisearch
+ * $ bin/plugin install delete-by-query
+ */
+public class DeleteService {
+
+
+    Client client;
+
+    public DeleteService(Client client) {
+        this.client = client;
+    }
+
+
+    public boolean delete(String id) {
+        return client.prepareDelete("test", "tweet", id).get().isFound();
+    }
+
+    public long deleteByQuery(String name) {
+        return new DeleteByQueryRequestBuilder(client, DeleteByQueryAction.INSTANCE).setQuery(QueryBuilders.termQuery("name", name))
+                .execute().actionGet().getTotalDeleted();
+    }
+}

src/main/java/com/es/service/IngestService.java

@@ -0,0 +1,30 @@
+package com.es.service;
+
+
+import org.elasticsearch.action.bulk.BulkRequestBuilder;
+import org.elasticsearch.client.Client;
+
+import java.util.List;
+
+public class IngestService {
+
+    Client client;
+
+    public IngestService(Client client) {
+        this.client = client;
+    }
+
+    public boolean ingest(String type, String doc) {
+        return client.prepareIndex("test", type).setSource(doc).get().isCreated();
+    }
+
+
+    public boolean ingest(String type, List<String> docs) {
+        BulkRequestBuilder bulkRequest = client.prepareBulk();
+        docs.forEach(doc -> bulkRequest.add(client.prepareIndex("test", type).setSource(doc)));
+        return bulkRequest.get().hasFailures();
+
+    }
+
+
+}

src/main/java/com/es/util/ESManager.java

@@ -3,19 +3,25 @@
 
 import org.elasticsearch.client.Client;
 import org.elasticsearch.client.transport.TransportClient;
+import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.transport.InetSocketTransportAddress;
+import org.elasticsearch.plugin.deletebyquery.DeleteByQueryPlugin;
 
 import java.net.InetAddress;
 import java.util.Optional;
 
 public class ESManager {
 
+
+
     public Optional<Client> getClient(String host, int port) {
         try {
-            Client client = TransportClient.builder().build()
+            Settings.Builder setting =Settings.builder().put("client.transport.sniff", false);
+            TransportClient client = TransportClient.builder().settings(setting).addPlugin(DeleteByQueryPlugin.class).build()
                     .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(host), port));
             return Optional.of(client);
         } catch (Exception e) {
+            e.printStackTrace();
             return Optional.empty();
         }
     }