remove export

Author: iamazy

pom.xml

@@ -10,8 +10,9 @@
     <url>https://github.com/iamazy/elasticsearch-sql</url>
 
     <properties>
-        <elasticsearch.version>7.0.1</elasticsearch.version>
+        <elasticsearch.version>7.0.0</elasticsearch.version>
         <java.version>1.8</java.version>
+        <maven.compiler.target>${java.version}</maven.compiler.target>
         <elasticsearch.plugin.name>isql</elasticsearch.plugin.name>
         <elasticsearch.plugin.classname>io.github.iamazy.elasticsearch.dsl.plugin.SqlPlugin</elasticsearch.plugin.classname>
         <elasticsearch.plugin.jvm>true</elasticsearch.plugin.jvm>

src/main/java/io/github/iamazy/elasticsearch/dsl/plugin/RestSqlAction.java

@@ -1,6 +1,7 @@
 package io.github.iamazy.elasticsearch.dsl.plugin;
 
 import com.carrotsearch.hppc.cursors.ObjectObjectCursor;
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import io.github.iamazy.elasticsearch.dsl.sql.exception.ElasticSql2DslException;
 import io.github.iamazy.elasticsearch.dsl.sql.model.ElasticSqlParseResult;
 import io.github.iamazy.elasticsearch.dsl.sql.parser.ElasticSql2DslParser;
@@ -13,6 +14,7 @@
 import org.elasticsearch.rest.*;
 
 import java.io.IOException;
+import java.util.concurrent.*;
 
 
 /**
@@ -30,14 +32,13 @@ public class RestSqlAction extends BaseRestHandler {
         restController.registerHandler(RestRequest.Method.GET, "/_isql", this);
     }
 
-
     @Override
     public String getName() {
         return "isql";
     }
 
     @Override
-    protected RestChannelConsumer prepareRequest(RestRequest restRequest, NodeClient nodeClient) throws IOException {
+    protected RestChannelConsumer prepareRequest(RestRequest restRequest, NodeClient nodeClient) {
         try (XContentParser parser = restRequest.contentOrSourceParamParser()) {
             parser.mapStrings().forEach((k, v) -> restRequest.params().putIfAbsent(k, v));
         } catch (IOException e) {
@@ -54,9 +55,6 @@ protected RestChannelConsumer prepareRequest(RestRequest restRequest, NodeClient
             if (restRequest.path().endsWith("/_explain")) {
                 return channel -> channel.sendResponse(new BytesRestResponse(RestStatus.OK, builder.value(parseResult.toRequest().source())));
             }
-            else if(restRequest.path().endsWith("/_export")){
-                return null;
-            }
             else {
                 if (parseResult.toFieldMapping() != null) {
                     return channel -> channel.sendResponse(new BytesRestResponse(RestStatus.OK, builder.value(nodeClient.admin().indices().getFieldMappings(parseResult.toFieldMapping()).actionGet())));
@@ -70,8 +68,10 @@ else if(restRequest.path().endsWith("/_export")){
                     return channel -> channel.sendResponse(new BytesRestResponse(RestStatus.OK, builder.value(nodeClient.search(parseResult.toRequest()).actionGet())));
                 }
             }
-        } catch (ElasticSql2DslException e) {
+        } catch (Exception e) {
             return channel -> channel.sendResponse(new BytesRestResponse(RestStatus.INTERNAL_SERVER_ERROR, XContentType.JSON.mediaType(), "{\"error\":\"" + e.getMessage() + "\"}"));
         }
     }
+
+
 }

src/main/java/io/github/iamazy/elasticsearch/dsl/plugin/export/ExportAction.java

@@ -1,4 +1,4 @@
 grant {
   // needed because of the hot reload functionality
-  permission java.lang.RuntimePermission "accessDeclaredMembers";
+  permission java.net.SocketPermission "*", "connect,resolve";
 };