SQL: Introduce ODBC mode, similar to JDBC

Close #34720
elastic · Oct 24, 2018 · 2c2a22b · 2c2a22b
1 parent 18e004c
commit 2c2a22b
Show file tree

Hide file tree

Showing 5 changed files with 28 additions and 4 deletions.
diff --git a/x-pack/plugin/core/src/main/java/org/elasticsearch/license/XPackLicenseState.java b/x-pack/plugin/core/src/main/java/org/elasticsearch/license/XPackLicenseState.java
@@ -628,6 +628,20 @@ public synchronized boolean isJdbcAllowed() {
         return licensed && localStatus.active;
     }
 
+    /**
+     * Determine if ODBC support should be enabled.
+     * <p>
+     * ODBC is available only in for {@link OperationMode#PLATINUM} and {@link OperationMode#TRIAL} licences
+     */
+    public synchronized boolean isOdbcAllowed() {
+        Status localStatus = status;
+        OperationMode operationMode = localStatus.mode;
+
+        boolean licensed = operationMode == OperationMode.TRIAL || operationMode == OperationMode.PLATINUM;
+
+        return licensed && localStatus.active;
+    }
+
     public synchronized boolean isTrialLicense() {
         return status.mode == OperationMode.TRIAL;
     }

diff --git a/...gin/sql/sql-action/src/main/java/org/elasticsearch/xpack/sql/action/SqlQueryResponse.java b/...gin/sql/sql-action/src/main/java/org/elasticsearch/xpack/sql/action/SqlQueryResponse.java
@@ -167,7 +167,7 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
      * Serializes the provided value in SQL-compatible way based on the client mode
      */
     public static XContentBuilder value(XContentBuilder builder, Mode mode, Object value) throws IOException {
-        if (mode == Mode.JDBC && value instanceof ReadableDateTime) {
+        if (Mode.isDriver(mode) && value instanceof ReadableDateTime) {
             // JDBC cannot parse dates in string format
             builder.value(((ReadableDateTime) value).getMillis());
         } else {

diff --git a/x-pack/plugin/sql/sql-proto/src/main/java/org/elasticsearch/xpack/sql/proto/Mode.java b/x-pack/plugin/sql/sql-proto/src/main/java/org/elasticsearch/xpack/sql/proto/Mode.java
@@ -13,7 +13,8 @@
  */
 public enum Mode {
     PLAIN,
-    JDBC;
+    JDBC, 
+    ODBC;
 
     public static Mode fromString(String mode) {
         if (mode == null) {
@@ -27,4 +28,8 @@ public static Mode fromString(String mode) {
     public String toString() {
         return this.name().toLowerCase(Locale.ROOT);
     }
+
+    public static boolean isDriver(Mode mode) {
+        return mode == JDBC || mode == ODBC;
+    }
 }
diff --git a/x-pack/plugin/sql/src/main/java/org/elasticsearch/xpack/sql/plugin/SqlPlugin.java b/x-pack/plugin/sql/src/main/java/org/elasticsearch/xpack/sql/plugin/SqlPlugin.java
@@ -64,6 +64,11 @@ public SqlPlugin(Settings settings) {
                                 throw LicenseUtils.newComplianceException("jdbc");
                             }
                             break;
+                        case ODBC:
+                            if (licenseState.isOdbcAllowed() == false) {
+                                throw LicenseUtils.newComplianceException("odbc");
+                            }
+                            break;
                         case PLAIN:
                             if (licenseState.isSqlAllowed() == false) {
                                 throw LicenseUtils.newComplianceException(XPackField.SQL);

diff --git a/.../plugin/sql/src/main/java/org/elasticsearch/xpack/sql/plugin/TransportSqlQueryAction.java b/.../plugin/sql/src/main/java/org/elasticsearch/xpack/sql/plugin/TransportSqlQueryAction.java
@@ -20,6 +20,7 @@
 import org.elasticsearch.xpack.sql.action.SqlQueryResponse;
 import org.elasticsearch.xpack.sql.execution.PlanExecutor;
 import org.elasticsearch.xpack.sql.proto.ColumnInfo;
+import org.elasticsearch.xpack.sql.proto.Mode;
 import org.elasticsearch.xpack.sql.session.Configuration;
 import org.elasticsearch.xpack.sql.session.Cursors;
 import org.elasticsearch.xpack.sql.session.RowSet;
@@ -30,7 +31,6 @@
 import java.util.List;
 
 import static java.util.Collections.unmodifiableList;
-import static org.elasticsearch.xpack.sql.proto.Mode.JDBC;
 
 public class TransportSqlQueryAction extends HandledTransportAction<SqlQueryRequest, SqlQueryResponse> {
     private final PlanExecutor planExecutor;
@@ -73,7 +73,7 @@ public static void operation(PlanExecutor planExecutor, SqlQueryRequest request,
     static SqlQueryResponse createResponse(SqlQueryRequest request, SchemaRowSet rowSet) {
         List<ColumnInfo> columns = new ArrayList<>(rowSet.columnCount());
         for (Schema.Entry entry : rowSet.schema()) {
-            if (request.mode() == JDBC) {
+            if (Mode.isDriver(request.mode())) {
                 columns.add(new ColumnInfo("", entry.name(), entry.type().esType, entry.type().jdbcType,
                         entry.type().displaySize));
             } else {