Elastic search EOL version upgrade

indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndexerMappingServiceImpl.java

@@ -19,8 +19,10 @@ import com.google.gson.reflect.TypeToken;
 import com.lambdaworks.redis.RedisException;
 import org.elasticsearch.ElasticsearchException;
 import org.elasticsearch.action.support.master.AcknowledgedResponse;
-import org.elasticsearch.client.*;
-import org.elasticsearch.client.indices.GetIndexRequest;
+import org.elasticsearch.client.Request;
+import org.elasticsearch.client.RequestOptions;
+import org.elasticsearch.client.Response;
+import org.elasticsearch.client.RestHighLevelClient;
 import org.elasticsearch.client.indices.PutMappingRequest;
 import org.elasticsearch.core.TimeValue;
 import org.elasticsearch.xcontent.XContentType;
@@ -70,7 +72,7 @@ public class IndexerMappingServiceImpl extends MappingServiceImpl implements IMa
 
         Map<String, Object> mappingMap = this.getIndexMappingFromRecordSchema(schema);
         String mapping = new Gson().toJson(mappingMap, Map.class);
-        this.createMappingWithJson(client, index, mapping, merge);
+        this.createMappingWithJson(client, index, schema.getType(), mapping, merge);
         return mapping;
     }
 
@@ -209,7 +211,7 @@ public class IndexerMappingServiceImpl extends MappingServiceImpl implements IMa
         documentMapping.put(Constants.PROPERTIES, properties);
 
         String mapping = new Gson().toJson(documentMapping, Map.class);
-        this.createMappingWithJson(restClient, index,  mapping, true);
+        this.createMappingWithJson(restClient, index, "_doc", mapping, true);
         log.info(String.format("Creating Mapping for index %s, %s", index, mapping));
 
         this.indexCache.put(cacheKey, true);
@@ -220,16 +222,17 @@ public class IndexerMappingServiceImpl extends MappingServiceImpl implements IMa
      *
      * @param client  Elasticsearch client
      * @param index   Index name
+     * @param type    Type name
      * @param mapping Mapping if any, null if no specific mapping
      * @param merge   Try to merge mapping if type already exists
      * @throws IOException if cannot create index mapping with input json
      */
-    private void createMappingWithJson(RestHighLevelClient client, String index, String mapping, boolean merge)
+    private void createMappingWithJson(RestHighLevelClient client, String index, String type, String mapping, boolean merge)
             throws IOException {
 
-        boolean mappingExist = isTypeExist(client, index);
+        boolean mappingExist = isTypeExist(client, index, type);
         if (merge || !mappingExist) {
-            createTypeWithMappingInElasticsearch(client, index, mapping);
+            createTypeWithMappingInElasticsearch(client, index, type, mapping);
         }
     }
 
@@ -238,15 +241,15 @@ public class IndexerMappingServiceImpl extends MappingServiceImpl implements IMa
      *
      * @param client Elasticsearch client
      * @param index  Index name
+     * @param type   Type name
      * @return true if type already exists
      * @throws IOException in case Elasticsearch responded with a status code that indicated an error
      */
-    public boolean isTypeExist(RestHighLevelClient client, String index) throws IOException {
+    public boolean isTypeExist(RestHighLevelClient client, String index, String type) throws IOException {
 
-        GetIndexRequest getIndexRequest = new GetIndexRequest(index);
-        IndicesClient indices = client.indices();
-        boolean exists = indices.exists(getIndexRequest, RequestOptions.DEFAULT);
-        return exists;
+        Request request = new Request("HEAD", "/" + index + "/_mapping/" + type);
+        Response response = client.getLowLevelClient().performRequest(request);
+        return response.getStatusLine().getStatusCode() == 200;
     }
 
     /**
@@ -254,13 +257,15 @@ public class IndexerMappingServiceImpl extends MappingServiceImpl implements IMa
      *
      * @param client  Elasticsearch client
      * @param index   Index name
+     * @param type    Type name
      * @param mapping Mapping if any, null if no specific mapping
      * @throws IOException if mapping cannot be created
      */
-    private Boolean createTypeWithMappingInElasticsearch(RestHighLevelClient client, String index, String mapping) throws IOException {
+    private Boolean createTypeWithMappingInElasticsearch(RestHighLevelClient client, String index, String type, String mapping) throws IOException {
 
         Preconditions.checkNotNull(client, "client cannot be null");
         Preconditions.checkNotNull(index, "index cannot be null");
+        Preconditions.checkNotNull(type, "type cannot be null");
 
         try {
             if (mapping != null) {
@@ -274,7 +279,7 @@ public class IndexerMappingServiceImpl extends MappingServiceImpl implements IMa
             throw new AppException(
                     e.status().getStatus(),
                     e.getMessage(),
-                    String.format("Could not create mapping %s.", index),
+                    String.format("Could not create type mapping %s/%s.", index, type),
                     String.format("Failed creating mapping: %s", mapping),
                     e);
         }