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());
     }
 }

Reply via email to