IGNITE-21568 Java thin: Pass client time zone to server

modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlProperties.java

@@ -17,6 +17,7 @@
 
 package org.apache.ignite.client.handler.requests.sql;
 
+import java.time.ZoneId;
 import javax.annotation.Nullable;
 import org.apache.ignite.internal.client.proto.ClientMessageUnpacker;
 import org.apache.ignite.internal.sql.api.IgniteSqlImpl;
@@ -25,26 +26,32 @@
 import org.apache.ignite.internal.sql.engine.property.SqlPropertiesHelper;
 
 class ClientSqlProperties {
-    private final @Nullable String schema;
+    @Nullable
+    private final String schema;
 
     private final int pageSize;
 
     private final long queryTimeout;
 
     private final long idleTimeout;
 
+    @Nullable
+    private String timeZoneId;
+
     ClientSqlProperties(ClientMessageUnpacker in) {
         schema = in.tryUnpackNil() ? null : in.unpackString();
         pageSize = in.tryUnpackNil() ? IgniteSqlImpl.DEFAULT_PAGE_SIZE : in.unpackInt();
         queryTimeout = in.tryUnpackNil() ? 0 : in.unpackLong();
         idleTimeout = in.tryUnpackNil() ? 0 : in.unpackLong();
+        timeZoneId = in.tryUnpackNil() ? null : in.unpackString();
 
         // Skip properties - not used by SQL engine.
         in.unpackInt(); // Number of properties.
         in.readBinaryUnsafe(); // Binary tuple with properties
     }
 
-    public @Nullable String schema() {
+    @Nullable
+    public String schema() {
         return schema;
     }
 
@@ -68,6 +75,10 @@ SqlProperties toSqlProps() {
             builder.set(QueryProperty.DEFAULT_SCHEMA, schema);
         }
 
+        if (timeZoneId != null) {
+            builder.set(QueryProperty.TIME_ZONE_ID, ZoneId.of(timeZoneId));
+        }
+
         return builder.build();
     }
 }

modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSql.java

@@ -20,6 +20,7 @@
 import static org.apache.ignite.internal.client.table.ClientTable.writeTx;
 import static org.apache.ignite.internal.util.ExceptionUtils.unwrapCause;
 
+import java.time.ZoneId;
 import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Objects;
