Fix potential syntax error of sources.Filters

apache · Jul 15, 2019 · bc9daf9 · bc9daf9
1 parent 4e8ed51
commit bc9daf9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/sources/filters.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/sources/filters.scala
@@ -187,7 +187,7 @@ case class IsNotNull(attribute: String) extends Filter {
  */
 @Stable
 case class And(left: Filter, right: Filter) extends Filter {
-  override def sql: String = s"${left.sql} AND ${right.sql}"
+  override def sql: String = s"(${left.sql}) AND (${right.sql})"
   override def references: Array[String] = left.references ++ right.references
 }
 
@@ -198,7 +198,7 @@ case class And(left: Filter, right: Filter) extends Filter {
  */
 @Stable
 case class Or(left: Filter, right: Filter) extends Filter {
-  override def sql: String = s"${left.sql} OR ${right.sql}"
+  override def sql: String = s"(${left.sql}) OR (${right.sql})"
   override def references: Array[String] = left.references ++ right.references
 }
 
@@ -209,7 +209,7 @@ case class Or(left: Filter, right: Filter) extends Filter {
  */
 @Stable
 case class Not(child: Filter) extends Filter {
-  override def sql: String = s"NOT ${child.sql}"
+  override def sql: String = s"NOT (${child.sql})"
   override def references: Array[String] = child.references
 }