中如何实现MySql响应式编程框架（DataR2DBC）应用框架

注意这里返回的结果是 Mono 和 Flux 等异步结果。这是响应式交互和非响应式交互的最大区别。

如果要自定义操作，有以下几种方式：

(1） 由方法名定义

只要我们通过规则定义方法名，就会为我们生成 SQL。

// 按名称查找
Flux findByName(String name);
// 查找给定范围内的
Flux findByIdGreaterThan(Long startId);
// 查找大于给定id的数据
Flux findByIdGreaterThan(Long startId);
// 查询名称以给定字符串开头的数据
Flux findByNameStartingWith(String start);
// 分页
Flux findByIdGreaterThanEqual(Long startId, Pageable pageable);

注意以上方法名需要根据规范定义

findByName -> findBy
findByIdGreaterThan -> findByGreaterThan

它会为我们生成相应的SQL，非常方便。这种方法可以满足大多数简单的查询。

对应删除操作

Mono deleteByName(String name);   

详细的方法命名规则请参考官方文档。

(2）手动写SQL

对于复杂的SQL，开发者也可以手写SQL，

@Query("select  id,name from delivery_company where id in  (:ids)")
Flux findByIds2(List ids);
@Query("select  id,name from delivery_company where name = :name")
Flux findByName2(String name);
@Modifying
@Query("update delivery_company set name = :name where id = :id")
Mono update2(@Param("id") long id, @Param("name") String name);

可以看到，写SQL也很简单，对设置参数的支持也很好。

没有办法使用JPQL（Java Query），但是使用原生SQL是没有问题的。

如果你用过，应该用过下面这个判断参数不为空的方法

  SELECT * FROM delivery_company
  WHERE name = #{name}
  
    AND label like #{label}
  

可惜JPA没有办法支持。如果有同学知道，请不吝赐教。

(3) 使用

或者，可以使用自动生成的 SQL

    @Autowired
    private R2dbcEntityTemplate template;
	
    public Flux getByName3(String name) {
        return template
                .select(DeliveryCompany.class)
                .from("delivery_company")
                .matching(Query.query(Criteria.where("name").is(name))).all();
        // Criteria.where("name").is(name).and
    }
    public Mono update3(DeliveryCompany company) {
        return template
                .update(DeliveryCompany.class)
                .inTable("delivery_company")
                .matching(Query.query(Criteria.where("id").is(company.getId())))
                .apply(Update.update("name", company.getName()));
    }

该方法可以实现判断参数不是空查询，但是使用起来比较复杂（我们也可以封装起来方便我们使用）。

(4)Data R2DBC中也支持，我们定义的可以继承自，该接口提供以下模板方法

public interface ReactiveQuerydslPredicateExecutor {
    Mono findOne(Predicate var1);
    Flux findAll(Predicate var1);
    Flux findAll(Predicate var1, Sort var2);
    Flux findAll(Predicate var1, OrderSpecifier... var2);
    Flux findAll(OrderSpecifier... var1);
    Mono count(Predicate var1);
    Mono exists(Predicate var1);
}

Data R2DBC中也支持@注解，这里不再深入。

Data R2DBC支持事务，用法很简单，业务方法加@即可

    @Transactional
    public Flux save(List companyList) {
        Flux result = Flux.just();
        for (DeliveryCompany deliveryCompany : companyList) {
            result = result.concat(result, repository.save(deliveryCompany));
        }
        return result;
    }

为了演示事务的使用，没有调用方法，而是循环插入数据并返回最终结果。注意最终结果 Flux 和 Mono 必须作为方法返回值安卓连接mysql数据库，因为反应式编程的异常信息存储在这些结果中（而不是在方法被调用时抛出），所以这些结果必须作为方法返回值，否则无法知道方法是否报错，事务无法回滚。

Data R2DBC与Data JPA的使用基本相同，所以本文主要是介绍Data JPA的使用。

我以前没有使用过 Data JPA。本文主要是介绍。还有很多东西没有涉及到，比如id生成、多表查询等，这里就不做介绍了。

文章来源:http://www.toutiao.com/a6984373796518035982/

感谢您的来访，获取更多精彩文章请收藏本站。