diff --git a/src/main/java/org/springframework/data/r2dbc/convert/MappingR2dbcConverter.java b/src/main/java/org/springframework/data/r2dbc/convert/MappingR2dbcConverter.java index c10bde3..933fa14 100644 --- a/src/main/java/org/springframework/data/r2dbc/convert/MappingR2dbcConverter.java +++ b/src/main/java/org/springframework/data/r2dbc/convert/MappingR2dbcConverter.java @@ -451,22 +451,22 @@ public class MappingR2dbcConverter extends BasicRelationalConverter implements R @Nullable public T getParameterValue(Parameter parameter) { - RelationalPersistentProperty property = entity.getRequiredPersistentProperty(parameter.getName()); - String column = prefix + property.getColumnName(); + RelationalPersistentProperty property = this.entity.getRequiredPersistentProperty(parameter.getName()); + String column = this.prefix + property.getColumnName(); try { - if (metadata != null && !metadata.getColumnNames().contains(column)) { + if (this.metadata != null && !this.metadata.getColumnNames().contains(column)) { return null; } - Object value = resultSet.get(column); + Object value = this.resultSet.get(column); if (value == null) { return null; } - return converter.getConversionService().convert(value, parameter.getType().getType()); + return this.converter.getConversionService().convert(value, parameter.getType().getType()); } catch (Exception o_O) { throw new MappingException(String.format("Couldn't read column %s from Row.", column), o_O); }