|
|
|
@ -107,9 +107,7 @@ public class R2dbcRepositoryFactory extends ReactiveRepositoryFactorySupport { |
|
|
|
@Override |
|
|
|
@Override |
|
|
|
protected Object getTargetRepository(RepositoryInformation information) { |
|
|
|
protected Object getTargetRepository(RepositoryInformation information) { |
|
|
|
|
|
|
|
|
|
|
|
RelationalEntityInformation<?, ?> entityInformation = getEntityInformation(information.getDomainType(), |
|
|
|
RelationalEntityInformation<?, ?> entityInformation = getEntityInformation(information.getDomainType()); |
|
|
|
information); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return getTargetRepositoryViaReflection(information, entityInformation, operations, this.converter); |
|
|
|
return getTargetRepositoryViaReflection(information, entityInformation, operations, this.converter); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -119,16 +117,10 @@ public class R2dbcRepositoryFactory extends ReactiveRepositoryFactorySupport { |
|
|
|
return Optional.of(new R2dbcQueryLookupStrategy(operations, new CachingValueExpressionDelegate(valueExpressionDelegate), converter, dataAccessStrategy)); |
|
|
|
return Optional.of(new R2dbcQueryLookupStrategy(operations, new CachingValueExpressionDelegate(valueExpressionDelegate), converter, dataAccessStrategy)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
public <T, ID> RelationalEntityInformation<T, ID> getEntityInformation(Class<T> domainClass) { |
|
|
|
public <T, ID> RelationalEntityInformation<T, ID> getEntityInformation(Class<T> domainClass) { |
|
|
|
return getEntityInformation(domainClass, null); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@SuppressWarnings("unchecked") |
|
|
|
|
|
|
|
private <T, ID> RelationalEntityInformation<T, ID> getEntityInformation(Class<T> domainClass, |
|
|
|
|
|
|
|
@Nullable RepositoryInformation information) { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
RelationalPersistentEntity<?> entity = this.mappingContext.getRequiredPersistentEntity(domainClass); |
|
|
|
RelationalPersistentEntity<?> entity = this.mappingContext.getRequiredPersistentEntity(domainClass); |
|
|
|
|
|
|
|
|
|
|
|
return new MappingRelationalEntityInformation<>((RelationalPersistentEntity<T>) entity); |
|
|
|
return new MappingRelationalEntityInformation<>((RelationalPersistentEntity<T>) entity); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|