From 319169e2fa60d4865b1c203ddf85bc7ed8679181 Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Tue, 25 Jun 2024 13:33:01 -0400 Subject: [PATCH] DBZ-7969 Fix more test failures --- .../connector/jdbc/dialect/GeneralDatabaseDialect.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java b/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java index 9b70fd5c..76412b13 100644 --- a/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java +++ b/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java @@ -516,6 +516,8 @@ public String getTypeName(int jdbcType) { case Types.VARCHAR: case Types.NVARCHAR: return getTypeName(Types.LONGVARCHAR); + case Types.VARBINARY: + return getTypeName(Types.LONGVARBINARY); default: return ddlTypeRegistry.getTypeName(jdbcType, dialect); } @@ -526,6 +528,8 @@ public String getTypeName(int jdbcType) { return getTypeName(jdbcType, dialect.getMaxVarcharLength()); case Types.NVARCHAR: return getTypeName(jdbcType, dialect.getMaxNVarcharLength()); + case Types.VARBINARY: + return getTypeName(jdbcType, dialect.getMaxVarbinaryLength()); default: return ddlTypeRegistry.getTypeName(jdbcType, dialect); }