几种不同的Reactive的Repository数据库保存接口

package com.example.webfluxr2dbcdemo.repository;

import com.example.webfluxr2dbcdemo.entity.ClientUser;
import org.springframework.data.r2dbc.repository.Modifying;
import org.springframework.data.r2dbc.repository.Query;
import org.springframework.data.repository.reactive.ReactiveSortingRepository;
import reactor.core.publisher.Mono;

/**
 * @Author: zhangQi
 * @Date: 2020-10-08 9:49
 */
public interface RClientUserSortingRepository extends ReactiveSortingRepository<ClientUser,String> {
    /**
     * 添加Modifying后,返回值可以从Mono<ClientUser>, Mono<Boolean> 或者 Mono<Integer> 任意一种选择
     * @param userId
     * @param nickName
     * @param phoneNumber
     * @param gender
     * @return
     */
    @Modifying
    @Query("insert into client_user (user_id,nick_name,phone_number,gender) values (:userId,:nickName,:phoneNumber,:gender)")
    Mono<Integer> addClientUser(String userId,String nickName,String phoneNumber,Integer gender);
}

package com.example.webfluxr2dbcdemo.repository;

import com.example.webfluxr2dbcdemo.entity.Groups;
import org.springframework.data.repository.reactive.ReactiveCrudRepository;

/**
 * @Author: zhangQi
 * @Date: 2020-10-10 13:29
 */
public interface RGroupsCrudRepository extends ReactiveCrudRepository<Groups,Long> {
}

package com.example.webfluxr2dbcdemo.repository;

import com.example.webfluxr2dbcdemo.entity.Groups;
import org.springframework.data.r2dbc.repository.R2dbcRepository;

/**
 * @Author: zhangQi
 * @Date: 2020-10-10 13:30
 */
public interface RGroupsR2dbcRepository extends R2dbcRepository<Groups,Long> {
}