一文徹底理清SpringBoot CURD處理邏輯、順序

更新時(shí)間：2023年10月14日 11:36:46 作者：wei_shuo

這篇文章主要給大家介紹了關(guān)于如何一文徹底理清SpringBoot CURD處理邏輯、順序的相關(guān)資料,CURD是一個(gè)數(shù)據(jù)庫技術(shù)中的縮寫詞,一般的項(xiàng)目開發(fā)的各種參數(shù)的基本功能都是CURD,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下

理清SpringBoot CURD處理邏輯、順序

1、Controller（控制器）：

控制器接收來自客戶端的請求，并負(fù)責(zé)處理請求的路由和參數(shù)解析。
控制器通常會調(diào)用相應(yīng)的服務(wù)層方法來處理業(yè)務(wù)邏輯，并將結(jié)果返回給客戶端。

2、Service（服務(wù)層）：

服務(wù)層包含了應(yīng)用程序的業(yè)務(wù)邏輯。
服務(wù)層通常會調(diào)用數(shù)據(jù)訪問對象（DAO）來進(jìn)行數(shù)據(jù)的讀取、寫入和修改。
服務(wù)層可以對數(shù)據(jù)進(jìn)行處理、驗(yàn)證和轉(zhuǎn)換，并協(xié)調(diào)多個(gè)數(shù)據(jù)訪問對象的操作。
服務(wù)層的方法可以被控制器調(diào)用，也可以被其他服務(wù)層方法調(diào)用。

3、DAO（數(shù)據(jù)訪問對象）：

數(shù)據(jù)訪問對象負(fù)責(zé)與數(shù)據(jù)源（如數(shù)據(jù)庫）進(jìn)行交互，執(zhí)行數(shù)據(jù)的讀取、寫入和修改操作。
DAO通常會定義一組方法，用于執(zhí)行CRUD操作（創(chuàng)建、讀取、更新、刪除）。
DAO可以使用ORM（對象關(guān)系映射）工具或手動(dòng)編寫SQL語句來與數(shù)據(jù)源進(jìn)行交互。
DAO的實(shí)現(xiàn)可以是直接操作數(shù)據(jù)庫的類，也可以是使用ORM框架生成的類。

4、PO（持久化對象）：

持久化對象是與數(shù)據(jù)源中的表或集合相對應(yīng)的對象。
持久化對象通常具有與數(shù)據(jù)表字段相對應(yīng)的屬性，并提供了用于讀取和寫入數(shù)據(jù)的方法。
持久化對象可以由ORM框架自動(dòng)生成，也可以手動(dòng)編寫。

5、Repo（倉庫接口）：

倉庫接口定義了對領(lǐng)域?qū)ο蟮某志没筒樵兎椒ā?/li>
倉庫接口通常包含根據(jù)特定條件查詢領(lǐng)域?qū)ο蟮姆椒?，如根?jù)ID查詢、根據(jù)條件查詢等。
倉庫接口提供了抽象的方法，用于與具體的數(shù)據(jù)訪問對象進(jìn)行交互。

6、RepoImpl（倉庫實(shí)現(xiàn)類）：

倉庫實(shí)現(xiàn)類是倉庫接口的具體實(shí)現(xiàn)。
倉庫實(shí)現(xiàn)類負(fù)責(zé)將倉庫接口定義的方法與具體的數(shù)據(jù)訪問對象（DAO）進(jìn)行關(guān)聯(lián)。
倉庫實(shí)現(xiàn)類實(shí)現(xiàn)了倉庫接口中定義的方法，并根據(jù)需要調(diào)用相應(yīng)的DAO方法。

7、Mapper（映射器）：

映射器是一種用于將持久化對象與數(shù)據(jù)庫表之間進(jìn)行映射的工具。
映射器可以根據(jù)配置文件或注解來定義對象與表之間的映射關(guān)系。
映射器可以將持久化對象的屬性映射到數(shù)據(jù)庫表的列，并提供了CRUD操作的方法

