Skip to content

Commit 211e3a1

Browse files
committed
Use client for all operations to preserve causality
1 parent 3de35ec commit 211e3a1

File tree

1 file changed

+7
-8
lines changed

1 file changed

+7
-8
lines changed

modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItCriteriaQueryTest.java

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -530,7 +530,8 @@ public <T> void testKeyViewWithQuotes(CriteriaQuerySource<T> view, Function<T, E
530530
public void testQueryAllColumnTypes() {
531531
String tableName = "all_column_types";
532532

533-
sql(format("CREATE TABLE {} (str VARCHAR PRIMARY KEY, byteCol TINYINT, shortCol SMALLINT, intCol INT, longCol BIGINT, "
533+
CLIENT.sql().executeScript(format(
534+
"CREATE TABLE {} (str VARCHAR PRIMARY KEY, byteCol TINYINT, shortCol SMALLINT, intCol INT, longCol BIGINT, "
534535
+ "floatCol REAL, doubleCol DOUBLE, decimalCol DECIMAL(6, 3), boolCol BOOLEAN, bytesCol VARBINARY, "
535536
+ "uuidCol UUID, dateCol DATE, timeCol TIME, datetimeCol TIMESTAMP, instantCol TIMESTAMP WITH LOCAL TIME ZONE)",
536537
tableName));
@@ -542,13 +543,11 @@ public void testQueryAllColumnTypes() {
542543
Instant instant = Instant.parse("2024-01-01T12:00:00Z");
543544
byte[] bytes = {1, 2, 3};
544545

545-
insertData(
546-
tableName,
547-
List.of("str", "byteCol", "shortCol", "intCol", "longCol", "floatCol", "doubleCol", "decimalCol",
548-
"boolCol", "bytesCol", "uuidCol", "dateCol", "timeCol", "datetimeCol", "instantCol"),
549-
new Object[]{"test", (byte) 1, (short) 2, 3, 4L, 5.0f, 6.0d, new BigDecimal("7.89"), true,
550-
bytes, uuid, localDate, localTime, localDateTime, instant}
551-
);
546+
CLIENT.sql().executeScript("INSERT INTO " + tableName + " (str, byteCol, shortCol, intCol, longCol, floatCol, doubleCol, "
547+
+ "decimalCol, boolCol, bytesCol, uuidCol, dateCol, timeCol, datetimeCol, instantCol) VALUES "
548+
+ "(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)",
549+
"test", (byte) 1, (short) 2, 3, 4L, 5.0f, 6.0d, new BigDecimal("7.89"), true,
550+
bytes, uuid, localDate, localTime, localDateTime, instant);
552551

553552
Table table = CLIENT.tables().table(tableName);
554553

0 commit comments

Comments
 (0)