diff --git a/network-data-jooq/src/main/java/dev/struchkov/network/data/jooq/PersonRepositoryImpl.java b/network-data-jooq/src/main/java/dev/struchkov/network/data/jooq/PersonRepositoryImpl.java index a60e8c8..57fcfe8 100644 --- a/network-data-jooq/src/main/java/dev/struchkov/network/data/jooq/PersonRepositoryImpl.java +++ b/network-data-jooq/src/main/java/dev/struchkov/network/data/jooq/PersonRepositoryImpl.java @@ -35,9 +35,7 @@ public class PersonRepositoryImpl implements PersonRepository { return Uni.createFrom().item(dsl.insertInto(PERSON).set(mapper.toRecord(person)).getSQL(ParamType.NAMED_OR_INLINED)) .map(pgPool::query) .flatMap(Query::execute) - .onItem().transformToMulti(RowSet::toMulti) - .collect().last() - .onItem().ifNotNull().transform(toDomain()); + .flatMap(ignore -> findById(person.getId())); } @Override