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

DBZ-3769 Throw sqlexception from postgres message decoder

Browse Source
This commit is contained in:
bep7520 2021-07-21 15:19:44 -05:00 committed by Jiri Pechanec
parent 59465009b9
commit 9e9c2fc2ab
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java
View File

@ -326,7 +326,8 @@ private void handleRelationMessage(ByteBuffer buffer, TypeRegistry typeRegistry)
decoderContext.getSchema().applySchemaChangesForTable(relationId, table);
}
private List<io.debezium.relational.Column> getTableColumnsFromDatabase(PostgresConnection connection, DatabaseMetaData databaseMetadata, TableId tableId) {
private List<io.debezium.relational.Column> getTableColumnsFromDatabase(PostgresConnection connection, DatabaseMetaData databaseMetadata, TableId tableId)
throws SQLException {
List<io.debezium.relational.Column> readColumns = new ArrayList<>();
try {
try (ResultSet columnMetadata = databaseMetadata.getColumns(null, tableId.schema(), tableId.table(), null)) {
@ -338,6 +339,7 @@ private List<io.debezium.relational.Column> getTableColumnsFromDatabase(Postgres
}
catch (SQLException e) {
LOGGER.warn("Failed to read column metadata for '{}.{}'", tableId.schema(), tableId.table());
throw e;
// todo: DBZ-766 Should this throw the exception or just log the warning?
}