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

DBZ-644 change Original Data Type mapper and add a test

Browse Source
This commit is contained in:
orr.ganani 2018-04-26 15:43:01 +03:00 committed by Jiri Pechanec
parent 747184c572
commit ac515b8064
2 changed files with 39 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-core/src/main/java/io/debezium/relational/mapping/AddOriginalDataType.java
View File

@ -17,6 +17,7 @@ public ValueConverter create(Column column) {
@Override
public void alterFieldSchema(Column column, SchemaBuilder schemaBuilder) {
schemaBuilder.parameter("originalType", column.typeName().toUpperCase());
schemaBuilder.parameter("originalType", String.valueOf(column.jdbcType()));
schemaBuilder.parameter("columnSize", String.valueOf(column.length()));
}
}

37
debezium-core/src/test/java/io/debezium/relational/mapping/OriginalDataTypeTest.java Normal file
View File

@ -0,0 +1,37 @@
/*
* Copyright Debezium Authors.
*
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/
package io.debezium.relational.mapping;
import io.debezium.relational.Column;
import org.apache.kafka.connect.data.SchemaBuilder;
import org.junit.Test;
import java.sql.Types;
import static org.fest.assertions.Assertions.assertThat;
/**
* @author Orr Ganani
*
*/
public class OriginalDataTypeTest {
private final int length = 255;
private final Column column = Column.editor()
.name("col")
.type("VARCHAR")
.jdbcType(Types.VARCHAR)
.length(length)
.create();
@Test
public void shouldTruncateStrings() {
SchemaBuilder schemaBuilder = SchemaBuilder.string();
new AddOriginalDataType().alterFieldSchema(column, schemaBuilder);
assertThat(schemaBuilder.parameters().get("originalType")).isEqualTo(String.valueOf(Types.VARCHAR));
assertThat(schemaBuilder.parameters().get("columnSize")).isEqualTo(String.valueOf(length));
}
}