File tree Expand file tree Collapse file tree 2 files changed +2
-0
lines changed
main/scala/org/apache/spark/sql/execution/datasources/jdbc
test/scala/org/apache/spark/sql/jdbc Expand file tree Collapse file tree 2 files changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -285,6 +285,7 @@ private[sql] class JDBCRDD(
285285 case GreaterThan (attr, value) => s " $attr > ${compileValue(value)}"
286286 case LessThanOrEqual (attr, value) => s " $attr <= ${compileValue(value)}"
287287 case GreaterThanOrEqual (attr, value) => s " $attr >= ${compileValue(value)}"
288+ case IsNotNull (attr) => s " $attr IS NOT NULL "
288289 case _ => null
289290 }
290291
Original file line number Diff line number Diff line change @@ -182,6 +182,7 @@ class JDBCSuite extends SparkFunSuite with BeforeAndAfter with SharedSQLContext
182182 assert(sql(" SELECT * FROM foobar WHERE NAME = 'fred'" ).collect().size === 1 )
183183 assert(sql(" SELECT * FROM foobar WHERE NAME > 'fred'" ).collect().size === 2 )
184184 assert(sql(" SELECT * FROM foobar WHERE NAME != 'fred'" ).collect().size === 2 )
185+ assert(sql(" SELECT * FROM nulltypes WHERE A IS NOT NULL" ).collect().size === 0 )
185186 }
186187
187188 test(" SELECT * WHERE (quoted strings)" ) {
You can’t perform that action at this time.
0 commit comments