Skip to content

Commit 19d5a82

Browse files
mipo256mipo256
committed
GH-1006 included QueryMappingConfiguration for all part tree queries
1 parent f3dc789 commit 19d5a82

File tree

29 files changed

+222
-40
lines changed

29 files changed

+222
-40
lines changed

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/core/convert/DataAccessStrategyFactory.java‎

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
* {@link DataAccessStrategy} for consistent access strategy creation.
2626
*
2727
* @author Mark Paluch
28+
* @author Mikhail Polivakha
2829
* @since 3.2
2930
*/
3031
public class DataAccessStrategyFactory {
@@ -34,6 +35,7 @@ public class DataAccessStrategyFactory {
3435
private final NamedParameterJdbcOperations operations;
3536
private final SqlParametersFactory sqlParametersFactory;
3637
private final InsertStrategyFactory insertStrategyFactory;
38+
private final QueryMappingConfiguration queryMappingConfiguration;
3739

3840
/**
3941
* Creates a new {@link DataAccessStrategyFactory}.
@@ -46,7 +48,7 @@ public class DataAccessStrategyFactory {
4648
*/
4749
public DataAccessStrategyFactory(SqlGeneratorSource sqlGeneratorSource, JdbcConverter converter,
4850
NamedParameterJdbcOperations operations, SqlParametersFactory sqlParametersFactory,
49-
InsertStrategyFactory insertStrategyFactory) {
51+
InsertStrategyFactory insertStrategyFactory, QueryMappingConfiguration queryMappingConfiguration) {
5052

5153
Assert.notNull(sqlGeneratorSource, "SqlGeneratorSource must not be null");
5254
Assert.notNull(converter, "JdbcConverter must not be null");
@@ -59,6 +61,7 @@ public DataAccessStrategyFactory(SqlGeneratorSource sqlGeneratorSource, JdbcConv
5961
this.operations = operations;
6062
this.sqlParametersFactory = sqlParametersFactory;
6163
this.insertStrategyFactory = insertStrategyFactory;
64+
this.queryMappingConfiguration = queryMappingConfiguration;
6265
}
6366

6467
/**
@@ -70,7 +73,7 @@ public DataAccessStrategy create() {
7073

7174
DefaultDataAccessStrategy defaultDataAccessStrategy = new DefaultDataAccessStrategy(sqlGeneratorSource,
7275
this.converter.getMappingContext(), this.converter, this.operations, sqlParametersFactory,
73-
insertStrategyFactory);
76+
insertStrategyFactory, queryMappingConfiguration);
7477

7578
if (this.converter.getMappingContext().isSingleQueryLoadingEnabled()) {
7679
return new SingleQueryFallbackDataAccessStrategy(sqlGeneratorSource, converter, operations,

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/core/convert/DefaultDataAccessStrategy.java‎

Lines changed: 21 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,7 @@
6262
* @author Chirag Tailor
6363
* @author Diego Krupitza
6464
* @author Sergey Korotaev
65+
* @author Mikhail Polivakha
6566
* @since 1.1
6667
*/
6768
public class DefaultDataAccessStrategy implements DataAccessStrategy {
@@ -73,6 +74,8 @@ public class DefaultDataAccessStrategy implements DataAccessStrategy {
7374
private final SqlParametersFactory sqlParametersFactory;
7475
private final InsertStrategyFactory insertStrategyFactory;
7576

77+
private final QueryMappingConfiguration queryMappingConfiguration;
78+
7679
/**
7780
* Creates a {@link DefaultDataAccessStrategy}
7881
*
@@ -84,21 +87,23 @@ public class DefaultDataAccessStrategy implements DataAccessStrategy {
8487
*/
8588
public DefaultDataAccessStrategy(SqlGeneratorSource sqlGeneratorSource, RelationalMappingContext context,
8689
JdbcConverter converter, NamedParameterJdbcOperations operations, SqlParametersFactory sqlParametersFactory,
87-
InsertStrategyFactory insertStrategyFactory) {
90+
InsertStrategyFactory insertStrategyFactory, QueryMappingConfiguration queryMappingConfiguration) {
8891

8992
Assert.notNull(sqlGeneratorSource, "SqlGeneratorSource must not be null");
9093
Assert.notNull(context, "RelationalMappingContext must not be null");
9194
Assert.notNull(converter, "JdbcConverter must not be null");
9295
Assert.notNull(operations, "NamedParameterJdbcOperations must not be null");
9396
Assert.notNull(sqlParametersFactory, "SqlParametersFactory must not be null");
9497
Assert.notNull(insertStrategyFactory, "InsertStrategyFactory must not be null");
98+
Assert.notNull(queryMappingConfiguration, "InsertStrategyFactory must not be null");
9599

96100
this.sqlGeneratorSource = sqlGeneratorSource;
97101
this.context = context;
98102
this.converter = converter;
99103
this.operations = operations;
100104
this.sqlParametersFactory = sqlParametersFactory;
101105
this.insertStrategyFactory = insertStrategyFactory;
106+
this.queryMappingConfiguration = queryMappingConfiguration;
102107
}
103108

104109
@Override
@@ -272,15 +277,15 @@ public <T> T findById(Object id, Class<T> domainType) {
272277
SqlIdentifierParameterSource parameter = sqlParametersFactory.forQueryById(id, domainType, ID_SQL_PARAMETER);
273278

274279
try {
275-
return operations.queryForObject(findOneSql, parameter, getEntityRowMapper(domainType));
280+
return operations.queryForObject(findOneSql, parameter, getRowMapper(domainType));
276281
} catch (EmptyResultDataAccessException e) {
277282
return null;
278283
}
279284
}
280285

281286
@Override
282287
public <T> List<T> findAll(Class<T> domainType) {
283-
return operations.query(sql(domainType).getFindAll(), getEntityRowMapper(domainType));
288+
return operations.query(sql(domainType).getFindAll(), getRowMapper(domainType));
284289
}
285290

286291
@Override
@@ -298,7 +303,7 @@ public <T> List<T> findAllById(Iterable<?> ids, Class<T> domainType) {
298303

299304
SqlParameterSource parameterSource = sqlParametersFactory.forQueryByIds(ids, domainType);
300305
String findAllInListSql = sql(domainType).getFindAllInList();
301-
return operations.query(findAllInListSql, parameterSource, getEntityRowMapper(domainType));
306+
return operations.query(findAllInListSql, parameterSource, getRowMapper(domainType));
302307
}
303308

304309
@Override
@@ -365,7 +370,7 @@ public <T> boolean existsById(Object id, Class<T> domainType) {
365370

366371
@Override
367372
public <T> List<T> findAll(Class<T> domainType, Sort sort) {
368-
return operations.query(sql(domainType).getFindAll(sort), getEntityRowMapper(domainType));
373+
return operations.query(sql(domainType).getFindAll(sort), getRowMapper(domainType));
369374
}
370375

371376
@Override
@@ -376,7 +381,7 @@ public <T> Stream<T> streamAll(Class<T> domainType, Sort sort) {
376381

377382
@Override
378383
public <T> List<T> findAll(Class<T> domainType, Pageable pageable) {
379-
return operations.query(sql(domainType).getFindAll(pageable), getEntityRowMapper(domainType));
384+
return operations.query(sql(domainType).getFindAll(pageable), getRowMapper(domainType));
380385
}
381386

382387
@Override
@@ -386,7 +391,7 @@ public <T> Optional<T> findOne(Query query, Class<T> domainType) {
386391
String sqlQuery = sql(domainType).selectByQuery(query, parameterSource);
387392

388393
try {
389-
return Optional.ofNullable(operations.queryForObject(sqlQuery, parameterSource, getEntityRowMapper(domainType)));
394+
return Optional.ofNullable(operations.queryForObject(sqlQuery, parameterSource, getRowMapper(domainType)));
390395
} catch (EmptyResultDataAccessException e) {
391396
return Optional.empty();
392397
}
@@ -398,7 +403,7 @@ public <T> List<T> findAll(Query query, Class<T> domainType) {
398403
MapSqlParameterSource parameterSource = new MapSqlParameterSource();
399404
String sqlQuery = sql(domainType).selectByQuery(query, parameterSource);
400405

401-
return operations.query(sqlQuery, parameterSource, getEntityRowMapper(domainType));
406+
return operations.query(sqlQuery, parameterSource, getRowMapper(domainType));
402407
}
403408

404409
@Override
@@ -416,7 +421,7 @@ public <T> List<T> findAll(Query query, Class<T> domainType, Pageable pageable)
416421
MapSqlParameterSource parameterSource = new MapSqlParameterSource();
417422
String sqlQuery = sql(domainType).selectByQuery(query, parameterSource, pageable);
418423

419-
return operations.query(sqlQuery, parameterSource, getEntityRowMapper(domainType));
424+
return operations.query(sqlQuery, parameterSource, getRowMapper(domainType));
420425
}
421426

422427
@Override
@@ -445,7 +450,13 @@ public <T> long count(Query query, Class<T> domainType) {
445450
return result;
446451
}
447452

448-
private <T> EntityRowMapper<T> getEntityRowMapper(Class<T> domainType) {
453+
private <T> RowMapper<? extends T> getRowMapper(Class<T> domainType) {
454+
RowMapper<? extends T> targetRowMapper;
455+
456+
if ((targetRowMapper = queryMappingConfiguration.getRowMapper(domainType)) != null) {
457+
return targetRowMapper;
458+
}
459+
449460
return new EntityRowMapper<>(getRequiredPersistentEntity(domainType), converter);
450461
}
451462

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/repository/QueryMappingConfiguration.java‎ renamed to ‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/core/convert/QueryMappingConfiguration.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.springframework.data.jdbc.repository;
1+
package org.springframework.data.jdbc.core.convert;
22

33
import org.springframework.jdbc.core.RowMapper;
44
import org.springframework.lang.Nullable;

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/mybatis/MyBatisDataAccessStrategy.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
import org.springframework.data.domain.Pageable;
3333
import org.springframework.data.domain.Sort;
3434
import org.springframework.data.jdbc.core.convert.*;
35+
import org.springframework.data.jdbc.core.convert.QueryMappingConfiguration;
3536
import org.springframework.data.mapping.PersistentPropertyPath;
3637
import org.springframework.data.mapping.PropertyPath;
3738
import org.springframework.data.relational.core.conversion.IdValueSource;
@@ -76,9 +77,10 @@ public class MyBatisDataAccessStrategy implements DataAccessStrategy {
7677
* uses a {@link DefaultDataAccessStrategy}
7778
*/
7879
public static DataAccessStrategy createCombinedAccessStrategy(RelationalMappingContext context,
79-
JdbcConverter converter, NamedParameterJdbcOperations operations, SqlSession sqlSession, Dialect dialect) {
80+
JdbcConverter converter, NamedParameterJdbcOperations operations, SqlSession sqlSession,
81+
Dialect dialect, QueryMappingConfiguration queryMappingConfiguration) {
8082
return createCombinedAccessStrategy(context, converter, operations, sqlSession, NamespaceStrategy.DEFAULT_INSTANCE,
81-
dialect);
83+
dialect, queryMappingConfiguration);
8284
}
8385

8486
/**
@@ -87,7 +89,7 @@ public static DataAccessStrategy createCombinedAccessStrategy(RelationalMappingC
8789
*/
8890
public static DataAccessStrategy createCombinedAccessStrategy(RelationalMappingContext context,
8991
JdbcConverter converter, NamedParameterJdbcOperations operations, SqlSession sqlSession,
90-
NamespaceStrategy namespaceStrategy, Dialect dialect) {
92+
NamespaceStrategy namespaceStrategy, Dialect dialect, QueryMappingConfiguration queryMappingConfiguration) {
9193

9294
SqlGeneratorSource sqlGeneratorSource = new SqlGeneratorSource(context, converter, dialect);
9395
SqlParametersFactory sqlParametersFactory = new SqlParametersFactory(context, converter);
@@ -98,7 +100,8 @@ public static DataAccessStrategy createCombinedAccessStrategy(RelationalMappingC
98100
converter, //
99101
operations, //
100102
sqlParametersFactory, //
101-
insertStrategyFactory //
103+
insertStrategyFactory, //
104+
queryMappingConfiguration //
102105
).create();
103106

104107
// the DefaultDataAccessStrategy needs a reference to the returned DataAccessStrategy. This creates a dependency

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/repository/config/AbstractJdbcConfiguration.java‎

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
import org.springframework.data.jdbc.core.mapping.IdGeneratingBeforeSaveCallback;
4242
import org.springframework.data.jdbc.core.mapping.JdbcMappingContext;
4343
import org.springframework.data.jdbc.core.mapping.JdbcSimpleTypes;
44+
import org.springframework.data.jdbc.core.convert.QueryMappingConfiguration;
4445
import org.springframework.data.mapping.model.SimpleTypeHolder;
4546
import org.springframework.data.relational.RelationalManagedTypes;
4647
import org.springframework.data.relational.core.conversion.RelationalConverter;
@@ -62,6 +63,7 @@
6263
* @author Christoph Strobl
6364
* @author Myeonghyeon Lee
6465
* @author Chirag Tailor
66+
* @author Mikhail Polivakha
6567
* @since 1.1
6668
*/
6769
@Configuration(proxyBeanMethods = false)
@@ -71,6 +73,8 @@ public class AbstractJdbcConfiguration implements ApplicationContextAware {
7173

7274
private ApplicationContext applicationContext;
7375

76+
private QueryMappingConfiguration queryMappingConfiguration;
77+
7478
/**
7579
* Returns the base packages to scan for JDBC mapped entities at startup. Returns the package name of the
7680
* configuration class' (the concrete class, not this one here) by default. So if you have a
@@ -225,7 +229,9 @@ public DataAccessStrategy dataAccessStrategyBean(NamedParameterJdbcOperations op
225229
SqlGeneratorSource sqlGeneratorSource = new SqlGeneratorSource(context, jdbcConverter, dialect);
226230
DataAccessStrategyFactory factory = new DataAccessStrategyFactory(sqlGeneratorSource, jdbcConverter, operations,
227231
new SqlParametersFactory(context, jdbcConverter),
228-
new InsertStrategyFactory(operations, dialect));
232+
new InsertStrategyFactory(operations, dialect),
233+
this.queryMappingConfiguration
234+
);
229235

230236
return factory.create();
231237
}
@@ -249,6 +255,10 @@ public void setApplicationContext(ApplicationContext applicationContext) throws
249255
this.applicationContext = applicationContext;
250256
}
251257

258+
public void setQueryMappingConfiguration(Optional<QueryMappingConfiguration> queryMappingConfiguration) throws BeansException {
259+
this.queryMappingConfiguration = queryMappingConfiguration.orElse(QueryMappingConfiguration.EMPTY);
260+
}
261+
252262
/**
253263
* Scans the mapping base package for classes annotated with {@link Table}. By default, it scans for entities in all
254264
* packages returned by {@link #getMappingBasePackages()}.

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/repository/config/DefaultQueryMappingConfiguration.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import java.util.LinkedHashMap;
44
import java.util.Map;
55

6-
import org.springframework.data.jdbc.repository.QueryMappingConfiguration;
6+
import org.springframework.data.jdbc.core.convert.QueryMappingConfiguration;
77
import org.springframework.jdbc.core.ResultSetExtractor;
88
import org.springframework.jdbc.core.RowMapper;
99
import org.springframework.lang.Nullable;

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/repository/config/MyBatisJdbcConfiguration.java‎

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,8 @@
1515
*/
1616
package org.springframework.data.jdbc.repository.config;
1717

18+
import java.util.Optional;
19+
1820
import org.apache.ibatis.session.SqlSession;
1921
import org.springframework.beans.factory.annotation.Autowired;
2022
import org.springframework.context.annotation.Bean;
@@ -23,25 +25,29 @@
2325
import org.springframework.data.jdbc.core.convert.JdbcConverter;
2426
import org.springframework.data.jdbc.core.mapping.JdbcMappingContext;
2527
import org.springframework.data.jdbc.mybatis.MyBatisDataAccessStrategy;
28+
import org.springframework.data.jdbc.core.convert.QueryMappingConfiguration;
2629
import org.springframework.data.relational.core.dialect.Dialect;
2730
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcOperations;
2831

2932
/**
3033
* Configuration class tweaking Spring Data JDBC to use a {@link MyBatisDataAccessStrategy} instead of the default one.
3134
*
3235
* @author Oliver Drotbohm
36+
* @author Mikhail Polivakha
3337
* @since 1.1
3438
*/
3539
@Configuration(proxyBeanMethods = false)
3640
public class MyBatisJdbcConfiguration extends AbstractJdbcConfiguration {
3741

3842
private @Autowired SqlSession session;
3943

44+
private @Autowired Optional<QueryMappingConfiguration> queryMappingConfiguration;
45+
4046
@Bean
4147
@Override
4248
public DataAccessStrategy dataAccessStrategyBean(NamedParameterJdbcOperations operations, JdbcConverter jdbcConverter,
4349
JdbcMappingContext context, Dialect dialect) {
4450

45-
return MyBatisDataAccessStrategy.createCombinedAccessStrategy(context, jdbcConverter, operations, session, dialect);
51+
return MyBatisDataAccessStrategy.createCombinedAccessStrategy(context, jdbcConverter, operations, session, dialect, queryMappingConfiguration.orElse(QueryMappingConfiguration.EMPTY));
4652
}
4753
}

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/repository/support/JdbcQueryLookupStrategy.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
import org.springframework.context.ApplicationEventPublisher;
2626
import org.springframework.data.jdbc.core.convert.EntityRowMapper;
2727
import org.springframework.data.jdbc.core.convert.JdbcConverter;
28-
import org.springframework.data.jdbc.repository.QueryMappingConfiguration;
28+
import org.springframework.data.jdbc.core.convert.QueryMappingConfiguration;
2929
import org.springframework.data.jdbc.repository.query.AbstractJdbcQuery;
3030
import org.springframework.data.jdbc.repository.query.JdbcQueryMethod;
3131
import org.springframework.data.jdbc.repository.query.PartTreeJdbcQuery;

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/repository/support/JdbcRepositoryFactory.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
import org.springframework.data.jdbc.core.JdbcAggregateTemplate;
2323
import org.springframework.data.jdbc.core.convert.DataAccessStrategy;
2424
import org.springframework.data.jdbc.core.convert.JdbcConverter;
25-
import org.springframework.data.jdbc.repository.QueryMappingConfiguration;
25+
import org.springframework.data.jdbc.core.convert.QueryMappingConfiguration;
2626
import org.springframework.data.mapping.callback.EntityCallbacks;
2727
import org.springframework.data.relational.core.dialect.Dialect;
2828
import org.springframework.data.relational.core.mapping.RelationalMappingContext;

‎spring-data-jdbc/src/main/java/org/springframework/data/jdbc/repository/support/JdbcRepositoryFactoryBean.java‎

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
import org.springframework.data.jdbc.core.convert.JdbcConverter;
2828
import org.springframework.data.jdbc.core.convert.SqlGeneratorSource;
2929
import org.springframework.data.jdbc.core.convert.SqlParametersFactory;
30-
import org.springframework.data.jdbc.repository.QueryMappingConfiguration;
30+
import org.springframework.data.jdbc.core.convert.QueryMappingConfiguration;
3131
import org.springframework.data.mapping.callback.EntityCallbacks;
3232
import org.springframework.data.relational.core.dialect.Dialect;
3333
import org.springframework.data.relational.core.mapping.RelationalMappingContext;
@@ -48,6 +48,7 @@
4848
* @author Mark Paluch
4949
* @author Hebert Coelho
5050
* @author Chirag Tailor
51+
* @author Mikhail Polivakha
5152
*/
5253
public class JdbcRepositoryFactoryBean<T extends Repository<S, ID>, S, ID extends Serializable>
5354
extends TransactionalRepositoryFactoryBeanSupport<T, S, ID> implements ApplicationEventPublisherAware {
@@ -166,6 +167,10 @@ public void afterPropertiesSet() {
166167
this.operations = beanFactory.getBean(NamedParameterJdbcOperations.class);
167168
}
168169

170+
if (this.queryMappingConfiguration == null) {
171+
this.queryMappingConfiguration = QueryMappingConfiguration.EMPTY;
172+
}
173+
169174
if (this.dataAccessStrategy == null) {
170175

171176
Assert.state(beanFactory != null, "If no DataAccessStrategy is set a BeanFactory must be available");
@@ -181,16 +186,12 @@ public void afterPropertiesSet() {
181186
InsertStrategyFactory insertStrategyFactory = new InsertStrategyFactory(this.operations, this.dialect);
182187

183188
DataAccessStrategyFactory factory = new DataAccessStrategyFactory(sqlGeneratorSource, this.converter,
184-
this.operations, sqlParametersFactory, insertStrategyFactory);
189+
this.operations, sqlParametersFactory, insertStrategyFactory, queryMappingConfiguration);
185190

186191
return factory.create();
187192
});
188193
}
189194

190-
if (this.queryMappingConfiguration == null) {
191-
this.queryMappingConfiguration = QueryMappingConfiguration.EMPTY;
192-
}
193-
194195
if (beanFactory != null) {
195196
entityCallbacks = EntityCallbacks.create(beanFactory);
196197
}

0 commit comments

Comments
 (0)