diff --git a/src/main/java/org/springframework/data/r2dbc/function/DefaultDatabaseClient.java b/src/main/java/org/springframework/data/r2dbc/function/DefaultDatabaseClient.java index 3aa0881..b363f7b 100644 --- a/src/main/java/org/springframework/data/r2dbc/function/DefaultDatabaseClient.java +++ b/src/main/java/org/springframework/data/r2dbc/function/DefaultDatabaseClient.java @@ -245,9 +245,9 @@ class DefaultDatabaseClient implements DatabaseClient, ConnectionAccessor { byIndex.forEach((i, o) -> { if (o.getValue() != null) { - statement.bind(i, o.getValue()); + statement.bind(i.intValue(), o.getValue()); } else { - statement.bindNull(i, o.getType()); + statement.bindNull(i.intValue(), o.getType()); } });