From 7fbd937c50d61530d6c3e06e021f741ccce6eaa3 Mon Sep 17 00:00:00 2001 From: wanghuanming Date: Wed, 21 Sep 2016 18:51:09 +0800 Subject: [PATCH] FIX: AggregatedDialect does not quote identifier correctly --- .../scala/org/apache/spark/sql/jdbc/AggregatedDialect.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/jdbc/AggregatedDialect.scala b/sql/core/src/main/scala/org/apache/spark/sql/jdbc/AggregatedDialect.scala index 467d8d62d1b7..75c137b38dfe 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/jdbc/AggregatedDialect.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/jdbc/AggregatedDialect.scala @@ -41,4 +41,8 @@ private class AggregatedDialect(dialects: List[JdbcDialect]) extends JdbcDialect override def getJDBCType(dt: DataType): Option[JdbcType] = { dialects.flatMap(_.getJDBCType(dt)).headOption } + + override def quoteIdentifier(colName: String): String = { + dialects.head.quoteIdentifier(colName) + } }