1

对于以下代码，存储库中的获取和更新操作可以正常工作。但保存操作不会将数据持久化到表中。如果我自己实现存储库，它工作正常。将其替换为扩展 ReactiveCrudRepository 的接口后，开始出现此问题。我错过了什么吗？

@SpringBootApplication
public class ReactiveSqlApplication {
public static void main(String[] args) {
    SpringApplication.run(ReactiveSqlApplication.class, args);
}

}

@Data
@AllArgsConstructor
@NoArgsConstructor
@Table("store")
class Store {

@Id
private String id;

private String name;

private String description;

}

interface StoreRepository extends ReactiveCrudRepository<Store, String> {
}

@Configuration
@EnableR2dbcRepositories
class R2dbcConfiguration extends AbstractR2dbcConfiguration {

private final ConnectionFactory connectionFactory;



   R2dbcConfiguration(ConnectionFactory connectionFactory) {
        this.connectionFactory = connectionFactory;
    }

    @Override
    public ConnectionFactory connectionFactory() {
        return this.connectionFactory;
    }
}


@Configuration
class ConnectionFactoryConfiguration {

@Bean
ConnectionFactory connectionFactory() {
    PostgresqlConnectionConfiguration config = PostgresqlConnectionConfiguration.builder()
            .host("localhost")
            .port(5433)
            .database("testdb")
            .username("postgres")
            .password("root")
            .build();
    return new PostgresqlConnectionFactory(config);
}

}

代码测试如下：

@SpringBootTest
@RunWith(SpringRunner.class)

public class StoreRepositoryTest {
@Autowired
private StoreRepository repository;

@Test
public void all() {

    Flux<Store> storeFlux = Flux.just(new Store("1", "a1", "a1"), new Store("2", "a2", "a2"))
            .flatMap(store -> repository.save(store));

    StepVerifier
            .create(storeFlux)
            .expectNextCount(2)
            .verifyComplete();

    Flux<Store> all = repository.findAll();

    StepVerifier
            .create(all)
            .expectNextCount(2)
            .verifyComplete();

}

}
4

3 回答 3

0

我在 github 问题上找到了一些解决方案： https ://github.com/spring-projects/spring-data-r2dbc/issues/218 似乎您可能想要Persistable为您的模型对象实现，因为您应该以某种方式告诉框架您的课程是新的，应该存储。这是上面链接中的示例代码：

@Data
@Table("sessions")
@NoArgsConstructor
public class Session implements Persistable<UUID> {

    @Id
    private UUID id;
    private String name, speakers;

    @Override
    public boolean isNew() {
        boolean result = Objects.isNull(id);
        this.id = result ? UUID.randomUUID() : this.id;
        return result;
    }
}

如果您已经收到一个 id，您可以在您的实体中使用一些字段并在代码中设置它以通过从方法@Transient返回该字段来指示对象是新的。isNew()

于 2021-03-19T23:22:07.787 回答
0

我最近遇到了同样的问题。这是因为它进行更新而不是插入。你需要自己处理。请参阅相关问题：为什么 Spring-data-jdbc 不保存我的 Car 对象？

于 2019-02-28T10:08:43.037 回答
0

如果您自己设置 id，该save()方法不会保存给定的实体。尝试将 id 值设置为 null。（这至少在Long用作 id 的类型时有效。）

于 2019-02-08T09:18:56.423 回答