From 5d84a2e41e37136519f6e34afbf8924ba3259d4d Mon Sep 17 00:00:00 2001
From: oshai <ohadshai@gmail.com>
Date: Mon, 14 Aug 2023 09:18:55 +0300
Subject: [PATCH] r2dbc - set session transaction isolation

fix for #409
---
 r2dbc-mysql/src/main/java/JasyncClientConnection.kt | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/r2dbc-mysql/src/main/java/JasyncClientConnection.kt b/r2dbc-mysql/src/main/java/JasyncClientConnection.kt
index 112a2342..456d6d99 100644
--- a/r2dbc-mysql/src/main/java/JasyncClientConnection.kt
+++ b/r2dbc-mysql/src/main/java/JasyncClientConnection.kt
@@ -104,7 +104,7 @@ class JasyncClientConnection(
         Mono.defer { (jasyncConnection as MySQLConnection).sendQueryAfterCurrent(query).toMono().then() }
 
     override fun setTransactionIsolationLevel(isolationLevel: IsolationLevel): Publisher<Void> {
-        return executeVoidAfterCurrent("SET TRANSACTION ISOLATION LEVEL ${isolationLevel.asSql()}")
+        return executeVoidAfterCurrent("SET SESSION TRANSACTION ISOLATION LEVEL ${isolationLevel.asSql()}")
             .doOnSuccess { this.isolationLevel = isolationLevel }
     }