[ignite-3] branch ignite-14972 updated: wip ClientSqlTest

[ptupitsyn]

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 dc46c9ada wip ClientSqlTest
dc46c9ada is described below

commit dc46c9adab8a97d4bf18454fb0c59d409ee31284
Author: Pavel Tupitsyn <ptupit...@apache.org>
AuthorDate: Mon May 30 19:51:16 2022 +0300

    wip ClientSqlTest
---
 .../java/org/apache/ignite/internal/client/sql/ClientSession.java   | 6 +++++-
 .../java/org/apache/ignite/internal/client/sql/ClientStatement.java | 2 ++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSession.java
 
b/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSession.java
index a8070ec72..c660ee4ce 100644
--- 
a/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSession.java
+++ 
b/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSession.java
@@ -96,7 +96,11 @@ public class ClientSession implements Session {
     /** {@inheritDoc} */
     @Override
     public CompletableFuture<AsyncResultSet> executeAsync(@Nullable 
Transaction transaction, String query, @Nullable Object... arguments) {
-        return null;
+        Objects.requireNonNull(query);
+
+        ClientStatement statement = new ClientStatement(query, null, false, 
null, null, null);
+
+        return executeAsync(transaction, statement, arguments);
     }
 
     /** {@inheritDoc} */
diff --git 
a/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatement.java
 
b/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatement.java
index eaec3a81a..fa5973b67 100644
--- 
a/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatement.java
+++ 
b/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatement.java
@@ -64,6 +64,8 @@ class ClientStatement implements Statement {
             Long queryTimeoutMs,
             Integer pageSize,
             Map<String, Object> properties) {
+        Objects.requireNonNull(query);
+
         this.query = query;
         this.defaultSchema = defaultSchema;
         this.prepared = prepared;