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(