You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by do...@apache.org on 2021/06/27 04:44:17 UTC
[spark] branch master updated: [SPARK-35893][TESTS] Add unit test
case for MySQLDialect.getCatalystType
This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new b11b175 [SPARK-35893][TESTS] Add unit test case for MySQLDialect.getCatalystType
b11b175 is described below
commit b11b175148592b27695b422e81a22881bf14dd87
Author: zengruios <57...@qq.com>
AuthorDate: Sat Jun 26 21:43:52 2021 -0700
[SPARK-35893][TESTS] Add unit test case for MySQLDialect.getCatalystType
### What changes were proposed in this pull request?
Add unit test case for MySQLDialect.getCatalystType
### Why are the changes needed?
add unit test case
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
Unit Test
Closes #33087 from zengruios/SPARK-35893.
Authored-by: zengruios <57...@qq.com>
Signed-off-by: Dongjoon Hyun <do...@apache.org>
---
.../src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala
index f85c479d..95a9161 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala
@@ -899,6 +899,17 @@ class JDBCSuite extends QueryTest
Option(TimestampType))
}
+ test("MySQLDialect catalyst type mapping") {
+ val mySqlDialect = JdbcDialects.get("jdbc:mysql")
+ val metadata = new MetadataBuilder()
+ assert(mySqlDialect.getCatalystType(java.sql.Types.VARBINARY, "BIT", 2, metadata) ==
+ Some(LongType))
+ assert(metadata.build().contains("binarylong"))
+ assert(mySqlDialect.getCatalystType(java.sql.Types.VARBINARY, "BIT", 1, metadata) == None)
+ assert(mySqlDialect.getCatalystType(java.sql.Types.BIT, "TINYINT", 1, metadata) ==
+ Some(BooleanType))
+ }
+
test("SPARK-35446: MySQLDialect type mapping of float") {
val mySqlDialect = JdbcDialects.get("jdbc:mysql://127.0.0.1/db")
assert(mySqlDialect.getJDBCType(FloatType).map(_.databaseTypeDefinition).get == "FLOAT")
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org