[INLONG-6507][Sort] Convert date to timestamp in oracle connector

[e-mhui]

Prepare a Pull Request

[INLONG-6507][Sort] Convert date to timestamp in oracle connector

• Fixes [Bug][Sort] Should convert date type to timestamp type in Oracle connector #6507

Motivation

In debezium, the oracle date type will be read as the int64 type, but the oracle date type mapping is the debezium timestamp type, and the debezium timestamp type is the string format of date-time. So, we need to convert the int64 to the string format of date-time.

Modifications

When parsing field value, if the field schema is date or timestamp type, we need to convert the filed value from the number of milliseconds to the string format of date-time. The main logic is as follows:

    /**
     * extract the data with the format provided by debezium
     *
     * @param fieldValue
     * @param schemaName
     * @return the extracted data with schema
     */
    private Object getValueWithSchema(Object fieldValue, String schemaName) {
        if (MicroTime.SCHEMA_NAME.equals(schemaName)) {
            Instant instant = Instant.ofEpochMilli((Long) fieldValue / 1000);
            fieldValue = timeFormatter.format(LocalDateTime.ofInstant(instant, serverTimeZone));
        } else if (Date.SCHEMA_NAME.equals(schemaName)) {
            fieldValue = dateFormatter.format(LocalDate.ofEpochDay((Integer) fieldValue));
        } else if (ZonedTimestamp.SCHEMA_NAME.equals(schemaName)) {
            ZonedDateTime zonedDateTime = ZonedDateTime.parse((CharSequence) fieldValue);
            fieldValue = zonedDateTime.withZoneSameInstant(serverTimeZone).toLocalDateTime()
                    .atZone(ZONE_UTC).format(DateTimeFormatter.ISO_INSTANT);
        } else if (Timestamp.SCHEMA_NAME.equals(schemaName)) {
            Instant instantTime = Instant.ofEpochMilli((Long) fieldValue);
            fieldValue = LocalDateTime.ofInstant(instantTime, ZONE_UTC).toString();
        }
        return fieldValue;
    }

[gong]

Maybe, PR description is not consistent with modification of code

[EMsnap]

Please check the mysql connector for the date and timestamp data.

[e-mhui]

Please check the mysql connector for the date and timestamp data.

Yes, the oracle connector handles date and timestamp data like the mysql connector.

[e-mhui]

Maybe, PR description is not consistent with modification of code

More details have been added to the PR description.

[gong]

Maybe, PR description is not consistent with modification of code

More details have been added to the PR description.

@e-mhui good.