alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-8142 Clean-up casting to be type-safe

Browse Source
This commit is contained in:
Chris Cranford 2024-09-03 06:46:14 -04:00 committed by Jiri Pechanec
parent 421be19ffe
commit b15ce52021
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/olr/OpenLogReplicatorValueConverter.java
View File

@ -115,7 +115,7 @@ protected Object convertTimestampWithZone(Column column, Field fieldDefn, Object
@Override @Override
protected Object convertTimestampWithLocalZone(Column column, Field fieldDefn, Object value) { protected Object convertTimestampWithLocalZone(Column column, Field fieldDefn, Object value) {
if (value instanceof Number) { if (value instanceof Number) {
final Instant instant = Instant.ofEpochSecond(0, (Long) value); final Instant instant = Instant.ofEpochSecond(0, ((Number) value).longValue());
return getTimestampWithLocalTimeZoneFormatter(column).format(OffsetDateTime.ofInstant(instant, ZoneOffset.UTC)); return getTimestampWithLocalTimeZoneFormatter(column).format(OffsetDateTime.ofInstant(instant, ZoneOffset.UTC));
} }
return super.convertTimestampWithLocalZone(column, fieldDefn, value); return super.convertTimestampWithLocalZone(column, fieldDefn, value);
@ -160,12 +160,12 @@ private Object convertTimestampValue(Column column, Object value) {
value = ((BigInteger) value).divide(BigInteger.valueOf(1_000_000L)).longValue(); value = ((BigInteger) value).divide(BigInteger.valueOf(1_000_000L)).longValue();
} }
else { else {
value = ((Long) value) / 1_000_000L; value = ((Number) value).longValue() / 1_000_000L;
} }
} }
else { else {
// TIMESTAMP(n) // TIMESTAMP(n)
value = Instant.ofEpochSecond(0, (Long) value); value = Instant.ofEpochSecond(0, ((Number) value).longValue());
} }
return value; return value;
} }