[ignite-3] branch ignite-14972 updated: Add ClientSql

[pt...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ptupitsyn pushed a commit to branch ignite-14972
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/ignite-14972 by this push:
     new 8c0bf0dc8 Add ClientSql
8c0bf0dc8 is described below

commit 8c0bf0dc8ab16b0e86b389242c3055a50f9c1b89
Author: Pavel Tupitsyn <pt...@apache.org>
AuthorDate: Mon May 30 10:26:41 2022 +0300

    Add ClientSql
---
 .../ignite/internal/client/TcpIgniteClient.java    |  5 ++
 .../ignite/internal/client/sql/ClientSql.java      | 66 ++++++++++++++++++++++
 2 files changed, 71 insertions(+)

diff --git a/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java b/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java
index e64ae8e69..ef7449890 100644
--- a/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java
+++ b/modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java
@@ -32,6 +32,7 @@ import org.apache.ignite.compute.IgniteCompute;
 import org.apache.ignite.internal.client.compute.ClientCompute;
 import org.apache.ignite.internal.client.io.ClientConnectionMultiplexer;
 import org.apache.ignite.internal.client.proto.ClientOp;
+import org.apache.ignite.internal.client.sql.ClientSql;
 import org.apache.ignite.internal.client.table.ClientTables;
 import org.apache.ignite.internal.client.tx.ClientTransactions;
 import org.apache.ignite.internal.jdbc.proto.ClientMessage;
@@ -60,6 +61,9 @@ public class TcpIgniteClient implements IgniteClient {
     /** Compute. */
     private final ClientCompute compute;
 
+    /** Compute. */
+    private final ClientSql sql;
+
     /**
      * Constructor.
      *
@@ -88,6 +92,7 @@ public class TcpIgniteClient implements IgniteClient {
         tables = new ClientTables(ch);
         transactions = new ClientTransactions(ch);
         compute = new ClientCompute(ch, tables);
+        sql = new ClientSql(ch);
     }
 
     /**
diff --git a/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSql.java b/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSql.java
new file mode 100644
index 000000000..2f4c74e5c
--- /dev/null
+++ b/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSql.java
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.client.sql;
+
+import org.apache.ignite.internal.client.ReliableChannel;
+import org.apache.ignite.sql.IgniteSql;
+import org.apache.ignite.sql.Session;
+import org.apache.ignite.sql.Session.SessionBuilder;
+import org.apache.ignite.sql.Statement;
+import org.apache.ignite.sql.Statement.StatementBuilder;
+
+/**
+ * Client SQL.
+ */
+public class ClientSql implements IgniteSql {
+    /** Channel. */
+    private final ReliableChannel ch;
+
+    /**
+     * Constructor.
+     *
+     * @param ch Channel.
+     */
+    public ClientSql(ReliableChannel ch) {
+        this.ch = ch;
+    }
+
+    /** {@inheritDoc} */
+    @Override
+    public Session createSession() {
+        return null;
+    }
+
+    /** {@inheritDoc} */
+    @Override
+    public SessionBuilder sessionBuilder() {
+        return null;
+    }
+
+    /** {@inheritDoc} */
+    @Override
+    public Statement createStatement(String query) {
+        return null;
+    }
+
+    /** {@inheritDoc} */
+    @Override
+    public StatementBuilder statementBuilder() {
+        return null;
+    }
+}