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

[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 8e07ec19b wip ClientSession
8e07ec19b is described below

commit 8e07ec19be82c05e203cc1b515d2852f17fb064d
Author: Pavel Tupitsyn <ptupit...@apache.org>
AuthorDate: Mon May 30 18:10:09 2022 +0300

    wip ClientSession
---
 .../ignite/internal/client/sql/ClientSession.java      | 18 ++++++++++--------
 1 file changed, 10 insertions(+), 8 deletions(-)

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 a14d05069..a8070ec72 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
@@ -101,16 +101,18 @@ public class ClientSession implements Session {
 
     /** {@inheritDoc} */
     @Override
-    public CompletableFuture<AsyncResultSet> executeAsync(@Nullable 
Transaction transaction, Statement statement,
+    public CompletableFuture<AsyncResultSet> executeAsync(
+            @Nullable Transaction transaction,
+            Statement statement,
             @Nullable Object... arguments) {
         Objects.requireNonNull(statement);
 
         return ch.serviceAsync(ClientOp.SQL_EXEC, w -> {
             writeTx(transaction, w);
 
-            w.out().packInt(defaultPageSize);
-            w.out().packString(defaultSchema);
-            w.out().packLong(defaultTimeout);
+            w.out().packObject(defaultPageSize);
+            w.out().packObject(defaultSchema);
+            w.out().packObject(defaultTimeout);
 
             if (properties != null) {
                 w.out().packMapHeader(0);
@@ -123,10 +125,10 @@ public class ClientSession implements Session {
                 }
             }
 
-            w.out().packString(statement.defaultSchema());
-            w.out().packInt(statement.pageSize());
-            w.out().packString(statement.query());
-            w.out().packLong(statement.queryTimeout(TimeUnit.MILLISECONDS));
+            w.out().packObject(statement.defaultSchema());
+            w.out().packObject(statement.pageSize());
+            w.out().packObject(statement.query());
+            w.out().packObject(statement.queryTimeout(TimeUnit.MILLISECONDS));
             w.out().packBoolean(statement.prepared());
 
             // TODO: Pack statement properties.