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); }