File tree Expand file tree Collapse file tree 1 file changed +8
-9
lines changed
sql/core/src/test/scala/org/apache/spark/sql/jdbc Expand file tree Collapse file tree 1 file changed +8
-9
lines changed Original file line number Diff line number Diff line change @@ -176,15 +176,14 @@ class JDBCSuite extends SparkFunSuite with BeforeAndAfter with SharedSQLContext
176176 }
177177
178178 test(" SELECT * WHERE (simple predicates)" ) {
179- assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE THEID < 1" )).collect().size === 0 )
180- assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE THEID != 2" )).collect().size === 2 )
181- assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE THEID = 1" )).collect().size === 1 )
182- assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE NAME = 'fred'" )).collect().size === 1 )
183- assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE NAME > 'fred'" )).collect().size === 2 )
184- assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE NAME != 'fred'" )).collect().size === 2 )
185- assert(stripSparkFilter(sql(" SELECT * FROM nulltypes WHERE A IS NULL" )).collect().size === 1 )
186- assert(stripSparkFilter(
187- sql(" SELECT * FROM nulltypes WHERE A IS NOT NULL" )).collect().size === 0 )
179+ assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE THEID < 1" )).collect().size == 0 )
180+ assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE THEID != 2" )).collect().size == 2 )
181+ assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE THEID = 1" )).collect().size == 1 )
182+ assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE NAME = 'fred'" )).collect().size == 1 )
183+ assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE NAME > 'fred'" )).collect().size == 2 )
184+ assert(stripSparkFilter(sql(" SELECT * FROM foobar WHERE NAME != 'fred'" )).collect().size == 2 )
185+ assert(stripSparkFilter(sql(" SELECT * FROM nulltypes WHERE A IS NULL" )).collect().size == 1 )
186+ assert(stripSparkFilter(sql(" SELECT * FROM nulltypes WHERE A IS NOT NULL" )).collect().size == 0 )
188187 }
189188
190189 test(" SELECT * WHERE (quoted strings)" ) {
You can’t perform that action at this time.
0 commit comments