diff --git a/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/ClientE2ETestSuite.scala b/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/ClientE2ETestSuite.scala index 5aa5500116d8..6a2e076641e1 100644 --- a/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/ClientE2ETestSuite.scala +++ b/connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/ClientE2ETestSuite.scala @@ -632,6 +632,19 @@ class ClientE2ETestSuite extends RemoteSparkSession with SQLHelper { session.createDataFrame(list.asScala.toSeq)) } + test("write jdbc2") { + val rows = java.util.Arrays.asList[Row](Row("dave", 42), Row("mary", 222)) + val schema = StructType( + StructField("name", StringType) :: + StructField("id", IntegerType) :: Nil) + val df = spark.createDataFrame(rows, schema) + df.write.jdbc("jdbc:h2:mem:testdb2", "BASICCREATETEST", new Properties()) + + checkSameResult( + rows.asScala.map(row => Row(row.getString(0), row.getInt(1))), + spark.read.jdbc("jdbc:h2:mem:testdb2", "BASICCREATETEST", new Properties())) + } + test("SparkSession newSession") { val oldId = spark.sql("SELECT 1").analyze.getSessionId val newId = spark.newSession().sql("SELECT 1").analyze.getSessionId diff --git a/connector/connect/server/pom.xml b/connector/connect/server/pom.xml index 079d07db362c..6d3922134d7c 100644 --- a/connector/connect/server/pom.xml +++ b/connector/connect/server/pom.xml @@ -181,6 +181,11 @@ grpc-stub ${io.grpc.version} + + com.h2database + h2 + 2.1.214 + io.netty netty-codec-http2 @@ -215,12 +220,6 @@ mockito-core test - - com.h2database - h2 - 2.1.214 - test - target/scala-${scala.binary.version}/classes