Skip to content

Commit 7f9c42c

Browse files
committed
#73 - hacking - fixed another error.
1 parent 71b81a1 commit 7f9c42c

File tree

2 files changed

+11
-9
lines changed

2 files changed

+11
-9
lines changed

src/main/java/org/springframework/data/r2dbc/function/Bindings.java

+3-2
Original file line numberDiff line numberDiff line change
@@ -63,9 +63,10 @@ public void bindTo(Statement statement) {
6363

6464
if (value.isEmpty()) {
6565
statement.bindNull(identifier, value.getType());
66+
} else {
67+
statement.bind(identifier, value.getValue());
6668
}
6769

68-
statement.bind(identifier, value);
6970
}
7071

7172
@Override
@@ -86,7 +87,7 @@ public void bindTo(Statement statement) {
8687
if (value.isEmpty()) {
8788
statement.bindNull((int) identifier, value.getType());
8889
} else {
89-
statement.bind((int) identifier, value);
90+
statement.bind((int) identifier, value.getValue());
9091
}
9192
}
9293

src/main/java/org/springframework/data/r2dbc/function/DefaultStatementFactory.java

+8-7
Original file line numberDiff line numberDiff line change
@@ -112,18 +112,19 @@ private static Bindings createBindings(Binding binding) {
112112
.add(new Bindings.IndexedSingleBinding( //
113113
((IndexedBindMarker) bindMarker).getIndex(), //
114114
settableValue) //
115-
);
115+
);
116116
}
117117
});
118118

119119
binding.getValues().forEach( //
120120
(bindMarker, value) -> {
121-
singleBindings //
122-
.add(new Bindings.NamedSingleBinding<>( //
123-
bindMarker.getPlaceholder(), //
124-
value instanceof SettableValue ? (SettableValue) value
125-
: SettableValue.from(value)) //
126-
);
121+
if (bindMarker instanceof IndexedBindMarker) {
122+
singleBindings //
123+
.add(new Bindings.IndexedSingleBinding( //
124+
((IndexedBindMarker) bindMarker).getIndex(), //
125+
value instanceof SettableValue ? (SettableValue) value : SettableValue.from(value)) //
126+
);
127+
}
127128
});
128129

129130
return new Bindings(singleBindings);

0 commit comments

Comments
 (0)