[SPARK-43362][SQL][FOLLOWUP] Special handling of JSON type for MySQL …

…connector
beryllw · Apr 3, 2024 · 5fc0ee3 · 5fc0ee3
1 parent 360a3f9
commit 5fc0ee3
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/jdbc/MySQLDialect.scala b/sql/core/src/main/scala/org/apache/spark/sql/jdbc/MySQLDialect.scala
@@ -110,8 +110,9 @@ private case class MySQLDialect() extends JdbcDialect with SQLConfHelper {
       case Types.VARCHAR if "TINYTEXT".equalsIgnoreCase(typeName) =>
         // TINYTEXT is Types.VARCHAR(63) from mysql jdbc, but keep it AS-IS for historical reason
         Some(StringType)
-      case Types.VARCHAR if "JSON".equalsIgnoreCase(typeName) =>
-        // Some MySQL JDBC drivers converts JSON type into Types.VARCHAR with a precision of -1.
+      case Types.VARCHAR | Types.CHAR if "JSON".equalsIgnoreCase(typeName) =>
+        // Some MySQL JDBC drivers converts JSON type into Types.VARCHAR with a precision of -1
+        // or Types.CHAR with a precision of Int.Max.
         // Explicitly converts it into StringType here.
         Some(StringType)
       case Types.TINYINT =>