Skip to content

Commit 44e1978

Browse files
Fixed JDBCSuite for DB2 to send extra parameter for getJDBCType
1 parent 27f118b commit 44e1978

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ import org.scalatest.BeforeAndAfter
2727
import org.apache.spark.SparkFunSuite
2828
import org.apache.spark.sql.test.SharedSQLContext
2929
import org.apache.spark.sql.types._
30-
import org.apache.spark.util.Utils
30+
import org.apache.spark.util.{MetadataCleanerType, Utils}
3131

3232
class JDBCSuite extends SparkFunSuite with BeforeAndAfter with SharedSQLContext {
3333
import testImplicits._
@@ -450,8 +450,8 @@ class JDBCSuite extends SparkFunSuite with BeforeAndAfter with SharedSQLContext
450450

451451
test("DB2Dialect type mapping") {
452452
val db2Dialect = JdbcDialects.get("jdbc:db2://127.0.0.1/db")
453-
assert(db2Dialect.getJDBCType(StringType).map(_.databaseTypeDefinition).get == "CLOB")
454-
assert(db2Dialect.getJDBCType(BooleanType).map(_.databaseTypeDefinition).get == "CHAR(1)")
453+
assert(db2Dialect.getJDBCType(StringType,null).map(_.databaseTypeDefinition).get == "CLOB")
454+
assert(db2Dialect.getJDBCType(BooleanType,null).map(_.databaseTypeDefinition).get == "CHAR(1)")
455455
}
456456

457457
test("table exists query by jdbc dialect") {

0 commit comments

Comments
 (0)