问题：

Webflux R2dbc问题一对一关系表

殳凯捷

2023-03-14

大家好，我正在用R2dbc（非阻塞）编写RESTAPI项目，但问题是表关系

任务模型

 @Getter
 @Setter
 @Entity(name = "task")
 @Table(name = "task")
 public class Task {

    @Id
    @Column(name = "id",unique = true,nullable = false)
    private Integer id;

    @Column(name = "comment_count")
    private Integer comment_count;

    @Column(name = "completed")
    private Boolean completed;

    @Column(name = "content")
    private String  content;

    @Column(name = "url")
    private String  url;

    @Column(name = "orderdata")
    private Integer orderdata;

    @Column(name = "priority")
    private Integer priority;

    @OneToOne
    @JoinColumn(name = "due_id")//this is relation table Due but this relation retunr response null
    private Due due;

 }

到期模型

  @Getter
  @Setter//Lombok library
  @Entity
  @Table(name = "due")
  public class Due {

    @Id
    @Column(nullable = false, unique = true, updatable = false)
    private Integer id;

   @Column(name = "date_data")
   private Date date_Data;

   @Column
   private Boolean recurring;

   @Column(name = "string_data")
  private String string_data;


}

任务仓库//这个反应性的污物仓库

     @Repository
     public interface TasksRepository extends ReactiveCrudRepository<Task,Integer> {

      }

任务管理器//这是业务层

   @Component
   @Slf4j
   @RequiredArgsConstructor
   public class  TaskManager {

          private final TasksRepository tasksRepository;

          public Flux<Task> findAll() {
           return tasksRepository.findAll();
          }

      }

任务服务//这是服务层

    @Service
    @RequiredArgsConstructor
    public class TasksService {


        private final TaskManager taskManager;


          public Flux<Task> getAll() {
            return taskManager.findAll();
      }
    }

任务控制器

  @RestController
  @RequestMapping("/api/tasks")
  @RequiredArgsConstructor
  public class TasksController {


        private final TasksService tasksService;

         @GetMapping
         public Flux<Task> getAllTasks(){
          return tasksService.getAll();
       }
     }

任务响应

