From 5058f4e19caee4dbb15423fd6f26373cd060d343 Mon Sep 17 00:00:00 2001 From: wangyu <727842003@qq.com> Date: Mon, 1 Jul 2024 17:44:12 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B5=8B=E8=AF=95=E7=94=A8=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../flyfish/framework/r2dbc/R2DbcRepositoryTest.java | 12 ++++++++---- .../framework/r2dbc/repository/TestRepository.java | 3 +++ 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/flyfish-data/flyfish-data-r2dbc/src/test/java/com/flyfish/framework/r2dbc/R2DbcRepositoryTest.java b/flyfish-data/flyfish-data-r2dbc/src/test/java/com/flyfish/framework/r2dbc/R2DbcRepositoryTest.java index 31183e1..a20b047 100644 --- a/flyfish-data/flyfish-data-r2dbc/src/test/java/com/flyfish/framework/r2dbc/R2DbcRepositoryTest.java +++ b/flyfish-data/flyfish-data-r2dbc/src/test/java/com/flyfish/framework/r2dbc/R2DbcRepositoryTest.java @@ -7,6 +7,7 @@ import com.flyfish.framework.r2dbc.repository.TestAssoRepository; import com.flyfish.framework.r2dbc.repository.TestRepository; import com.flyfish.framework.utils.JacksonUtil; import jakarta.annotation.Resource; +import lombok.extern.slf4j.Slf4j; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.springframework.beans.factory.annotation.Autowired; @@ -21,6 +22,7 @@ import java.util.List; @SpringBootTest(classes = R2DbcRepositoryTest.class) @SpringBootApplication(scanBasePackages = "com.flyfish.framework") @Import(R2dbcDataConfig.class) +@Slf4j public class R2DbcRepositoryTest { @Resource @@ -42,12 +44,14 @@ public class R2DbcRepositoryTest { test.setOtherId("1"); // 打印插入结果 - System.out.println(JacksonUtil.toPrettyJson(testRepository.insert(test).block())); + log.info("插入结果:{}", JacksonUtil.toPrettyJson(testRepository.insert(test).block())); + // 查询生成 + log.info("生成查询:{}", JacksonUtil.toPrettyJson(testRepository.findByNameContaining("名").block())); List all = testRepository.findAll(qo).collectList().block(); - System.out.println(JacksonUtil.toPrettyJson(all)); + log.info("qo查询:{}", JacksonUtil.toPrettyJson(all)); // 修改值并保存测试 all.get(0).getAsso().setName("修改后的值"); - System.out.println(JacksonUtil.toPrettyJson(testRepository.saveAll(all).collectList().block())); - System.out.println(JacksonUtil.toPrettyJson(testAssoRepository.findById("1").block())); + log.info("批量保存:{}", JacksonUtil.toPrettyJson(testRepository.saveAll(all).collectList().block())); + log.info("id查询:{}", JacksonUtil.toPrettyJson(testAssoRepository.findById("1").block())); } } diff --git a/flyfish-data/flyfish-data-r2dbc/src/test/java/com/flyfish/framework/r2dbc/repository/TestRepository.java b/flyfish-data/flyfish-data-r2dbc/src/test/java/com/flyfish/framework/r2dbc/repository/TestRepository.java index 05548cb..203c943 100644 --- a/flyfish-data/flyfish-data-r2dbc/src/test/java/com/flyfish/framework/r2dbc/repository/TestRepository.java +++ b/flyfish-data/flyfish-data-r2dbc/src/test/java/com/flyfish/framework/r2dbc/repository/TestRepository.java @@ -2,9 +2,12 @@ package com.flyfish.framework.r2dbc.repository; import com.flyfish.framework.r2dbc.domain.TestDO; import com.flyfish.framework.repository.DefaultReactiveRepository; +import reactor.core.publisher.Mono; /** * 测试仓库 */ public interface TestRepository extends DefaultReactiveRepository { + + Mono findByNameContaining(String like); }