Spring/spring-data-relational
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

#452 - Introduce factory method for StatementMapper.

Browse Source
This commit is contained in:
Mark Paluch
2020-09-09 13:12:38 +02:00
parent 0868f2aaef
commit 6c3ba72253
2 changed files with 39 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/org/springframework/data/r2dbc/core/DefaultStatementMapper.java
View File

@@ -19,11 +19,13 @@ import java.util.ArrayList;
import java.util.List;
import org.springframework.data.mapping.context.MappingContext;
import org.springframework.data.r2dbc.convert.R2dbcConverter;
import org.springframework.data.r2dbc.dialect.BindTarget;
import org.springframework.data.r2dbc.dialect.R2dbcDialect;
import org.springframework.data.r2dbc.query.BoundAssignments;
import org.springframework.data.r2dbc.query.BoundCondition;
import org.springframework.data.r2dbc.query.UpdateMapper;
import org.springframework.data.relational.core.dialect.RenderContextFactory;
import org.springframework.data.relational.core.mapping.RelationalPersistentEntity;
import org.springframework.data.relational.core.mapping.RelationalPersistentProperty;
import org.springframework.data.relational.core.query.CriteriaDefinition;
@@ -48,7 +50,17 @@ class DefaultStatementMapper implements StatementMapper {
private final R2dbcDialect dialect;
private final RenderContext renderContext;
private final UpdateMapper updateMapper;
private final MappingContext<RelationalPersistentEntity<?>, ? extends RelationalPersistentProperty> mappingContext;
private final MappingContext<? extends RelationalPersistentEntity<?>, ? extends RelationalPersistentProperty> mappingContext;
DefaultStatementMapper(R2dbcDialect dialect, R2dbcConverter converter) {
RenderContextFactory factory = new RenderContextFactory(dialect);
this.dialect = dialect;
this.renderContext = factory.createRenderContext();
this.updateMapper = new UpdateMapper(dialect, converter);
this.mappingContext = converter.getMappingContext();
}
DefaultStatementMapper(R2dbcDialect dialect, RenderContext renderContext, UpdateMapper updateMapper,
MappingContext<RelationalPersistentEntity<?>, ? extends RelationalPersistentProperty> mappingContext) {

29
src/main/java/org/springframework/data/r2dbc/core/StatementMapper.java
View File

@@ -23,11 +23,13 @@ import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.function.BiFunction;
import java.util.function.Supplier;
import java.util.stream.Collectors;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.data.r2dbc.dialect.BindMarkers;
import org.springframework.data.r2dbc.convert.R2dbcConverter;
import org.springframework.data.r2dbc.dialect.R2dbcDialect;
import org.springframework.data.r2dbc.mapping.SettableValue;
import org.springframework.data.relational.core.query.Criteria;
import org.springframework.data.relational.core.query.CriteriaDefinition;
@@ -38,11 +40,16 @@ import org.springframework.data.relational.core.sql.render.RenderContext;
import org.springframework.lang.Nullable;
import org.springframework.r2dbc.core.Parameter;
import org.springframework.r2dbc.core.PreparedOperation;
import org.springframework.util.Assert;
/**
* Mapper for statement specifications to {@link PreparedOperation}. Statement mapping applies a
* {@link org.springframework.data.r2dbc.dialect.R2dbcDialect}-specific transformation considering {@link BindMarkers}
* and vendor-specific SQL differences.
* {@link org.springframework.data.r2dbc.dialect.R2dbcDialect}-specific transformation considering
* {@link org.springframework.r2dbc.core.binding.BindMarkers} and vendor-specific SQL differences.
* <p>
* {@link PreparedOperation Mapped statements} can be used directly with
* {@link org.springframework.r2dbc.core.DatabaseClient#sql(Supplier)} without specifying further SQL or bindings as the
* prepared operation encapsulates the specified SQL operation.
*
* @author Mark Paluch
* @author Roman Chigvintsev
@@ -50,6 +57,22 @@ import org.springframework.r2dbc.core.PreparedOperation;
*/
public interface StatementMapper {
/**
* Create a new {@link StatementMapper} given {@link R2dbcDialect} and {@link R2dbcConverter}.
*
* @param dialect must not be {@literal null}.
* @param converter must not be {@literal null}.
* @return the new {@link StatementMapper}.
* @since 1.2
*/
static StatementMapper create(R2dbcDialect dialect, R2dbcConverter converter) {
Assert.notNull(dialect, "R2dbcDialect must not be null");
Assert.notNull(converter, "R2dbcConverter must not be null");
return new DefaultStatementMapper(dialect, converter);
}
/**
* Create a typed {@link StatementMapper} that considers type-specific mapping metadata.
*