我的Rest Api响应任务

     {
        "id": 1,
        "comment_count": 10,
        "completed": false,
        "content": "new content",
        "url": "http:8085.com",
        "orderdata": 5,
        "priority": 5,
        "due": {
             "id": 3,
             "date_Data": null,
             "recurring": null,
             "string_data": null
 
      }

问题一对一关系响应空有什么问题？？？请帮帮我谢谢

错误跟踪

  2021-03-20 20:49:57.161 ERROR 13652 --- [actor-tcp-nio-1] 
   r.n.channel.ChannelOperationsHandler     : [id: 0x1126662b, 
    L:/127.0.0.1:55827 - R:localhost/127.0.0.1:5432] Error was received while 
     reading the incoming data. The connection will be closed.

    java.lang.StackOverflowError: null
      at  io.netty.util.internal.ReferenceCountUpdater
     .isLiveNonVolatile(ReferenceCountUpdt 
     er.java:88) ~[netty-common-4.1.59.Final.jar:4.1.59.Final]
         at 
      io.netty.buffer.AbstractReferenceCountedByteBuf
      .isAccessible(AbstractReferenceCountedByteBuf.java:56) ~[netty-buffer- 
       4.1.59.Final.jar:4.1.59.Final]
       at io.netty.buffer.AbstractByteBuf.ensureAccessible(AbstractByteBuf.java:1455) ~[netty-buffer-4.1.59.Final.jar:4.1.59.Final]
at io.netty.buffer.AbstractByteBuf.checkIndex(AbstractByteBuf.java:1385) ~[netty-buffer-4.1.59.Final.jar:4.1.59.Final]
at io.netty.buffer.UnsafeByteBufUtil.getBytes(UnsafeByteBufUtil.java:481) ~[netty-buffer-4.1.59.Final.jar:4.1.59.Final]
at io.netty.buffer.PooledUnsafeDirectByteBuf.getBytes(PooledUnsafeDirectByteBuf.java:130) ~[netty-buffer-4.1.59.Final.jar:4.1.59.Final]
at io.netty.buffer.PooledSlicedByteBuf.getBytes(PooledSlicedByteBuf.java:235) ~[netty-buffer-4.1.59.Final.jar:4.1.59.Final]
at io.netty.buffer.ByteBufUtil.decodeString(ByteBufUtil.java:1147) ~[netty-buffer-4.1.59.Final.jar:4.1.59.Final]
at io.netty.buffer.AbstractByteBuf.toString(AbstractByteBuf.java:1248) ~[netty-buffer-4.1.59.Final.jar:4.1.59.Final]
at io.netty.buffer.AbstractByteBuf.getCharSequence(AbstractByteBuf.java:515) ~[netty-buffer-4.1.59.Final.jar:4.1.59.Final]
at io.netty.buffer.AbstractByteBuf.readCharSequence(AbstractByteBuf.java:520) ~[netty-buffer-4.1.59.Final.jar:4.1.59.Final]
at io.r2dbc.postgresql.util.ByteBufUtils.decode(ByteBufUtils.java:42) ~[r2dbc-postgresql-0.8.6.RELEASE.jar:0.8.6.RELEASE]
at io.r2dbc.postgresql.codec.AbstractNumericCodec.decodeNumber(AbstractNumericCodec.java:122) ~[r2dbc-postgresql-0.8.6.RELEASE.jar:0.8.6.RELEASE]
at io.r2dbc.postgresql.codec.AbstractNumericCodec.decodeNumber(AbstractNumericCodec.java:89) ~[r2dbc-postgresql-0.8.6.RELEASE.jar:0.8.6.RELEASE]
at io.r2dbc.postgresql.codec.IntegerCodec.doDecode(IntegerCodec.java:49) ~[r2dbc-postgresql-0.8.6.RELEASE.jar:0.8.6.RELEASE]
at io.r2dbc.postgresql.codec.IntegerCodec.doDecode(IntegerCodec.java:30) ~[r2dbc-postgresql-0.8.6.RELEASE.jar:0.8.6.RELEASE]
at io.r2dbc.postgresql.codec.AbstractCodec.decode(AbstractCodec.java:82) ~[r2dbc-postgresql-0.8.6.RELEASE.jar:0.8.6.RELEASE]
at io.r2dbc.postgresql.codec.DefaultCodecs.decode(DefaultCodecs.java:149) ~[r2dbc-postgresql-0.8.6.RELEASE.jar:0.8.6.RELEASE]
at io.r2dbc.postgresql.PostgresqlRow.decode(PostgresqlRow.java:90) ~[r2dbc-postgresql-0.8.6.RELEASE.jar:0.8.6.RELEASE]
at io.r2dbc.postgresql.PostgresqlRow.get(PostgresqlRow.java:77) ~[r2dbc-postgresql-0.8.6.RELEASE.jar:0.8.6.RELEASE]
at io.r2dbc.spi.Row.get(Row.java:76) ~[r2dbc-spi-0.8.3.RELEASE.jar:na]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readFrom(MappingR2dbcConverter.java:173) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readEntityFrom(MappingR2dbcConverter.java:294) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readFrom(MappingR2dbcConverter.java:166) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readEntityFrom(MappingR2dbcConverter.java:294) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readFrom(MappingR2dbcConverter.java:166) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readEntityFrom(MappingR2dbcConverter.java:294) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readFrom(MappingR2dbcConverter.java:166) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readEntityFrom(MappingR2dbcConverter.java:294) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readFrom(MappingR2dbcConverter.java:166) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readEntityFrom(MappingR2dbcConverter.java:294) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readFrom(MappingR2dbcConverter.java:166) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readEntityFrom(MappingR2dbcConverter.java:294) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readFrom(MappingR2dbcConverter.java:166) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readEntityFrom(MappingR2dbcConverter.java:294) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readFrom(MappingR2dbcConverter.java:166) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readEntityFrom(MappingR2dbcConverter.java:294) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]
at org.springframework.data.r2dbc.convert.MappingR2dbcConverter.readFrom(MappingR2dbcConverter.java:166) ~[spring-data-r2dbc-1.2.5.jar:1.2.5]

