如何使用 Mono<Connection> 或 R2dbc 在 Spring 提供的

Question

我不知道如何使用spring-webflux（反应式）在R2dbc（java）中构建有效的查询。使用 R2dbc 提供的 DatabaseClient 对象（或者，连接对象），似乎我只能调用这两种方法之一的不同变体：或 。如果我在Java中有一个模式和一个相应的类，具有多个可为null的字段，那么我应该如何有效地处理这个问题？bind(Object field, Object value)bindNull(Object field, Class<?> type)

举个例子：

public Flux<Item> saveOrUpdate(Item entity) {

   Mono<Connection> connection = this.connection; 

   Flux<? extends Result> itemFlux = connection

       .doOnError(e -> e.printStackTrace())

           .flatMapMany(connect  ->  connect.createStatement(INSERT_OR_UPDATE_ITEM)

                .bind("itemId", entity.getItemId()).returnGeneratedValues("itemid")

                .bind("auditId", entity.getTx().getId())

                .bind("itemNum", entity.getItemNum())

                .bind("itemCat", entity.getItemCat()) //nullable

                 // How would I know when to use this?

                .bindNull("sourcedQty", Integer.class) //nullable

                .bind("makeQty", entity.getMakeQty())

                .bind("nameShown", entity.getNameShown()) //nullable

                .bind("price", entity.price())

                .bind("dateCreated", entity.getDateCreated()) //nullable

                .add()

                .execute())...

   ...

}

或

public Mono<Item> saveOrUpdate(Item entity){

   Mono<Item> itemMono = databaseClient.execute.sql(INSERT_OR_UPDATE_ITEM)

      .bind("itemId", entity.getItemId()).returnGeneratedValues("itemid")

                .bind("auditId", entity.getTx().getId())

                .bind("itemNum", entity.getItemNum())

                .bind("itemCat", entity.getItemCat())

                .bind("sourcedQty", entity.getSourcedQty()) 

                .bind("makeQty", entity.getMakeQty())

                .bind("nameShown", entity.getNameShown())

                .bind("price", entity.price())

                .bind("dateCreated", entity.getDateCreated())

                .as(Item.class)

                .fetch()

                .one()...

   ...

}

Answer 1

这是两个问题：如何以流畅的风格将潜在的可为空的值绑定到/？StatementDatabaseClient如何让数据库计算出其余部分？R2DBC 和 Spring Data R2DBC 通过要求将值绑定到或绑定 .没有方法可以接受可能为空的参数。这有两个原因：nullStatementnull你应该处理可空性，以表明那里发生了什么。这是处理可为 null 的值的好习惯，而不是使处理隐式。的隐式本质是导致最多错误的原因。nullnull数据库需要显式。带有占位符的参数化语句位于两个块的执行端：SQL 语句本身和参数绑定（描述符）。参数描述符需要与占位符、类型信息 （、 、 、 ...） 和实际值相关联。使用值进行调用时，驱动程序可以派生类型信息。绑定值时，驱动程序需要其他类型的信息。否则，我们无法执行查询。VARCHARBITINTbind(…)null话虽如此：没有像bindPotentiallyNull("auditId", entity.getTx().getId(), Integer.class)您无法在 SQL 查询中执行任何操作，因为绑定参数信息由辅助方法提供。在谈论存储过程时，我们面临着类似的问题，因为存储过程需要有关输入/输出/输入输出参数的其他详细信息。我们讨论了潜在的包装器类型，例如Parameters.in(@Nullable&nbsp;T&nbsp;value,&nbsp;Class<?&nbsp;super&nbsp;T>&nbsp;valueType)所以这些可以用作包装器bind("auditId",&nbsp;Parameters.in(entity.getTx().getId(),&nbsp;Integer.class))

Answer 2

可以使用如下所示的类设置值或 null：Parameterimport org.springframework.r2dbc.core.Parameter;// rest of the code.bind("customerId", Parameter.fromOrEmpty(o.getCustomerId(), UUID.class))早些时候，它是 ，未被弃用。SettableValue.fromOrEmpty