From 0248fdde1640ccd13d85bfea1c1a3f09164455d8 Mon Sep 17 00:00:00 2001 From: Jiri Pechanec Date: Mon, 9 Mar 2020 13:06:30 +0100 Subject: [PATCH] DBZ-1850 Delegate signed/nonsigned conversion to driver --- .../java/io/debezium/connector/postgresql/TypeRegistry.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/TypeRegistry.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/TypeRegistry.java index 06e6a54f9..11298c99d 100644 --- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/TypeRegistry.java +++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/TypeRegistry.java @@ -455,7 +455,7 @@ private PostgresType resolveUnknownType(int lookupOid) { final SqlTypeMapper sqlTypeMapper = new SqlTypeMapper(connection, typeInfo); try (final PreparedStatement statement = connection.prepareStatement(SQL_NON_ARRAY_TYPE_OID_LOOKUP)) { - statement.setLong(1, lookupOid); + statement.setInt(1, lookupOid); try (final ResultSet rs = statement.executeQuery()) { while (rs.next()) { final int oid = (int) rs.getLong("oid");