From e964abd2da6ec632aab337096df5eacda31f7af3 Mon Sep 17 00:00:00 2001
From: Koudai Aono <koxudaxi@gmail.com>
Date: Sat, 24 Apr 2021 23:10:49 +0900
Subject: [PATCH] Support Java SDK (#131)

---
 kotlin/local-data-api/src/com/koxudaxi/localDataApi/Resource.kt | 2 +-
 .../test/com/koxudaxi/localDataApi/ApplicationTest.kt           | 2 +-
 2 files changed, 2 insertions(+), 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
index 9d7564d..a2418bd 100644
--- 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
index 35683fc..c82cc94 100644
--- 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(