Skip to content

Commit 72172cb

Browse files
committed
aligned converter utils with #7339
1 parent 70f80bf commit 72172cb

File tree

1 file changed

+12
-2
lines changed
  • airbyte-integrations/bases/debezium/src/main/java/io/airbyte/integrations/debezium/internals

1 file changed

+12
-2
lines changed

airbyte-integrations/bases/debezium/src/main/java/io/airbyte/integrations/debezium/internals/MSSQLConverter.java

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,17 @@
66

77
import io.debezium.spi.converter.CustomConverter;
88
import io.debezium.spi.converter.RelationalColumn;
9+
import java.math.BigDecimal;
910
import java.util.Objects;
1011
import java.util.Properties;
1112
import org.apache.kafka.connect.data.SchemaBuilder;
13+
import org.slf4j.Logger;
14+
import org.slf4j.LoggerFactory;
1215

1316
public class MSSQLConverter implements CustomConverter<SchemaBuilder, RelationalColumn> {
1417

18+
private final Logger LOGGER = LoggerFactory.getLogger(MSSQLConverter.class);;
19+
1520
private final String SMALLDATETIME_TYPE = "SMALLDATETIME";
1621
private final String SMALLMONEY_TYPE = "SMALLMONEY";
1722

@@ -47,9 +52,14 @@ private void registerMoney(final RelationalColumn field,
4752
return DebeziumConverterUtils.convertDefaultValue(field);
4853
}
4954

50-
return DebeziumConverterUtils.convertMoney(input);
51-
});
55+
if (input instanceof BigDecimal) {
56+
return ((BigDecimal) input).doubleValue();
57+
}
5258

59+
LOGGER.warn("Uncovered money class type '{}'. Use default converter",
60+
input.getClass().getName());
61+
return input.toString();
62+
});
5363
}
5464

5565
}

0 commit comments

Comments
 (0)