Ensure sequential parameter collection.

ExtendedQueryPostgresqlStatement.collectBindingParameters(…) now uses concatMap to collect encoded parameter values instead of flatMap to ensure a consistent parameter ordering. [resolves #482] Signed-off-by: Mark Paluch <mpaluch@vmware.com>
pgjdbc · Feb 16, 2022 · 1e692fc · 1e692fc
1 parent 26cbd92
commit 1e692fc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/r2dbc/postgresql/ExtendedQueryPostgresqlStatement.java b/src/main/java/io/r2dbc/postgresql/ExtendedQueryPostgresqlStatement.java
@@ -235,7 +235,7 @@ private static void tryNextBinding(Iterator<Binding> iterator, EmitterProcessor<
     private static Mono<List<ByteBuf>> collectBindingParameters(Binding binding) {
 
         return Flux.fromIterable(binding.getParameterValues())
-            .flatMap(f -> {
+            .concatMap(f -> {
                 if (f == Parameter.NULL_VALUE) {
                     return Flux.just(Bind.NULL_VALUE);
                 } else {