fix type

snowflakedb · May 13, 2024 · e0b6658 · e0b6658
1 parent b2ace9e
commit e0b6658
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/scala/net/snowflake/spark/snowflake/SnowflakeJDBCWrapper.scala b/src/main/scala/net/snowflake/spark/snowflake/SnowflakeJDBCWrapper.scala
@@ -281,7 +281,6 @@ private[snowflake] class JDBCWrapper {
     // Snowflake-todo: Verify all types.
     val answer = sqlType match {
       // scalastyle:off
-      case java.sql.Types.ARRAY => null
       case java.sql.Types.BIGINT =>
         if (signed) {
           LongType
@@ -340,6 +339,8 @@ private[snowflake] class JDBCWrapper {
       //      case java.sql.Types.VARBINARY     => BinaryType
       case java.sql.Types.VARCHAR => StringType
       case java.sql.Types.BINARY  => BinaryType
+      case java.sql.Types.STRUCT  => StringType
+      case java.sql.Types.ARRAY   => StringType
       case _                      => null
       // scalastyle:on
     }