From 61fd4f62d71855a498f80b611fb52487a733aa38 Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Tue, 25 Jun 2024 15:30:04 -0400 Subject: [PATCH] DBZ-7969 Fix nvarchar test failures --- .../connector/jdbc/dialect/GeneralDatabaseDialect.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 76412b13..b4d4389e 100644 --- a/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java +++ b/src/main/java/io/debezium/connector/jdbc/dialect/GeneralDatabaseDialect.java @@ -514,8 +514,9 @@ public String getTypeName(int jdbcType) { if (ColumnTypeResolutionMode.LEGACY.equals(connectorConfig.getColumnTypeResolutionMode())) { switch (jdbcType) { case Types.VARCHAR: - case Types.NVARCHAR: return getTypeName(Types.LONGVARCHAR); + case Types.NVARCHAR: + return getTypeName(Types.LONGNVARCHAR); case Types.VARBINARY: return getTypeName(Types.LONGVARBINARY); default: