Код: Выделить всё
@Repository
public interface TasksRepository extends LcR2dbcRepository {
default Flux findAllTasks(){
return SelectQuery.from(Task.class,"root") //Ic spring data r2dbc query
.join("root","due","mydue")
.execute(getLcClient()).doOnError(System.out::println);
}
}
< /code>
Модель задачи < /p>
@Getter
@Setter
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Table
public class Task {
@Id
@GeneratedValue
@Column
private Integer id;
@Column
private Integer comment_count;
@Column
private Boolean completed;
@Column
private String content;
@Column
private String url;
@Column
private Integer orderdata;
@Column
private Integer priority;
@ForeignKey // this is Ic spring data r2dbc library anotation
private Integer due;
}
< /code>
Due Class < /p>
@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
@Builder
@Table
public class Due {
@Id
@GeneratedValue
@Column
private Integer id;
@Column
private Date my_data;
@Column
private Boolean recurring;
@Column
private String my_string;
}
< /code>
Ошибки < /p>
org.springframework.data.mapping.MappingException: Couldn't find PersistentEntity for type class
java.lang.Integer!
at
org.springframework.data.mapping.context.MappingContext
.getRequiredPersistentEntity(MappingContext.java:7
9) ~[spring-data-commons-2.4.5.jar:2.4.5]
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Error has been observed at the following site(s):
|_ checkpoint ⇢ Select from Task as root join mydue
|_ checkpoint ⇢ Handler
com.WebFluxTestCodes.WebFluxTestCodes.controller.TasksController#getAllTasks() [DispatcherHandler]
|_ checkpoint ⇢ HTTP GET "/api/tasks" [ExceptionHandlingWebHandler]
Подробнее здесь: https://stackoverflow.com/questions/668 ... tententity