r2dbc - set session transaction isolation

oshai · oshai · commit 5d84a2e41e37 · 2023-08-14T09:18:55.000+03:00
fix for #409
diff --git 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 }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ class JasyncClientConnection(`
`104`	`104`	`Mono.defer { (jasyncConnection as MySQLConnection).sendQueryAfterCurrent(query).toMono().then() }`
`105`	`105`
`106`	`106`	`override fun setTransactionIsolationLevel(isolationLevel: IsolationLevel): Publisher<Void> {`
`107`		`- return executeVoidAfterCurrent("SET TRANSACTION ISOLATION LEVEL ${isolationLevel.asSql()}")`
	`107`	`+ return executeVoidAfterCurrent("SET SESSION TRANSACTION ISOLATION LEVEL ${isolationLevel.asSql()}")`
`108`	`108`	`.doOnSuccess { this.isolationLevel = isolationLevel }`
`109`	`109`	`}`
`110`	`110`