保存新对象时反应性存储库抛出异常
Posted
技术标签:
【中文标题】保存新对象时反应性存储库抛出异常【英文标题】:reactive repository throws exception when saving a new object 【发布时间】:2020-04-15 13:03:59 【问题描述】:我正在使用r2dbc
、r2dbc-h2
和实验性spring-boot-starter-data-r2dbc
implementation 'org.springframework.boot.experimental:spring-boot-starter-data-r2dbc:0.1.0.M1'
implementation 'org.springframework.data:spring-data-r2dbc:1.0.0.RELEASE' // starter-data provides old version
implementation 'io.r2dbc:r2dbc-h2:0.8.0.RELEASE'
implementation 'io.r2dbc:r2dbc-pool:0.8.0.RELEASE'
我已经创建了响应式存储库
public interface IJsonComparisonRepository extends ReactiveCrudRepository<JsonComparisonResult, String>
还添加了一个自定义脚本,在启动时在 H2 中创建一个表
@SpringBootApplication
public class JsonComparisonApplication
public static void main(String[] args)
SpringApplication.run(JsonComparisonApplication.class, args);
@Bean
public CommandLineRunner startup(DatabaseClient client)
return (args) -> client
.execute(() ->
var resource = new ClassPathResource("ddl/script.sql");
try (var is = new InputStreamReader(resource.getInputStream()))
return FileCopyUtils.copyToString(is);
catch (IOException e)
throw new RuntimeException(e);
)
.then()
.block();
我的r2dbc
配置如下所示
@Configuration
@EnableR2dbcRepositories
public class R2dbcConfiguration extends AbstractR2dbcConfiguration
@Override
public ConnectionFactory connectionFactory()
return new H2ConnectionFactory(
H2ConnectionConfiguration.builder()
.url("mem:testdb;DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE")
.username("sa")
.build());
我执行逻辑的服务如下所示
@Override
public Mono<JsonComparisonResult> updateOrCreateRightSide(String comparisonId, String json)
return updateComparisonSide(comparisonId, storedComparisonResult ->
storedComparisonResult.setRightSide(json);
return storedComparisonResult;
);
private Mono<JsonComparisonResult> updateComparisonSide(String comparisonId,
Function<JsonComparisonResult, JsonComparisonResult> updateSide)
return repository.findById(comparisonId)
.defaultIfEmpty(createResult(comparisonId))
.filter(result -> ComparisonDecision.NONE == result.getDecision()) // if not NONE - it means it was found and completed
.switchIfEmpty(Mono.error(new NotUpdatableCompleteComparisonException(comparisonId)))
.map(updateSide)
.flatMap(repository::save);
private JsonComparisonResult createResult(String comparisonId)
LOGGER.info("Creating new comparison result: .", comparisonId);
var newResult = new JsonComparisonResult();
newResult.setDecision(ComparisonDecision.NONE);
newResult.setComparisonId(comparisonId);
return newResult;
域名如下所示
@Table("json_comparison")
public class JsonComparisonResult
@Column("comparison_id")
@Id
private String comparisonId;
@Column("left")
private String leftSide;
@Column("right")
private String rightSide;
// @Enumerated(EnumType.STRING) - no support for now
@Column("decision")
private ComparisonDecision decision;
private String differences;
问题是当我尝试将任何对象添加到数据库时,它会失败并出现异常
org.springframework.dao.TransientDataAccessResourceException: Failed to update table [json_comparison]. Row with Id [4] does not exist.
at org.springframework.data.r2dbc.repository.support.SimpleR2dbcRepository.lambda$save$0(SimpleR2dbcRepository.java:91) ~[spring-data-r2dbc-1.0.0.RELEASE.jar:1.0.0.RELEASE]
at reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:96) ~[reactor-core-3.3.1.RELEASE.jar:3.3.1.RELEASE]
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73) ~[reactor-core-3.3.1.RELEASE.jar:3.3.1.RELEASE]
at reactor.core.publisher.MonoUsingWhen$MonoUsingWhenSubscriber.deferredComplete(MonoUsingWhen.java:276) ~[reactor-core-3.3.1.RELEASE.jar:3.3.1.RELEASE]
at reactor.core.publisher.FluxUsingWhen$CommitInner.onComplete(FluxUsingWhen.java:536) ~[reactor-core-3.3.1.RELEASE.jar:3.3.1.RELEASE]
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:1858) ~[reactor-core-3.3.1.RELEASE.jar:3.3.1.RELEASE]
at reactor.core.publisher.Operators.complete(Operators.java:132) ~[reactor-core-3.3.1.RELEASE.jar:3.3.1.RELEASE]
at reactor.core.publisher.MonoEmpty.subscribe(MonoEmpty.java:45) ~[reactor-core-3.3.1.RELEASE.jar:3.3.1.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) ~[reactor-core-3.3.1.RELEASE.jar:3.3.1.RELEASE]
由于某种原因,在 SimpleR2dbcRepository
库类中的 save
期间,它不认为 objectToSave
是新的,但随后它无法更新,因为它实际上不存在。
// SimpleR2dbcRepository#save
@Override
@Transactional
public <S extends T> Mono<S> save(S objectToSave)
Assert.notNull(objectToSave, "Object to save must not be null!");
if (this.entity.isNew(objectToSave)) // not new
....
为什么会这样?问题是什么?
【问题讨论】:
【参考方案1】:TL;DR: Spring Data 应该如何知道您的对象是新对象还是应该存在?
关系 Spring 数据存储库(JDBC 和 R2DBC)必须区分 [Reactive]CrudRepository.save(…)
给定对象是新对象还是存在于您的数据库中。执行save(…)
操作会导致INSERT
或UPDATE
语句。发出错误的语句会导致主键违规或无操作,因为标准 SQL 无法表达 upsert。
Spring Data JDBC|R2DBC 默认使用 @Id
值的存在/不存在。生成主键是一种广泛使用的机制。如果提供了主键,则认为实体存在。如果 id 值为null
,则该实体被视为新实体。
阅读更多关于Entity State Detection Strategies的参考文档。
【讨论】:
所以基本上如果我使用@Id
我不能手动提供它或其他什么?因为最初(在反应之前)一切正常。
您有多种选择,其中一个不存在的@Id
只是一种选择。您还可以通过提供自己的isNew()
实现来实现Persistable
接口。
hm,所以基本上spring-data-jpa
使用了persistable
或entityInformation
的一些自定义版本?
不,Spring Data JPA 遵循相同的机制。从错误的isNew()
提示中恢复的是 JPA 本身。 JPA 具有附加实体的概念,可帮助 JPA 确定实体是否为新实体。如果 JPA 无法确定实体是否为新实体,它会在 INSERT
/UPDATE
之前发出 SELECT
以与数据库状态同步。
我可以将我现有的实体包装到某个代理中,并将其与persistable
接口一起使用,而不是为域实现persistable
吗?【参考方案2】:
您必须实现 Persistable,因为您提供了 @Id。库需要弄清楚该行是新行还是应该存在。如果您的实体实现了 Persistable,则 save(...) 将使用 isNew() 的结果来确定是发出 INSERT 还是 UPDATE。
例如:
public class Product implements Persistable<Integer>
@Id
private Integer id;
private String description;
private Double price;
@Transient
private boolean newProduct;
@Override
@Transient
public boolean isNew()
return this.newProduct || id == null;
public Product setAsNew()
this.newProduct = true;
return this;
【讨论】:
【参考方案3】:也许你应该考虑这个: 选择您的 id/Primary Key 的数据类型为 INT/LONG 并将其设置为 AUTO_INCREMENT(如下所示):
CREATE TABLE PRODUCT(id INT PRIMARY KEY AUTO_INCREMENT NOT NULL, modelname VARCHAR(30) , year VARCHAR(4), owner VARCHAR(50)); 在您的帖子请求正文中,不要包含 id 字段。
【讨论】:
以上是关于保存新对象时反应性存储库抛出异常的主要内容,如果未能解决你的问题,请参考以下文章