聯(lián)表查詢接口

Controller

    @GetMapping("status")
    @ApiOperation("公告狀態(tài)")
    @Logger(menu = "首頁", action = "公告狀態(tài)")
    public Result noticeStatus() {
        List<SystemNoticeResponse> responses = systemNoticeService.SystemNoticeStatus();
        return Result.succ(responses);
    }

Service

    /**
     * 公告狀態(tài)
     *
     * @param
     * @return
     */
    public List<SystemNoticeResponse> SystemNoticeStatus() {
        Long merchantId = AuthContextHolder.getLoginMerchant().getId();
        List<SystemNoticeReaderResponse> systemNoticeReaderResponses = systemNoticeReaderRepo.SystemNoticeReaderStatus(merchantId);
        Map<String, Integer> idNoticeIdMap = new HashMap<>();
        for (SystemNoticeReaderResponse response : systemNoticeReaderResponses) {
            if (response.getId().equals(response.getNoticeId())) {
                idNoticeIdMap.put(response.getId(), 1);//已閱讀:1
            } else {
                idNoticeIdMap.put(response.getId(), 0);//待閱讀:0
            }
        }
        List<SystemNoticeResponse> noticeResponses = new ArrayList<>();
        for (Map.Entry<String, Integer> entry : idNoticeIdMap.entrySet()) {
            String id = entry.getKey();
            long parseLong = Long.parseLong(id);
            SystemNoticeResponse response = new SystemNoticeResponse(
                    parseLong,
                    systemNoticeRepo.getById(parseLong).getNoticeTitle(),
                    systemNoticeRepo.getById(parseLong).getNoticeContent(),
                    systemNoticeRepo.getById(parseLong).getCreateAt(),
                    entry.getValue()
            );
            noticeResponses.add(response);
        }

        noticeResponses = noticeResponses.stream()
                .sorted(Comparator.comparing(SystemNoticeResponse::getReadStatus)
                        .thenComparing(Comparator.comparing(SystemNoticeResponse::getCreateAt).reversed()))
                .collect(Collectors.toList());

        return noticeResponses;
    }

Repo

List<SystemNoticeReaderResponse> SystemNoticeReaderStatus(Long merchantId);

RepoImpl

   @Override
    public List<SystemNoticeReaderResponse> SystemNoticeReaderStatus(Long merchantId) {
        return baseMapper.systemNoticeStatus(merchantId);
    }

Mapper

List<SystemNoticeReaderResponse> systemNoticeStatus(Long id);

Mapper.xml

    <select id="systemNoticeStatus" parameterType="java.lang.Long" resultMap="systemNoticeStatusResultMap">
        SELECT y.id, s.notice_id
        FROM "system_notice" as y
                 LEFT JOIN "system_notice_reader" as s ON y."id" = s.notice_id AND s.merchant_id = #{id}
    </select>

    <resultMap id="systemNoticeStatusResultMap" type="com.moozumi.bean.response.notice.SystemNoticeReaderResponse">
        <result column="id" property="id" />
        <result column="notice_id" property="NoticeId" />
    </resultMap>

@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@TableName("system_notice_reader")
public class SystemNoticeReader {

    /**
     * null | system_notice_reader.id | @mbg.generated
     */
    @ApiModelProperty("null")
    @TableId
    private Long id;

    /**
     * 公告 ID | system_notice_reader.notice_id | @mbg.generated
     */
    @ApiModelProperty("公告 ID")
    private Long noticeId;

    /**
     * 已閱讀商戶 ID | system_notice_reader.merchant_id | @mbg.generated
     */
    @ApiModelProperty("已閱讀商戶 ID")
    private Long merchantId;

}

DaoCol：實(shí)體類字段對應(yīng)的枚舉類字段

public class SystemNoticeReaderCol {
	public static final String ID = "id";
	public static final String NOTICE_ID = "notice_id";
	public static final String MERCHANT_ID = "merchant_id";
}

