Merge branch 'main' into QDCOS-114-Authorize-web-endpoints

quarkusio · Jan 23, 2023 · a61157e · a61157e
2 parents 71ee9fc + ed47ae6
commit a61157e
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 0 deletions.
diff --git a/...src/main/java/io/quarkus/reactive/mysql/client/runtime/DataSourceReactiveMySQLConfig.java b/...src/main/java/io/quarkus/reactive/mysql/client/runtime/DataSourceReactiveMySQLConfig.java
@@ -53,4 +53,18 @@ public class DataSourceReactiveMySQLConfig {
      */
     @ConfigItem(defaultValueDocumentation = "default")
     public Optional<MySQLAuthenticationPlugin> authenticationPlugin = Optional.empty();
+
+    /**
+     * The maximum number of inflight database commands that can be pipelined.
+     * By default, pipelining is disabled.
+     */
+    @ConfigItem
+    public OptionalInt pipeliningLimit = OptionalInt.empty();
+
+    /**
+     * Whether to return the number of rows matched by the <em>WHERE</em> clause in <em>UPDATE</em> statements, instead of the
+     * number of rows actually changed.
+     */
+    @ConfigItem(defaultValueDocumentation = "false")
+    public Optional<Boolean> useAffectedRows = Optional.empty();
 }
diff --git a/...ent/runtime/src/main/java/io/quarkus/reactive/mysql/client/runtime/MySQLPoolRecorder.java b/...ent/runtime/src/main/java/io/quarkus/reactive/mysql/client/runtime/MySQLPoolRecorder.java
@@ -173,6 +173,14 @@ private MySQLConnectOptions toMySQLConnectOptions(DataSourceRuntimeConfig dataSo
             mysqlConnectOptions.setCollation(dataSourceReactiveMySQLConfig.collation.get());
         }
 
+        if (dataSourceReactiveMySQLConfig.pipeliningLimit.isPresent()) {
+            mysqlConnectOptions.setPipeliningLimit(dataSourceReactiveMySQLConfig.pipeliningLimit.getAsInt());
+        }
+
+        if (dataSourceReactiveMySQLConfig.useAffectedRows.isPresent()) {
+            mysqlConnectOptions.setUseAffectedRows(dataSourceReactiveMySQLConfig.useAffectedRows.get());
+        }
+
         if (dataSourceReactiveMySQLConfig.sslMode.isPresent()) {
             final SslMode sslMode = dataSourceReactiveMySQLConfig.sslMode.get();
             mysqlConnectOptions.setSslMode(sslMode);