[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 6114df188 wip ClientSqlTest
6114df188 is described below

commit 6114df188bbdac6f674141449f8903287b433da5
Author: Pavel Tupitsyn <ptupit...@apache.org>
AuthorDate: Mon May 30 18:44:13 2022 +0300

    wip ClientSqlTest
---
 .../org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java  | 2 +-
 .../main/java/org/apache/ignite/internal/client/TcpIgniteClient.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java
 
b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java
index a952fe848..a480d92b3 100644
--- 
a/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java
+++ 
b/modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java
@@ -40,7 +40,7 @@ class ClientSqlCommon {
         }
 
         if (!asyncResultSet.hasMorePages()) {
-            asyncResultSet.close();
+            asyncResultSet.closeAsync();
         }
     }
 }
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 ef7449890..e75465107 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
@@ -131,7 +131,7 @@ public class TcpIgniteClient implements IgniteClient {
     /** {@inheritDoc} */
     @Override
     public IgniteSql sql() {
-        throw new UnsupportedOperationException("Not implemented yet.");
+        return new ClientSql(ch);
     }
 
     /** {@inheritDoc} */