DTO（VO）:數(shù)據(jù)傳輸對象

@Data
@AllArgsConstructor
public class SystemNoticeReaderResponse {

    @ApiModelProperty("ID")
    private String id;
    @ApiModelProperty("閱讀公告ID")
    private String NoticeId;

}

@Data
@AllArgsConstructor
public class SystemNoticeResponse {

    @ApiModelProperty("id")
    private Long id;
    @ApiModelProperty("標(biāo)題")
    private String noticeTitle;
    @ApiModelProperty("內(nèi)容")
    private String noticeContent;
    @ApiModelProperty("創(chuàng)建時(shí)間")
    private Date createAt;
    @ApiModelProperty("閱讀狀態(tài), 0: 待閱讀, 1: 已閱讀")
    private Integer readStatus;
}

CURD接口

add

Controller

    @PostMapping("add")
    @ApiOperation("新增公告")
    @Logger(menu = "公告管理", action = "新增公告")
    public Result noticeAdd(@Validated @RequestBody SystemNoticeResponse insert) {
        systemNoticeService.addSystemNotice(insert);
        return Result.succ("添加成功");
    }

Service

    /**
     * 公告添加
     *
     * @param insert
     * @return
     */
    public SystemNotice addSystemNotice(SystemNoticeResponse insert) {
        SystemNotice notice = new SystemNotice(
                null,
                insert.getNoticeTitle(),
                insert.getNoticeContent(),
                new Date(),
                AuthContextHolder.getLoginManager().getUserRealName()
        );
        systemNoticeRepo.save(notice);
        return notice;
    }

delete

Controller

    @PostMapping("delete")
    @ApiOperation("刪除公告")
    @Logger(menu = "公告管理", action = "刪除公告")
    public Result noticeDelete(@Validated @RequestBody CommonRequestId request) {
        systemNoticeRepo.removeById(request.getId());
        return Result.succ("刪除成功");
    }

update

Controller

    @PostMapping("update")
    @ApiOperation("編輯公告")
    @Logger(menu = "公告管理", action = "編輯公告")
    public Result noticeUpdate(@Validated @RequestBody SystemNoticeResponse insert) {
        systemNoticeService.updateSystemNotice(insert);
        return Result.succ("更新成功");
    }

Service

    /**
     * 編輯公告
     *
     * @param insert
     * @return
     */
    public SystemNotice updateSystemNotice(SystemNoticeResponse insert) {
        SystemNotice notice = systemNoticeRepo.getById(insert.getId());
        if (notice != null) {
            notice.setNoticeTitle(insert.getNoticeTitle());
            notice.setNoticeContent(insert.getNoticeContent());
            notice.setCreateAt(new Date());
            systemNoticeRepo.updateById(notice);
        }
        return notice;
    }

list

Controller

    @GetMapping("list")
    @ApiOperation("展示公告")
    @Logger(menu = "公告管理", action = "展示公告")
    public Result<PageResult<SystemNotice>> list(SystemNoticeQuery query) {
        Page<SystemNotice> systemNoticePage = systemNoticeRepo.systemNoticeQuery(query);
        return Result.succ(PageResult.toPage(systemNoticePage));
    }

insert

Controller

@PostMapping("insert")
@ApiOperation("已閱讀")
@Logger(menu = "首頁", action = "已閱讀")
public Result noticeReader(@Validated @RequestBody CommonRequestId request) {
    systemNoticeService.SystemNoticeReader(request.getId());
    return Result.succ("已閱讀");
}

Service

    /**
     * 公告 已閱讀
     *
     * @param
     * @return
     */
    public SystemNoticeReader SystemNoticeReader(Long noticeId) {
        SystemNoticeReader notice = new SystemNoticeReader(
                null,
                noticeId,
                AuthContextHolder.getLoginMerchant().getId()
        );
        systemNoticeReaderRepo.save(notice);
        return notice;
    }