@@ -75,7 +76,7 @@ public ClientSql(ReliableChannel ch, MarshallersProvider marshallers) {
     /** {@inheritDoc} */
     @Override
     public Statement createStatement(String query) {
-        return new ClientStatement(query, null, null, null);
+        return new ClientStatement(query, null, null, null, null);
     }
 
     /** {@inheritDoc} */
@@ -177,7 +178,7 @@ public CompletableFuture<AsyncResultSet<SqlRow>> executeAsync(
             @Nullable Object... arguments) {
         Objects.requireNonNull(query);
 
-        ClientStatement statement = new ClientStatement(query, null, null, null);
+        ClientStatement statement = new ClientStatement(query, null, null, null, null);
 
         return executeAsync(transaction, statement, arguments);
     }
@@ -200,7 +201,7 @@ public <T> CompletableFuture<AsyncResultSet<T>> executeAsync(
             @Nullable Object... arguments) {
         Objects.requireNonNull(query);
 
-        ClientStatement statement = new ClientStatement(query, null, null, null);
+        ClientStatement statement = new ClientStatement(query, null, null, null, null);
 
         return executeAsync(transaction, mapper, statement, arguments);
     }
@@ -228,6 +229,7 @@ public <T> CompletableFuture<AsyncResultSet<T>> executeAsync(
             w.out().packLongNullable(clientStatement.queryTimeoutNullable());
 
             w.out().packLongNullable(0L); // defaultSessionTimeout
+            w.out().packString(clientStatement.timeZoneId().getId());
 
             packProperties(w, null);
 
@@ -286,6 +288,7 @@ public CompletableFuture<Void> executeScriptAsync(String query, @Nullable Object
             w.out().packNil(); // pageSize
             w.out().packNil(); // queryTimeout
             w.out().packNil(); // sessionTimeout
+            w.out().packString(ZoneId.systemDefault().getId());
 
             packProperties(w, null);
 

modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatement.java

@@ -18,10 +18,10 @@
 package org.apache.ignite.internal.client.sql;
 
 import java.time.ZoneId;
-import java.time.ZoneOffset;
 import java.util.Objects;
 import java.util.concurrent.TimeUnit;
 import org.apache.ignite.sql.Statement;
+import org.jetbrains.annotations.Nullable;
 
 /**
  * Client SQL statement.
@@ -31,14 +31,20 @@ public class ClientStatement implements Statement {
     private final String query;
 
     /** Default schema. */
+    @Nullable
     private final String defaultSchema;
 
     /** Query timeout. */
+    @Nullable
     private final Long queryTimeoutMs;
 
     /** Page size. */
+    @Nullable
     private final Integer pageSize;
 
+    /** Time-zone ID. */
+    private final ZoneId timeZoneId;
+
     /**
      * Constructor.
      *
@@ -48,17 +54,19 @@ public class ClientStatement implements Statement {
      * @param pageSize Page size.
      */
     @SuppressWarnings("AssignmentOrReturnOfFieldWithMutableType")
-    public ClientStatement(
+    ClientStatement(
             String query,
-            String defaultSchema,
-            Long queryTimeoutMs,
-            Integer pageSize) {
+            @Nullable String defaultSchema,
+            @Nullable Long queryTimeoutMs,
+            @Nullable Integer pageSize,
+            @Nullable ZoneId timeZoneId) {
         Objects.requireNonNull(query);
 
         this.query = query;
         this.defaultSchema = defaultSchema;
         this.queryTimeoutMs = queryTimeoutMs;
         this.pageSize = pageSize;
+        this.timeZoneId = timeZoneId != null ? timeZoneId : ZoneId.systemDefault();
     }
 
     /** {@inheritDoc} */
@@ -80,7 +88,8 @@ public long queryTimeout(TimeUnit timeUnit) {
      *
      * @return Query timeout.
      */
-    public Long queryTimeoutNullable() {
+    @Nullable
+    Long queryTimeoutNullable() {
         return queryTimeoutMs;
     }
 
@@ -93,8 +102,7 @@ public String defaultSchema() {
     /** {@inheritDoc} */
     @Override
     public ZoneId timeZoneId() {
-        // TODO: https://issues.apache.org/jira/browse/IGNITE-21568
-        return ZoneOffset.UTC;
+        return timeZoneId;
     }
 
     /** {@inheritDoc} */
@@ -108,7 +116,8 @@ public int pageSize() {
      *
      * @return Page size.
      */
-    public Integer pageSizeNullable() {
+    @Nullable
+    Integer pageSizeNullable() {
         return pageSize;
     }
 

modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatementBuilder.java

@@ -39,6 +39,9 @@ public class ClientStatementBuilder implements Statement.StatementBuilder {
     /** Page size. */
     private Integer pageSize;
 
+    /** Time-zone ID. */
+    private ZoneId timeZoneId;
+
     /** {@inheritDoc} */
     @Override
     public StatementBuilder query(String query) {
@@ -75,8 +78,9 @@ public StatementBuilder pageSize(int pageSize) {
 
     @Override
     public StatementBuilder timeZoneId(ZoneId timeZoneId) {
-        // TODO: https://issues.apache.org/jira/browse/IGNITE-21568
-        throw new UnsupportedOperationException("Not implemented yet");
+        this.timeZoneId = timeZoneId;
+
+        return this;
     }
 
     /** {@inheritDoc} */
@@ -86,6 +90,7 @@ public Statement build() {
                 query,
                 defaultSchema,
                 queryTimeoutMs,
-                pageSize);
+                pageSize,
+                timeZoneId);
     }
 }

modules/client/src/test/java/org/apache/ignite/client/ClientSqlTest.java

@@ -33,6 +33,7 @@
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.Period;
+import java.time.ZoneId;
 import java.util.BitSet;
 import java.util.Map;
 import java.util.UUID;
@@ -84,6 +85,7 @@ public void testStatementPropertiesPropagation() {
                 .defaultSchema("SCHEMA2")
                 .queryTimeout(124, TimeUnit.SECONDS)
                 .pageSize(235)
+                .timeZoneId(ZoneId.of("Europe/London"))
                 .build();
 
         AsyncResultSet<SqlRow> resultSet = client.sql().executeAsync(null, statement).join();
@@ -94,6 +96,7 @@ public void testStatementPropertiesPropagation() {
         assertEquals("SCHEMA2", props.get("schema"));
         assertEquals("124000", props.get("timeout"));
         assertEquals("235", props.get("pageSize"));
+        assertEquals("Europe/London", props.get("timeZoneId"));
     }
 
     @Test

modules/client/src/test/java/org/apache/ignite/client/fakes/FakeCursor.java

@@ -19,6 +19,7 @@
 
 import static org.apache.ignite.internal.sql.engine.QueryProperty.DEFAULT_SCHEMA;
 import static org.apache.ignite.internal.sql.engine.QueryProperty.QUERY_TIMEOUT;
+import static org.apache.ignite.internal.sql.engine.QueryProperty.TIME_ZONE_ID;
 import static org.apache.ignite.internal.util.CompletableFutures.nullCompletedFuture;
 
 import java.math.BigDecimal;
@@ -61,6 +62,7 @@ public class FakeCursor implements AsyncSqlCursor<InternalSqlRow> {
 
             rows.add(getRow("schema", properties.get(DEFAULT_SCHEMA)));
             rows.add(getRow("timeout", String.valueOf(properties.get(QUERY_TIMEOUT))));
+            rows.add(getRow("timeZoneId", String.valueOf(properties.get(TIME_ZONE_ID))));
         } else if ("SELECT META".equals(qry)) {
             columns.add(new FakeColumnMetadata("BOOL", ColumnType.BOOLEAN));
             columns.add(new FakeColumnMetadata("INT8", ColumnType.INT8));

modules/platforms/cpp/ignite/client/detail/sql/sql_impl.cpp

@@ -29,6 +29,7 @@ void write_statement(protocol::writer &writer, const sql_statement &statement) {
     writer.write(statement.page_size());
     writer.write(std::int64_t(statement.timeout().count()));
     writer.write_nil(); // Session timeout (unused, session is closed by the server immediately).
+    writer.write_nil(); // TODO: IGNITE-21605 Time zone id.
 
     const auto &properties = statement.properties();
     auto props_num = std::int32_t(properties.size());

modules/platforms/cpp/ignite/odbc/query/data_query.cpp

@@ -274,6 +274,7 @@ sql_result data_query::make_request_execute() {
             writer.write(m_connection.get_configuration().get_page_size().get_value());
             writer.write(std::int64_t(m_connection.get_timeout()) * 1000);
             writer.write_nil(); // Session timeout (unused, session is closed by the server immediately).
+            writer.write_nil(); // TODO: IGNITE-21605 Time zone id.
 
             // Properties are not used for now.
             writer.write(0);

modules/platforms/dotnet/Apache.Ignite.Tests/FakeServer.cs

@@ -441,6 +441,7 @@ private void SqlExec(Socket handler, long requestId, MsgPackReader reader)
             props["timeoutMs"] = timeoutMs;
 
             props["sessionTimeoutMs"] = reader.TryReadNil() ? (long?)null : reader.ReadInt64();
+            props["timeZoneId"] = reader.TryReadNil() ? null : reader.ReadString();
 
             // ReSharper restore RedundantCast
             var propCount = reader.ReadInt32();
@@ -550,7 +551,8 @@ private void SqlExecScript(MsgPackReader reader)
                 ["schema"] = reader.TryReadNil() ? null : reader.ReadString(),
                 ["pageSize"] = reader.TryReadNil() ? null : reader.ReadInt32(),
                 ["timeoutMs"] = reader.TryReadNil() ? null : reader.ReadInt64(),
-                ["sessionTimeoutMs"] = reader.TryReadNil() ? null : reader.ReadInt64()
+                ["sessionTimeoutMs"] = reader.TryReadNil() ? null : reader.ReadInt64(),
+                ["timeZoneId"] = reader.TryReadNil() ? null : reader.ReadString()
             };
 
             var propCount = reader.ReadInt32();

modules/platforms/dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs

@@ -402,7 +402,7 @@ public async Task TestStatementProperties()
             var props = rows.ToDictionary(x => (string)x["NAME"]!, x => (string)x["VAL"]!);
 
             Assert.IsTrue(res.HasRowSet);
-            Assert.AreEqual(8, props.Count);
+            Assert.AreEqual(9, props.Count);
 
             Assert.AreEqual("schema-1", props["schema"]);
             Assert.AreEqual("987", props["pageSize"]);

modules/platforms/dotnet/Apache.Ignite/Internal/Sql/Sql.cs

@@ -238,6 +238,8 @@ private void WriteStatement(
             w.Write(statement.PageSize);
             w.Write((long)statement.Timeout.TotalMilliseconds);
             w.WriteNil(); // Session timeout (unused, session is closed by the server immediately).
+            w.WriteNil(); // TODO: IGNITE-21604 Time zone id.
+
             WriteProperties(statement, ref w);
             w.Write(statement.Query);
             w.WriteObjectCollectionAsBinaryTuple(args);

modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/api/ItSqlApiBaseTest.java

@@ -29,6 +29,8 @@
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
+import java.time.LocalDateTime;
+import java.time.ZoneId;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Set;
@@ -56,6 +58,7 @@
 import org.apache.ignite.sql.SqlException;
 import org.apache.ignite.sql.SqlRow;
 import org.apache.ignite.sql.Statement;
+import org.apache.ignite.sql.Statement.StatementBuilder;
 import org.apache.ignite.table.Table;
 import org.apache.ignite.tx.Transaction;
 import org.apache.ignite.tx.TransactionOptions;
@@ -840,6 +843,28 @@ public void runScriptThatFails() {
         assertEquals(1, result.result().get(0).intValue(0));
     }
 
+    @ParameterizedTest
+    @ValueSource(strings = {"", "UTC", "Europe/Athens", "America/New_York", "Asia/Tokyo"})
+    public void testTimeZoneId(String timeZoneId) {
+        ZoneId zoneId = timeZoneId.isEmpty() ? ZoneId.systemDefault() : ZoneId.of(timeZoneId);
+
+        StatementBuilder builder = igniteSql().statementBuilder()
+                .query("SELECT CURRENT_TIMESTAMP")
+                .timeZoneId(zoneId);
+
+        ResultSet<SqlRow> resultSet = igniteSql().execute(null, builder.build());
+        SqlRow row = resultSet.next();
+
+        LocalDateTime ts = row.value(0);
+        assertNotNull(ts);
+
+        float tsMillis = ts.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli();
+        float nowMillis = LocalDateTime.now(zoneId).atZone(ZoneId.systemDefault()).toInstant().toEpochMilli();
+        float deltaMillis = 5000;
+
+        assertEquals(nowMillis, tsMillis, deltaMillis);
+    }
+
     protected ResultSet<SqlRow> executeForRead(IgniteSql sql, String query, Object... args) {
         return executeForRead(sql, null, query, args);
     }