private Object readField(ResultSet rs, int fieldNo, Column actualColumn, Table actualTable)
                throws SQLException {

            OracleValueConverters oracleValueConverters =
                    new OracleValueConverters(connectorConfig, jdbcConnection);

            final SchemaBuilder schemaBuilder = oracleValueConverters.schemaBuilder(actualColumn);
            if (schemaBuilder == null) {
                return null;
            }
            Schema schema = schemaBuilder.build();
            Field field = new Field(actualColumn.name(), 1, schema);
            final ValueConverter valueConverter =
                    oracleValueConverters.converter(actualColumn, field);
            return valueConverter.convert(rs.getObject(fieldNo));
        }
copied from
io.debezium.connector.oracle.antlr.listener.ParserUtils#convertValueToSchemaType.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/reader/fetch/OracleScanFetchTask.java