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> {
}