jasync-sql
diff --git a/‎r2dbc-mysql/src/main/java/JasyncClientConnection.kt
Copy file name to clipboardExpand all lines: r2dbc-mysql/src/main/java/JasyncClientConnection.kt
+1-1Lines changed: 1 addition & 1 deletion b/‎r2dbc-mysql/src/main/java/JasyncClientConnection.kt
Copy file name to clipboardExpand all lines: r2dbc-mysql/src/main/java/JasyncClientConnection.kt
+1-1Lines changed: 1 addition & 1 deletion
@@ -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`