You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by pt...@apache.org on 2022/05/30 13:30:14 UTC
[ignite-3] branch ignite-14972 updated: wip ClientSql
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 5dea86e33 wip ClientSql
5dea86e33 is described below
commit 5dea86e33cf882ed692704d5976a7cd829056e0d
Author: Pavel Tupitsyn <pt...@apache.org>
AuthorDate: Mon May 30 16:30:08 2022 +0300
wip ClientSql
---
.../ignite/internal/client/sql/ClientSession.java | 17 +++++++++++++----
.../apache/ignite/internal/client/sql/ClientSql.java | 2 +-
2 files changed, 14 insertions(+), 5 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 343388e35..a14d05069 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
@@ -44,12 +44,14 @@ public class ClientSession implements Session {
/** Channel. */
private final ReliableChannel ch;
- private final int defaultPageSize;
+ @Nullable
+ private final Integer defaultPageSize;
@Nullable
private final String defaultSchema;
- private final long defaultTimeout;
+ @Nullable
+ private final Long defaultTimeout;
@Nullable
private final Map<String, Object> properties;
@@ -66,9 +68,9 @@ public class ClientSession implements Session {
@SuppressWarnings("AssignmentOrReturnOfFieldWithMutableType")
public ClientSession(
ReliableChannel ch,
- int defaultPageSize,
+ @Nullable Integer defaultPageSize,
@Nullable String defaultSchema,
- long defaultTimeout,
+ @Nullable Long defaultTimeout,
@Nullable Map<String, Object> properties) {
this.ch = ch;
this.defaultPageSize = defaultPageSize;
@@ -135,6 +137,13 @@ public class ClientSession implements Session {
boolean hasMorePages = r.in().unpackBoolean();
boolean wasApplied = r.in().unpackBoolean();
+ r.in().unpackArrayHeader(); // TODO: Metadata IGNITE-17052.
+
+ if (hasRowSet) {
+ // TODO: Unpack rows.
+ }
+
+ return new ClientAsyncResultSet();
});
}
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
index 1cab38d87..e369a2a7c 100644
--- 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
@@ -43,7 +43,7 @@ public class ClientSql implements IgniteSql {
/** {@inheritDoc} */
@Override
public Session createSession() {
- return new ClientSession(ch);
+ return new ClientSession(ch, null, null, null, null);
}
/** {@inheritDoc} */