共有2个答案

贺俊杰

2023-03-14

好的，伙计，首先，为什么这个“应得的”实体需要是它自己的实体？我的意思是，一项任务可能有一个最后期限，而且可能是重复的。保持简单。

关于代码，无论领域建模方面如何：

使用Long或UUID作为ID字段类型。就我个人而言，我从未在生产中见过int。

为那些“到期”实体创建一个CrudRepo，以检查您是否可以自己查询它们。编写一个测试来验证这一点。

我的猜测是“JoinTable”注释在某种程度上是多余的和/或配置错误的。试试“到期”。ID”而不是“Due_ID”来告诉它应该接受到期对象的哪个字段。

堵宏毅

2023-03-14

R2DBC不支持关系，因此JoinColzo注释不起作用。相反，您可以创建DueRepository并手动获取此实体。

类似资料：

Access一对一关系

让我们来理解MS Access中的一对一关系。这种关系用于将一个表中的一条记录与另一个表中的一条记录相关联。现在转到数据库工具选项卡。点击关系选项。然后选择和，然后单击添加按钮将它们添加到视图中，然后关闭显示表格对话框。如下图所示 - 要创建这两个表之间的关系，请使用鼠标，然后单击并按住Employees 中的字段，然后将该字段拖放到要关联的字段上，方法是将鼠标悬停在tblHRData
MySQL-一对一关系？

问题内容：我正在尝试在MySQL数据库中实现“一对一”的关系。例如，假设我有一个Users表和一个Accounts表。我想确保一个用户只能拥有一个帐户。每个用户只能有一个帐户。我找到了两个解决方案，但是不知道该使用什么，还有其他选择。第一个解决方案：在此示例中，我在指向用户主键的帐户中定义外键。然后，我使外键成为唯一键，因此帐户中不能有两个相同的用户。要联接表，我将使用以下查询：第二种解
MySQL-一对一关系？

我试图在MySQL数据库中实现“一对一”的关系。例如，假设我有一个Users表和一个Accounts表。我想确保一个用户只能有一个帐户。每个用户只能有一个帐户。我找到了两个解决方案，但不知道该用什么，还有其他的选择。在本例中，我定义了指向用户中主键的帐户中的外键。然后我使外键唯一，所以帐户中不能有两个相同的用户。要联接表，我将使用以下查询： null 如果我将这些解决方案中的任何一个导入到My
OpenJPA-嵌套的一对多关系合并问题

问题内容：将其发布在这里是因为我在这里没有太大的兴趣：http : //www.java- forums.org/jpa/96175-openjpa-one-many-within-one-many-merge- problems.html 试图找出这是OpenJPA的问题还是我做错了… 尝试使用OpenJPA更新包含与另一个实体具有一对多关系的实体时，遇到一个问题。这是我正在谈论的简单示例：
JPA hibernate一对一关系

问题内容：我有一对一的关系，但是hibernatetool在生成模式时抱怨。这是显示问题的示例：人与OtherInfo具有一对一关系：人是OtherInfo的拥有方。OtherInfo是拥有方，因此person用于在Person中指定属性名称“ otherInfo”。使用hibernatetool生成数据库架构时出现以下错误：知道为什么吗？我是在做错什么还是这是Hibernate错误？
在嵌套的一对多关系表上解决N1Hibernate问题

我有一个组织表，部门表和员工表。一个组织有许多部门，一个部门有许多员工。在执行（组织的 PK）时，我看到 Employee 表也被查询 n 次，其中 n 是组织的部门数。如何避免在执行相同操作时获取员工数据？我在这里看到了一个N 1问题。但不确定如何在嵌套的一对多映射中避免它。提取类型设置为“延迟”。

Webflux R2dbc问题一对一关系表

共有2个答案

相关问答

相关文章

相关阅读

相关工具

相关文档