幾種不同的Reactive的Repository資料庫儲存介面
阿新 • • 發佈:2020-10-21
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> { }