File tree Expand file tree Collapse file tree 1 file changed +5
-7
lines changed
spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core Expand file tree Collapse file tree 1 file changed +5
-7
lines changed Original file line number Diff line number Diff line change 93
93
* @author Jens Schauder
94
94
* @author Jose Luis Leon
95
95
* @author Robert Heim
96
- * @author Sebastian Wieland
97
96
* @since 1.1
98
97
*/
99
98
public class R2dbcEntityTemplate implements R2dbcEntityOperations , BeanFactoryAware , ApplicationContextAware {
@@ -820,15 +819,14 @@ public <T> RowsFetchSpec<T> getRowsFetchSpec(DatabaseClient.GenericExecuteSpec e
820
819
821
820
BiFunction <Row , RowMetadata , T > rowMapper ;
822
821
823
- if (simpleType ) {
824
- rowMapper = dataAccessStrategy .getRowMapper (resultType );
825
- }
826
822
// Bridge-code: Consider Converter<Row, T> until we have fully migrated to RowDocument
827
- else if (converter instanceof AbstractRelationalConverter relationalConverter
828
- && relationalConverter .getConversions ().hasCustomReadTarget (Row .class , entityType )) {
823
+ if (converter instanceof AbstractRelationalConverter relationalConverter
824
+ && relationalConverter .getConversions ().hasCustomReadTarget (Row .class , resultType )) {
829
825
830
826
ConversionService conversionService = relationalConverter .getConversionService ();
831
- rowMapper = (row , rowMetadata ) -> (T ) conversionService .convert (row , entityType );
827
+ rowMapper = (row , rowMetadata ) -> (T ) conversionService .convert (row , resultType );
828
+ } else if (simpleType ) {
829
+ rowMapper = dataAccessStrategy .getRowMapper (resultType );
832
830
} else {
833
831
834
832
EntityProjection <T , ?> projection = converter .introspectProjection (resultType , entityType );
You can’t perform that action at this time.
0 commit comments