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

DBZ-804 Simplifying construction of VariableScaleDecimal

Browse Source
This commit is contained in:
Gunnar Morling 2018-07-24 11:24:44 +02:00 committed by Jiri Pechanec
parent 5e02210553
commit bd4f3d60fa
1 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
debezium-core/src/main/java/io/debezium/data/VariableScaleDecimal.java
View File

@ -8,6 +8,7 @@
import java.math.BigDecimal;
import java.math.BigInteger;
import java.util.Objects;
import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.data.SchemaBuilder;
@ -61,7 +62,7 @@ public static Schema optionalSchema() {
}
/**
* Converts a value from its logical format (BigDecimal) to its encoded format - a struct containing
* Converts a value from its logical format to its encoded format - a struct containing
* the scale of the number and a binary representation of the number.
*
* @param schema of the encoded value
@ -70,11 +71,25 @@ public static Schema optionalSchema() {
* @return the encoded value
*/
public static Struct fromLogical(Schema schema, SpecialValueDecimal value) {
return fromLogical(schema, value.getDecimalValue().orElse(null));
}
/**
* Converts a value from its logical format to its encoded format - a struct containing
* the scale of the number and a binary representation of the number.
*
* @param schema of the encoded value
* @param value the value or the decimal
*
* @return the encoded value
*/
public static Struct fromLogical(Schema schema, BigDecimal decimalValue) {
Objects.requireNonNull(decimalValue, "decimalValue may not be null");
Struct result = new Struct(schema);
final BigDecimal decimalValue = value.getDecimalValue().orElse(null);
assert decimalValue != null : "Unable to encode special value";
result.put(VALUE_FIELD, decimalValue.unscaledValue().toByteArray());
result.put(SCALE_FIELD, decimalValue.scale());
return result;
}
@ -85,6 +100,6 @@ public static Struct fromLogical(Schema schema, SpecialValueDecimal value) {
* @return the decoded value
*/
public static SpecialValueDecimal toLogical(final Struct value) {
return new SpecialValueDecimal(new BigDecimal(new BigInteger((byte[])value.getBytes(VALUE_FIELD)), value.getInt32(SCALE_FIELD)));
return new SpecialValueDecimal(new BigDecimal(new BigInteger(value.getBytes(VALUE_FIELD)), value.getInt32(SCALE_FIELD)));
}
}