Skip to content

Commit 6a7b700

Browse files
committed
add a test for invalid index type
1 parent 9c32078 commit 6a7b700

File tree

1 file changed

+9
-1
lines changed
  • external/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2

1 file changed

+9
-1
lines changed

external/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/V2JDBCTest.scala

+9-1
Original file line numberDiff line numberDiff line change
@@ -203,6 +203,14 @@ private[v2] trait V2JDBCTest extends SharedSparkSession with DockerIntegrationFu
203203
assert(jdbcTable.indexExists("i2") == false)
204204

205205
val properties = new util.Properties();
206+
val indexType = "DUMMY"
207+
var m = intercept[UnsupportedOperationException] {
208+
jdbcTable.createIndex("i1", indexType, Array(FieldReference("col1")),
209+
Array.empty[util.Map[NamedReference, util.Properties]], properties)
210+
}.getMessage
211+
assert(m.contains(s"Index Type $indexType is not supported." +
212+
s" The supported Index Types are: BTREE and HASH"))
213+
206214
jdbcTable.createIndex("i1", "BTREE", Array(FieldReference("col1")),
207215
Array.empty[util.Map[NamedReference, util.Properties]], properties)
208216

@@ -213,7 +221,7 @@ private[v2] trait V2JDBCTest extends SharedSparkSession with DockerIntegrationFu
213221
assert(jdbcTable.indexExists("i1") == true)
214222
assert(jdbcTable.indexExists("i2") == true)
215223

216-
var m = intercept[IndexAlreadyExistsException] {
224+
m = intercept[IndexAlreadyExistsException] {
217225
jdbcTable.createIndex("i1", "", Array(FieldReference("col1")),
218226
Array.empty[util.Map[NamedReference, util.Properties]], properties)
219227
}.getMessage

0 commit comments

Comments
 (0)