Merge pull request #1020 from zhicwu/develop

apply timezone to datetime default value

Author: zhicwu

clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseDateTimeValue.java

@@ -9,6 +9,7 @@
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.OffsetDateTime;
+import java.time.ZoneOffset;
 import java.time.ZonedDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.TimeZone;
@@ -24,7 +25,8 @@ public class ClickHouseDateTimeValue extends ClickHouseObjectValue<LocalDateTime
     /**
      * Default value.
      */
-    public static final LocalDateTime DEFAULT = ClickHouseDateValue.DEFAULT.atStartOfDay();
+    public static final LocalDateTime DEFAULT = ClickHouseInstantValue.DEFAULT.atOffset(ZoneOffset.UTC)
+            .toLocalDateTime();
 
     static final DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
 
@@ -111,11 +113,15 @@ public static ClickHouseDateTimeValue of(ClickHouseValue ref, String value, int
 
     private final int scale;
     private final TimeZone tz;
+    private final LocalDateTime defaultValue;
 
     protected ClickHouseDateTimeValue(LocalDateTime value, int scale, TimeZone tz) {
         super(value);
         this.scale = ClickHouseChecker.between(scale, ClickHouseValues.PARAM_SCALE, 0, 9);
         this.tz = tz != null ? tz : ClickHouseValues.UTC_TIMEZONE;
+        this.defaultValue = this.tz.equals(ClickHouseValues.UTC_TIMEZONE) ? DEFAULT
+                : ClickHouseOffsetDateTimeValue.DEFAULT.toZonedDateTime().withZoneSameInstant(this.tz.toZoneId())
+                        .toLocalDateTime();
     }
 
     public int getScale() {
@@ -237,7 +243,7 @@ public String asString(int length, Charset charset) {
 
     @Override
     public ClickHouseDateTimeValue resetToDefault() {
-        set(DEFAULT);
+        set(defaultValue);
         return this;
     }
 

clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseDateValue.java

@@ -19,7 +19,7 @@ public class ClickHouseDateValue extends ClickHouseObjectValue<LocalDate> {
     /**
      * Default date.
      */
-    public static final LocalDate DEFAULT = LocalDate.of(1970, 1, 1);
+    public static final LocalDate DEFAULT = ClickHouseOffsetDateTimeValue.DEFAULT.toLocalDate();
 
     /**
      * Create a new instance representing null value.

clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseOffsetDateTimeValue.java

@@ -87,11 +87,15 @@ public static ClickHouseOffsetDateTimeValue of(ClickHouseValue ref, LocalDateTim
 
     private final int scale;
     private final TimeZone tz;
+    private final OffsetDateTime defaultValue;
 
     protected ClickHouseOffsetDateTimeValue(OffsetDateTime value, int scale, TimeZone tz) {
         super(value);
         this.scale = ClickHouseChecker.between(scale, ClickHouseValues.PARAM_SCALE, 0, 9);
         this.tz = tz == null || tz.equals(ClickHouseValues.UTC_TIMEZONE) ? ClickHouseValues.UTC_TIMEZONE : tz;
+        this.defaultValue = this.tz.equals(ClickHouseValues.UTC_TIMEZONE) ? DEFAULT
+                : ClickHouseInstantValue.DEFAULT
+                        .atOffset(tz.toZoneId().getRules().getOffset(ClickHouseInstantValue.DEFAULT));
     }
 
     public int getScale() {
@@ -221,9 +225,7 @@ public String asString(int length, Charset charset) {
 
     @Override
     public ClickHouseOffsetDateTimeValue resetToDefault() {
-        set(tz == null ? DEFAULT
-                : ClickHouseInstantValue.DEFAULT
-                        .atOffset(tz.toZoneId().getRules().getOffset(ClickHouseInstantValue.DEFAULT)));
+        set(defaultValue);
         return this;
     }
 

clickhouse-jdbc/src/test/java/com/clickhouse/jdbc/ClickHousePreparedStatementTest.java

@@ -20,6 +20,7 @@
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
+import java.util.Calendar;
 import java.util.Collections;
 import java.util.Properties;
 import java.util.TimeZone;
@@ -36,7 +37,9 @@
 import com.clickhouse.client.ClickHouseProtocol;
 import com.clickhouse.client.config.ClickHouseClientOption;
 import com.clickhouse.client.data.ClickHouseBitmap;
+import com.clickhouse.client.data.ClickHouseDateTimeValue;
 import com.clickhouse.client.data.ClickHouseExternalTable;
+import com.clickhouse.client.data.ClickHouseOffsetDateTimeValue;
 import com.clickhouse.jdbc.internal.InputBasedPreparedStatement;
 import com.clickhouse.jdbc.internal.SqlBasedPreparedStatement;
 
@@ -1480,6 +1483,39 @@ public void testInsertWithMultipleValues() throws Exception {
         }
     }
 
+    @Test(groups = "integration")
+    public void testInsertWithNullDateTime() throws Exception {
+        Properties props = new Properties();
+        props.setProperty(JdbcConfig.PROP_NULL_AS_DEFAULT, "2");
+        try (ClickHouseConnection conn = newConnection(props);
+                Statement s = conn.createStatement()) {
+            s.execute("drop table if exists test_insert_with_null_datetime; "
+                    + "CREATE TABLE test_insert_with_null_datetime(a Int32, "
+                    + "b01 DateTime32, b02 DateTime32('America/Los_Angeles'), "
+                    + "b11 DateTime32, b12 DateTime32('America/Los_Angeles'), "
+                    + "c01 DateTime64(3), c02 DateTime64(6, 'Asia/Shanghai'), "
+                    + "c11 DateTime64(3), c12 DateTime64(6, 'Asia/Shanghai')) ENGINE=Memory");
+            try (PreparedStatement ps = conn
+                    .prepareStatement("INSERT INTO test_insert_with_null_datetime values(?, ? ,? ,?,?)")) {
+                ps.setInt(1, 1);
+                ps.setObject(2, LocalDateTime.now());
+                ps.setObject(3, LocalDateTime.now());
+                ps.setTimestamp(4, null);
+                ps.setNull(5, Types.TIMESTAMP);
+                ps.setObject(6, LocalDateTime.now());
+                ps.setObject(7, LocalDateTime.now());
+                ps.setObject(8, null);
+                ps.setTimestamp(9, null, Calendar.getInstance());
+                ps.executeUpdate();
+            }
+
+            try (ResultSet rs = s.executeQuery("select * from test_insert_with_null_datetime order by a")) {
+                Assert.assertTrue(rs.next());
+                Assert.assertFalse(rs.next());
+            }
+        }
+    }
+
     @Test(groups = "integration")
     public void testGetParameterMetaData() throws Exception {
         try (Connection conn = newConnection(new Properties());