fix innodb timeout to seconds

oshai · oshai · commit d884ecbe3d50 · 2023-01-19T09:42:48.000+02:00
issue #367
diff --git a/r2dbc-mysql/src/main/java/JasyncClientConnection.kt b/r2dbc-mysql/src/main/java/JasyncClientConnection.kt
@@ -50,7 +50,7 @@ class JasyncClientConnection(
                     .map { this.isolationLevel = isolationLevel ; it }
             }
             definition.getAttribute(TransactionDefinition.LOCK_WAIT_TIMEOUT)?.let { timeout ->
-                future = future.flatMap { jasyncConnection.sendQuery("SET innodb_lock_wait_timeout=$timeout") }
+                future = future.flatMap { jasyncConnection.sendQuery("SET innodb_lock_wait_timeout=${timeout.toSeconds()}") }
             }
             future = future.flatMap { jasyncConnection.sendQuery("SET AUTOCOMMIT = 0") }
             future.toMono().then()
@@ -70,7 +70,7 @@ class JasyncClientConnection(
     }
 
     override fun setLockWaitTimeout(timeout: Duration): Publisher<Void> {
-        return executeVoid("SET innodb_lock_wait_timeout=$timeout")
+        return executeVoid("SET innodb_lock_wait_timeout=${timeout.toSeconds()}")
     }
 
     override fun setStatementTimeout(timeout: Duration): Publisher<Void> {

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ class JasyncClientConnection(`
`50`	`50`	`.map { this.isolationLevel = isolationLevel ; it }`
`51`	`51`	`}`
`52`	`52`	`definition.getAttribute(TransactionDefinition.LOCK_WAIT_TIMEOUT)?.let { timeout ->`
`53`		`- future = future.flatMap { jasyncConnection.sendQuery("SET innodb_lock_wait_timeout=$timeout") }`
	`53`	`+ future = future.flatMap { jasyncConnection.sendQuery("SET innodb_lock_wait_timeout=${timeout.toSeconds()}") }`
`54`	`54`	`}`
`55`	`55`	`future = future.flatMap { jasyncConnection.sendQuery("SET AUTOCOMMIT = 0") }`
`56`	`56`	`future.toMono().then()`
`@@ -70,7 +70,7 @@ class JasyncClientConnection(`
`70`	`70`	`}`
`71`	`71`
`72`	`72`	`override fun setLockWaitTimeout(timeout: Duration): Publisher<Void> {`
`73`		`- return executeVoid("SET innodb_lock_wait_timeout=$timeout")`
	`73`	`+ return executeVoid("SET innodb_lock_wait_timeout=${timeout.toSeconds()}")`
`74`	`74`	`}`
`75`	`75`
`76`	`76`	`override fun setStatementTimeout(timeout: Duration): Publisher<Void> {`