Fixes elasticsearch drive

Otavio Santana · Otavio Santana · commit 530d05e1cfdb · 2017-03-11T06:49:01.000-03:00
diff --git a/elasticsearch-driver/src/main/java/org/jnosql/diana/elasticsearch/document/ElasticsearchDocumentCollectionManagerFactory.java b/elasticsearch-driver/src/main/java/org/jnosql/diana/elasticsearch/document/ElasticsearchDocumentCollectionManagerFactory.java
@@ -78,8 +78,10 @@ private void initDatabase(String database) {
         boolean exists = isExists(database);
         if (!exists) {
             URL url = ElasticsearchDocumentCollectionManagerFactory.class.getResource('/' + database + ".json");
-            byte[] bytes = getBytes(url);
-            client.admin().indices().prepareCreate(database).setSource(bytes).get();
+            if (Objects.nonNull(url)) {
+                byte[] bytes = getBytes(url);
+                client.admin().indices().prepareCreate(database).setSource(bytes).get();
+            }
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -78,8 +78,10 @@ private void initDatabase(String database) {`
`78`	`78`	`boolean exists = isExists(database);`
`79`	`79`	`if (!exists) {`
`80`	`80`	`URL url = ElasticsearchDocumentCollectionManagerFactory.class.getResource('/' + database + ".json");`
`81`		`- byte[] bytes = getBytes(url);`
`82`		`- client.admin().indices().prepareCreate(database).setSource(bytes).get();`
	`81`	`+ if (Objects.nonNull(url)) {`
	`82`	`+ byte[] bytes = getBytes(url);`
	`83`	`+ client.admin().indices().prepareCreate(database).setSource(bytes).get();`
	`84`	`+ }`
`83`	`85`	`}`
`84`	`86`	`}`
`85`	`87`