Skip to content

Commit db855ae

Browse files
authored
add support for BIT data type (#4)
Add support for `BIT` data type. Signed-off-by: Max Englander <[email protected]>
1 parent 8f269a9 commit db855ae

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

src/main/java/io/debezium/connector/planetscale/VitessType.java

+2
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,8 @@ public int hashCode() {
104104
public static VitessType resolve(Query.Field field) {
105105
String type = field.getType().name();
106106
switch (type) {
107+
case "BIT":
108+
return new VitessType(type, Types.BIT);
107109
case "INT8":
108110
case "UINT8":
109111
case "INT16":

src/test/java/io/debezium/connector/planetscale/VitessTypeTest.java

+1
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ public class VitessTypeTest {
1818

1919
@Test
2020
public void shouldResolveVitessTypeToJdbcType() {
21+
assertThat(VitessType.resolve(asField(Query.Type.BIT)).getJdbcId()).isEqualTo(Types.BIT);
2122
assertThat(VitessType.resolve(asField(Query.Type.INT8)).getJdbcId()).isEqualTo(Types.SMALLINT);
2223
assertThat(VitessType.resolve(asField(Query.Type.INT16)).getJdbcId()).isEqualTo(Types.SMALLINT);
2324
assertThat(VitessType.resolve(asField(Query.Type.INT24)).getJdbcId()).isEqualTo(Types.INTEGER);

0 commit comments

Comments
 (0)