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 9abd46a18 wip ItThinClientSqlTest
9abd46a18 is described below
commit 9abd46a18e4b70f8c088f3b0839dea27eae0e6b4
Author: Pavel Tupitsyn <[email protected]>
AuthorDate: Mon May 30 21:54:45 2022 +0300
wip ItThinClientSqlTest
---
.../ignite/internal/client/sql/ClientAsyncResultSet.java | 3 +--
.../internal/runner/app/client/ItThinClientSqlTest.java | 13 ++++++++++++-
2 files changed, 13 insertions(+), 3 deletions(-)
diff --git
a/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientAsyncResultSet.java
b/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientAsyncResultSet.java
index fd6233ec1..f9c40d752 100644
---
a/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientAsyncResultSet.java
+++
b/modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientAsyncResultSet.java
@@ -75,8 +75,7 @@ class ClientAsyncResultSet implements AsyncResultSet {
/** {@inheritDoc} */
@Override
public @Nullable ResultSetMetadata metadata() {
- // TODO: IGNITE-17052
- throw new UnsupportedOperationException("Not implemented yet.");
+ return metadata;
}
/** {@inheritDoc} */
diff --git
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java
index cf80b401b..54a2a0ed0 100644
---
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java
+++
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java
@@ -21,6 +21,8 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertTrue;
+import java.util.List;
+import org.apache.ignite.sql.ColumnMetadata;
import org.apache.ignite.sql.SqlRow;
import org.apache.ignite.sql.async.AsyncResultSet;
import org.junit.jupiter.api.Test;
@@ -31,7 +33,10 @@ import org.junit.jupiter.api.Test;
public class ItThinClientSqlTest extends ItAbstractThinClientTest {
@Test
void testExecuteAsyncSimple() {
- AsyncResultSet resultSet =
client().sql().createSession().executeAsync(null, "select 1").join();
+ AsyncResultSet resultSet = client().sql()
+ .createSession()
+ .executeAsync(null, "select 1 as num, 'hello' as str")
+ .join();
assertTrue(resultSet.hasRowSet());
assertFalse(resultSet.wasApplied());
@@ -39,5 +44,11 @@ public class ItThinClientSqlTest extends
ItAbstractThinClientTest {
SqlRow row = resultSet.currentPage().iterator().next();
assertEquals(1, row.intValue(0));
+ assertEquals("hello", row.stringValue(1));
+
+ List<ColumnMetadata> columns = resultSet.metadata().columns();
+ assertEquals(2, columns.size());
+ assertEquals("NUM", columns.get(0).name());
+ assertEquals("STR", columns.get(1).name());
}
}