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

[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 abcb09aad wip testExecuteAsyncDdlDml
abcb09aad is described below

commit abcb09aad6942f90748502354e8bc40a2e191263
Author: Pavel Tupitsyn <ptupit...@apache.org>
AuthorDate: Mon May 30 22:37:05 2022 +0300

    wip testExecuteAsyncDdlDml
---
 .../runner/app/client/ItThinClientSqlTest.java     | 22 +++++++++++++++++-----
 1 file changed, 17 insertions(+), 5 deletions(-)

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 bfd7b6f6f..31bf22437 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
@@ -61,6 +61,7 @@ public class ItThinClientSqlTest extends 
ItAbstractThinClientTest {
     void testExecuteAsyncDdlDml() {
         Session session = client().sql().createSession();
 
+        // Create table.
         AsyncResultSet createRes = session.executeAsync(null, "CREATE TABLE 
TEST(ID INT PRIMARY KEY, VAL VARCHAR)").join();
 
         assertFalse(createRes.hasRowSet());
@@ -68,12 +69,23 @@ public class ItThinClientSqlTest extends 
ItAbstractThinClientTest {
         assertEquals(-1, createRes.affectedRows());
         assertThrows(NoRowSetExpectedException.class, 
createRes::currentPageSize);
 
-        AsyncResultSet insertRes = session.executeAsync(null, "INSERT INTO 
TEST VALUES (?, ?)", 1, "hello").join();
+        // Insert data.
+        for (int i = 0; i < 10; i++) {
+            AsyncResultSet insertRes = session.executeAsync(null, "INSERT INTO 
TEST VALUES (?, ?)", 1, "hello").join();
 
-        assertFalse(insertRes.hasRowSet());
-        assertFalse(insertRes.wasApplied());
-        assertEquals(1, insertRes.affectedRows());
-        assertThrows(NoRowSetExpectedException.class, createRes::currentPage);
+            assertFalse(insertRes.hasRowSet());
+            assertFalse(insertRes.wasApplied());
+            assertEquals(1, insertRes.affectedRows());
+            assertThrows(NoRowSetExpectedException.class, 
createRes::currentPage);
+        }
+
+        // Query data.
+
+        // Update data.
+
+        // Delete data.
+
+        // Delete table.
     }
 
     @Test