We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bc4dee3 commit 708343dCopy full SHA for 708343d
sql/core/src/main/scala/org/apache/spark/sql/jdbc/PostgresDialect.scala
@@ -70,7 +70,7 @@ private object PostgresDialect extends JdbcDialect {
70
case BooleanType => Some(JdbcType("BOOLEAN", Types.BOOLEAN))
71
case FloatType => Some(JdbcType("FLOAT4", Types.FLOAT))
72
case DoubleType => Some(JdbcType("FLOAT8", Types.DOUBLE))
73
- case ShortType => Some(JdbcType("SMALLINT", java.sql.Types.SMALLINT))
+ case ShortType => Some(JdbcType("SMALLINT", Types.SMALLINT))
74
case t: DecimalType => Some(
75
JdbcType(s"NUMERIC(${t.precision},${t.scale})", java.sql.Types.NUMERIC))
76
case ArrayType(et, _) if et.isInstanceOf[AtomicType] =>
0 commit comments