feat: 测试用例

This commit is contained in:
wangyu 2024-07-01 17:44:12 +08:00
parent 7fcd7c6e02
commit 5058f4e19c
2 changed files with 11 additions and 4 deletions

View File

@ -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<TestDO> 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()));
}
}

View File

@ -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<TestDO> {
Mono<TestDO> findByNameContaining(String like);
}