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: