Skip to content

Commit 75a5a68

Browse files
committed
Handled date datetype conversion
1 parent 872f823 commit 75a5a68

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

src/main/java/io/confluent/connect/jdbc/dialect/GenericDatabaseDialect.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1748,6 +1748,15 @@ protected boolean maybeBindLogical(
17481748
DateTimeUtils.getTimeZoneCalendar(timeZone)
17491749
);
17501750
return true;
1751+
case "io.debezium.time.Date":
1752+
long valuenew = Long.parseLong(value.toString()) * 86400000L;
1753+
java.util.Date dateValue = new java.util.Date(valuenew);
1754+
statement.setDate(
1755+
index,
1756+
new java.sql.Date(((java.util.Date) dateValue).getTime()),
1757+
DateTimeUtils.getTimeZoneCalendar(timeZone)
1758+
);
1759+
return true;
17511760
default:
17521761
return false;
17531762
}

0 commit comments

Comments
 (0)