Skip to content

Commit 4dd453e

Browse files
committed
Update SQLQuerySuite.scala
1 parent 790765d commit 4dd453e

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

sql/core/src/test/scala/org/apache/spark/sql/SQLQuerySuite.scala

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -369,6 +369,17 @@ class SQLQuerySuite extends QueryTest {
369369
(3, null)))
370370
}
371371

372+
test("INTERSECT") {
373+
374+
checkAnswer(
375+
sql("SELECT * FROM lowerCaseData INTERSECT SELECT * FROM lowerCaseData "),
376+
(1, "a") ::
377+
(2, "b") ::
378+
(3, "c") ::
379+
(4, "d") :: Nil)
380+
checkAnswer(
381+
sql("SELECT * FROM lowerCaseData INTERSECT SELECT * FROM upperCaseData "), Nil)
382+
}
372383
test("SET commands semantics using sql()") {
373384
clear()
374385
val testKey = "test.key.0"
@@ -406,3 +417,4 @@ class SQLQuerySuite extends QueryTest {
406417
}
407418

408419
}
420+

0 commit comments

Comments
 (0)