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

DBZ-478 Avoiding NPE in case of unsupported array column types for Postgres;

Browse Source 
Instead, just the warning about the unsupported type will be logged.
This commit is contained in:
Gunnar Morling 2017-11-21 16:18:00 +01:00 committed by Jiri Pechanec
parent 2b3276be1d
commit 833e81a3a4
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresValueConverter.java
View File

@ -198,6 +198,10 @@ public ValueConverter converter(Column column, Field fieldDefn) {
case PgOid.FLOAT8_ARRAY:
case PgOid.BOOL_ARRAY:
case PgOid.DATE_ARRAY:
return data -> convertArray(column, fieldDefn, data);
// TODO DBZ-459 implement support for these array types; for now we just fall back to the default, i.e.
// having no converter, so to be consistent with the schema definitions above
case PgOid.TIME_ARRAY:
case PgOid.TIMETZ_ARRAY:
case PgOid.TIMESTAMP_ARRAY:
@ -217,7 +221,7 @@ public ValueConverter converter(Column column, Field fieldDefn) {
case PgOid.JSONB_ARRAY:
case PgOid.JSON_ARRAY:
case PgOid.REF_CURSOR_ARRAY:
return data -> convertArray(column, fieldDefn, data);
return super.converter(column, fieldDefn);
default:
return super.converter(column, fieldDefn);
}