diff --git a/assembly/sql-server_2.11_2.3.0_0.1.1-SNAPSHOT-with-dependencies.jar b/assembly/sql-server_2.11_2.3.0_0.1.1-SNAPSHOT-with-dependencies.jar index 07fbb44..7732795 100644 Binary files a/assembly/sql-server_2.11_2.3.0_0.1.1-SNAPSHOT-with-dependencies.jar and b/assembly/sql-server_2.11_2.3.0_0.1.1-SNAPSHOT-with-dependencies.jar differ diff --git a/assembly/tpcds_2.11_2.3.0_0.1.1-SNAPSHOT-with-dependencies.jar b/assembly/tpcds_2.11_2.3.0_0.1.1-SNAPSHOT-with-dependencies.jar index a28bf1b..d063f71 100644 Binary files a/assembly/tpcds_2.11_2.3.0_0.1.1-SNAPSHOT-with-dependencies.jar and b/assembly/tpcds_2.11_2.3.0_0.1.1-SNAPSHOT-with-dependencies.jar differ diff --git a/releases/spark-sql-server-0.1.1.zip b/releases/spark-sql-server-0.1.1.zip index 9e9d03f..9d6e60e 100644 Binary files a/releases/spark-sql-server-0.1.1.zip and b/releases/spark-sql-server-0.1.1.zip differ diff --git a/sql/sql-server/src/test/scala/org/apache/spark/sql/server/service/postgresql/protocol/v3/ParameterBinderSuite.scala b/sql/sql-server/src/test/scala/org/apache/spark/sql/server/service/postgresql/protocol/v3/ParameterBinderSuite.scala index 915152e..b3cd64d 100644 --- a/sql/sql-server/src/test/scala/org/apache/spark/sql/server/service/postgresql/protocol/v3/ParameterBinderSuite.scala +++ b/sql/sql-server/src/test/scala/org/apache/spark/sql/server/service/postgresql/protocol/v3/ParameterBinderSuite.scala @@ -21,8 +21,8 @@ import java.sql.SQLException import org.apache.spark.sql.catalyst.dsl.expressions._ import org.apache.spark.sql.catalyst.expressions.{And, EqualTo, Literal} -import org.apache.spark.sql.catalyst.plans.logical._ import org.apache.spark.sql.catalyst.plans.PlanTest +import org.apache.spark.sql.catalyst.plans.logical._ import org.apache.spark.sql.server.catalyst.expressions.ParameterPlaceHolder import org.apache.spark.sql.types._ @@ -30,29 +30,31 @@ import org.apache.spark.sql.types._ class ParameterBinderSuite extends PlanTest { test("bind parameters") { - val r1 = LocalRelation('a.int, 'b.int) + val c0 = 'a.int + val c1 = 'b.int + val r1 = LocalRelation(c0, c1) val param1 = Literal(18, IntegerType) - val lp1 = Filter(EqualTo('a.int, ParameterPlaceHolder(1)), r1) - val expected1 = Filter(EqualTo('a.int, param1), r1) + val lp1 = Filter(EqualTo(c0, ParameterPlaceHolder(1)), r1) + val expected1 = Filter(EqualTo(c0, param1), r1) comparePlans(expected1, ParamBinder.bind(lp1, Map(1 -> param1))) val param2 = Literal(42, IntegerType) - val lp2 = Filter(EqualTo('a.int, ParameterPlaceHolder(300)), r1) - val expected2 = Filter(EqualTo('a.int, param2), r1) + val lp2 = Filter(EqualTo(c0, ParameterPlaceHolder(300)), r1) + val expected2 = Filter(EqualTo(c0, param2), r1) comparePlans(expected2, ParamBinder.bind(lp2, Map(300 -> param2))) val param3 = Literal(-1, IntegerType) val param4 = Literal(48, IntegerType) val lp3 = Filter( And( - EqualTo('a.int, ParameterPlaceHolder(1)), - EqualTo('b.int, ParameterPlaceHolder(2)) + EqualTo(c0, ParameterPlaceHolder(1)), + EqualTo(c1, ParameterPlaceHolder(2)) ), r1) val expected3 = Filter( And( - EqualTo('a.int, param3), - EqualTo('b.int, param4) + EqualTo(c0, param3), + EqualTo(c1, param4) ), r1) comparePlans(expected3, ParamBinder.bind(lp3, Map(1 -> param3, 2 -> param4))) diff --git a/sql/sql-server/src/test/scala/org/apache/spark/sql/server/service/postgresql/protocol/v3/PgV3ProtocolScenarioSuite.scala b/sql/sql-server/src/test/scala/org/apache/spark/sql/server/service/postgresql/protocol/v3/PgV3ProtocolScenarioSuite.scala index 09507d0..0f619c2 100644 --- a/sql/sql-server/src/test/scala/org/apache/spark/sql/server/service/postgresql/protocol/v3/PgV3ProtocolScenarioSuite.scala +++ b/sql/sql-server/src/test/scala/org/apache/spark/sql/server/service/postgresql/protocol/v3/PgV3ProtocolScenarioSuite.scala @@ -38,8 +38,8 @@ class PgV3ProtocolScenarioSuite extends PgV3ProtocolTest { } testIfSupported("unsupported SQL strings") { - def expectedErrorMessage(message: String, cmd: String): String = - s"Exception detected in `$message`: java.sql.SQLException: Cannot handle command $cmd" + def expectedErrorMessage(message: String, cmd: String): Seq[String] = + Seq(s"Exception detected in `$message`", s"Operation not allowed: $cmd") Seq("COMMIT", "ROLLBACK").foreach { cmd => val e1 = intercept[Exception] { @@ -51,7 +51,7 @@ class PgV3ProtocolScenarioSuite extends PgV3ProtocolTest { expected = "" ) }.getMessage - assert(e1.contains(expectedErrorMessage("Query", cmd))) + assert(expectedErrorMessage("Query", cmd).forall(e1.contains)) val e2 = intercept[Exception] { checkV3Protocol( @@ -62,7 +62,7 @@ class PgV3ProtocolScenarioSuite extends PgV3ProtocolTest { expected = "" ) }.getMessage - assert(e2.contains(expectedErrorMessage("Parse", cmd))) + assert(expectedErrorMessage("Parse", cmd).forall(e2.contains)) } }