R2DBC `DatabaseClient` fails to provide reused named parameters from list with MySQL

[Dieken]

https://github.com/spring-projects/spring-framework/blob/v7.0.0-M3/spring-r2dbc/src/main/java/org/springframework/r2dbc/core/NamedParameterUtils.java#L528

if (parameter.getValue() instanceof Collection collection) {
				Iterator<Object> iterator = collection.iterator();
				Iterator<BindMarker> markers = bindMarkers.iterator();
				while (iterator.hasNext()) {
					Object valueToBind = iterator.next();
					if (valueToBind instanceof Object[] objects) {
						for (Object object : objects) {
							bind(target, markers, object);
						}
					}
					else {
						bind(target, markers, valueToBind);
					}
				}
			}

For example, for SELECT ... WHERE fund_codeA in (:fundCodes) OR fund_codeB in (:fundCodes), fundCodes references a List, then the code above only fill the first occurrence of :fundCodes.

parameter = ["00001"]
markers = [?, ?]    // two occurrence

// iterate on parameter won't fill second "?"
// SELECT .... WHERE fund_codeA in (?)   OR fund_codeB in (?)

[Dieken]

Possible fix below, sorry my network speed to download gradle and dependencies is too slow, I haven't tested it.

$ git diff -w

diff --git a/spring-r2dbc/src/main/java/org/springframework/r2dbc/core/NamedParameterUtils.java b/spring-r2dbc/src/main/java/org/springframework/r2dbc/core/NamedParameterUtils.java

index f6696e8d9c..91ae7b35a4 100644
--- a/spring-r2dbc/src/main/java/org/springframework/r2dbc/core/NamedParameterUtils.java
+++ b/spring-r2dbc/src/main/java/org/springframework/r2dbc/core/NamedParameterUtils.java
@@ -529,6 +529,7 @@ abstract class NamedParameterUtils {
                        if (parameter.getValue() instanceof Collection collection) {
                                Iterator<Object> iterator = collection.iterator();
                                Iterator<BindMarker> markers = bindMarkers.iterator();
+                               do {
                                        while (iterator.hasNext()) {
                                                Object valueToBind = iterator.next();
                                                if (valueToBind instanceof Object[] objects) {
@@ -540,6 +541,13 @@ abstract class NamedParameterUtils {
                                                        bind(target, markers, valueToBind);
                                                }
                                        }
+
+                                       if (markers.hasNext()) {
+                                               iterator = collection.iterator();
+                                       } else {
+                                               break;
+                                       }
+                               } while (true);
                        }
                        else {
                                for (BindMarker bindMarker : bindMarkers) {

[sbrannen]

Hi @Dieken,

Congratulations on submitting your first issue for the Spring Framework! 👍

Before I noticed that you had submitted PR #34769, I put together some tests in an attempt to reproduce the behavior you described, and I pushed those in commit 018d3c9.

Those tests pass.

For example, the executeSelectWithReusedNamedParameterList() test method results in the following being logged at TRACE level when running H2DatabaseClientIntegrationTests.

Expanded SQL [SELECT * FROM legoset WHERE version IN ($1, $2, $3, $4) OR manual IN ($1, $2, $3, $4)]

That is expanded from the following SQL.

SELECT * FROM legoset WHERE version IN (:numbers) OR manual IN (:numbers)

Thus, I was not able to reproduce your claim.

If you would like us to investigate this further (or to consider your PR), please provide tests that fail before the proposed change and then pass after the proposed change.

Thanks,

Sam

[Dieken]

No idea why your tests can pass, I can reproduce the issue with test code below:

Demo project is created with
https://start.springboot.io/#!type=maven-project&language=java&platformVersion=3.4.4&packaging=jar&jvmVersion=21&groupId=com.example&artifactId=demo&name=demo&description=Demo%20project%20for%20Spring%20Boot&packageName=com.example.demo&dependencies=webflux,data-r2dbc,h2,mysql,lombok

demo/src/test/java/com/example/demo/DemoApplicationTests.java:

package com.example.demo;

import java.util.List;
import lombok.Data;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.r2dbc.core.DatabaseClient;

@SpringBootTest
class DemoApplicationTests {

    @Autowired
    private DatabaseClient db;

    @BeforeEach
    void setupDb() {
        db.sql("CREATE TABLE IF NOT EXISTS fund_info  (id int not null primary key, fund_code varchar(20) not null)")
                .then()
                .block();
    }

    @Test
    void contextLoads() {
    }

    @Test
    void testIt() {
        Req r = new Req();
        r.fundCodes = List.of("000001");

        db.sql("SELECT * FROM fund_info WHERE fund_code IN (:fundCodes) OR fund_code IN (:fundCodes)")
                //.bind("fundCodes", r.fundCodes)
                .bindProperties(r)
                .fetch()
                .all()
                .collectList()
                .block();
    }

    @Data
    static class Req {
        private List<String> fundCodes;
    }
}