Support Java SDK (#131)

koxudaxi · Apr 24, 2021 · e964abd · e964abd
1 parent 8a48f24
commit e964abd
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/kotlin/local-data-api/src/com/koxudaxi/localDataApi/Resource.kt b/kotlin/local-data-api/src/com/koxudaxi/localDataApi/Resource.kt
@@ -10,7 +10,7 @@ class Resource(
 ) {
     private val connectionManager = ConnectionManager.INSTANCE
 
-    val connection = if (transactionId == null) {
+    val connection = if (transactionId == null || transactionId.isBlank()) {
         connectionManager.createConnection(config.url, userName, password, database, schema, config.jdbcOptions)
     } else {
         connectionManager.getConnection(transactionId)

diff --git a/kotlin/local-data-api/test/com/koxudaxi/localDataApi/ApplicationTest.kt b/kotlin/local-data-api/test/com/koxudaxi/localDataApi/ApplicationTest.kt
@@ -117,7 +117,7 @@ class ApplicationTest {
         withTestApplication({ module(testing = true) }) {
             handleRequest(HttpMethod.Post, "/Execute") {
                 addHeader(HttpHeaders.ContentType, "*/*")
-                setBody(Json.encodeToString(ExecuteStatementRequest(dummyResourceArn, dummySecretArn, "select 1")))
+                setBody(Json.encodeToString(ExecuteStatementRequest(dummyResourceArn, dummySecretArn, "select 1", transactionId = "")))
             }.apply {
                 assertEquals(HttpStatusCode.OK, response.status())
                 assertEquals(