当前位置：首页 > 文章列表 > 数据库 > MySQL > Java + Springboot + myBatis 实现评论以及子回复评论接口

Java + Springboot + myBatis 实现评论以及子回复评论接口

来源：SegmentFault 2023-02-24 12:59:03 0浏览收藏

编程并不是一个机械性的工作，而是需要有思考，有创新的工作，语法是固定的，但解决问题的思路则是依靠人的思维，这就需要我们坚持学习和更新自己的知识。今天golang学习网就整理分享《Java + Springboot + myBatis 实现评论以及子回复评论接口》，文章讲解的知识点主要包括MySQL、Java、springboot、mybatis，如果你对数据库方面的知识点感兴趣，就不要错过golang学习网，在这可以对大家的知识积累有所帮助，助力开发能力的提升。

1. 创建表

biz_comment

biz_users

表的字段，类型，长度等均可根据你的业务需求，随你发挥。这里只提供必要字段。

2. 通过自动生成代码生成 biz_comment 表

domain ：
说明：
@TableField(exist = false)

表示此字段不在表中，为自己定义的属性，不需要mybatis去找此字段。

private List subComments;

把子评论当做是 Comment 的一条属性装进List集合中，Comment是所有父级评 
论，而 subComments  是此父级的所有子评论。如果你愿意可以单独写一个 
CommentVO来封装所有子评论。（举个例子：一篇文章，A进行了回复，B觉得A说的不错回复了 
A，C也觉得A说的不错回复了A，这时候A就是父级，咱们就把A装进Comment里面，通过循 
环和set方法将B、C装进 subComments 里面成为A的子评论 ）这一步很重要，希望先能 
理解这一步再继续往下做。

package com.cema.manage.project.manage.comment.domain;

/**
 * 评论表 biz_comment
 *
 * @author reasahi
 * @date 2021-04-22
 */
@TableName(value = "biz_comment")
public class Comment extends Model<comment>
{
private static final long serialVersionUID=1L;

/** 编号 */
    @TableId(value = "id")
    private Integer id;
/** 用户ID
 */
    @TableField(value = "bu_id")
    private Integer buId;
/** 文章ID */
    @TableField(value = "bp_id")
    private Integer bpId;
/** 回复用户ID */
    @TableField(value = "wc_id")
    private Integer wcId;
/** 内容 */
    @TableField(value = "wc_content")
    private String wcContent;
/** 评论时间 */
    @TableField(value = "create_time")
    private String createTime;

    @TableField(exist = false)
    private List<comment> subComments;

    public List<comment> getSubComments() {
        return subComments;
    }

    public void setSubComments(List<comment> subComments) {
        this.subComments = subComments;
    }

    /**
 * 设置：编号
 */
public void setId(Integer id)
        {
            this.id = id;
        }

/**
 * 获取：编号
 */
public Integer getId()
        {
        return id;
        }
/**
 * 设置：用户ID

 */
public void setBuId(Integer buId)
        {
            this.buId = buId;
        }

/**
 * 获取：用户ID

 */
public Integer getBuId()
        {
        return buId;
        }
/**
 * 设置：文章ID
 */
public void setBpId(Integer bpId)
        {
            this.bpId = bpId;
        }

/**
 * 获取：文章ID
 */
public Integer getBpId()
        {
        return bpId;
        }
/**
 * 设置：回复用户ID
 */
public void setWcId(Integer wcId)
        {
            this.wcId = wcId;
        }

/**
 * 获取：回复用户ID
 */
public Integer getWcId()
        {
        return wcId;
        }
/**
 * 设置：内容
 */
public void setWcContent(String wcContent)
        {
            if(wcContent!=null){
            if(wcContent.trim().isEmpty()){
            this.wcContent =null;
            }else{
            this.wcContent = wcContent;
            }
            }
        }

/**
 * 获取：内容
 */
public String getWcContent()
        {
        return wcContent;
        }
/**
 * 设置：评论时间
 * @param createTime
 */
public void setCreateTime(String createTime)
        {
            this.createTime = createTime;
        }

/**
 * 获取：评论时间
 * @return
 */
public String getCreateTime()
        {
        return createTime;
        }

@Override
protected Serializable pkVal(){
        return this.id;
        }
        }</comment></comment></comment></comment>

mapper :
说明：
两个接口分别对应两条查询，level1Query为查询父级，另一个为查询子级。

package com.cema.manage.project.manage.comment.mapper;

/**
 * 评论 数据层
 * 
 * @author reasahi
 * @date 2021-04-22
 */
public interface CommentMapper  extends BaseMapper<comment>
{

    List<comment> level1Query(Map<string> map);
    List<comment> level2Query(Map<string> map);

}</string></comment></string></comment></comment>

xml :
说明：

bu_id为用户id，wc_id 为回复的用户的id。通过wc_id为null可以判断查询出来的结果都为 
父级id。（设想一下，你去评论一篇文章，你自己有个id，或者说是用户名，这个id/用户名就 
是bu_id，你评论了文章，文章是没有wc_id的吧，所以像数据库存入了默认值null，当然你可 
以存0或其它的，随意就好。这就是父级。在设想一下，这次你拿着你的id/用户名不去评论文 
章了，你去评论了一篇文章下诸多评论者A，你回复了A，这样在数据库是怎么存入的呢？是不 
是需要拿着你的bu_id和A的bu_id都存入数据库，其实A的bu_id就是wc_id，没错吧，那是不 
是就可以通过wc_id判断所有在同一篇文章回复了A的人，咱们只需要拿出这个关键的 
wc_id。）

<?xml version="1.0" encoding="UTF-8" ?><mapper namespace="com.cema.manage.project.manage.comment.mapper.CommentMapper"><!--  biz_comment  --><resultmap id="resultMapComment" type="com.cema.manage.project.manage.comment.domain.Comment"><id column="id" property="id"></id><result column="bu_id" property="buId"></result><result column="bp_id" property="bpId"></result><result column="wc_id" property="wcId"></result><result column="wc_content" property="wcContent"></result><result column="create_time" property="createTime"></result></resultmap>&lt;select id=&quot;level1Query&quot; resultmap=&quot;resultMapComment&quot; parametertype=&quot;map&quot;&gt;
        SELECT u.bu_mail,
               c.bp_id,
               c.wc_id,
               c.bu_id,
               c.create_time,
               c.wc_content
        FROM biz_comment c
                 LEFT JOIN biz_users_1 u ON c.bu_id = u.id
        WHERE c.wc_id IS NULL
          AND c.bp_id = #{bp_id}
        ORDER BY c.create_time DESC LIMIT #{current}, #{size};
    &lt;/select&gt;&lt;select id=&quot;level2Query&quot; resultmap=&quot;resultMapComment&quot; parametertype=&quot;map&quot;&gt;
        SELECT u.bu_mail,
               c.bp_id,
               c.wc_id,
               c.bu_id,
               c.create_time,
               c.wc_content
        FROM biz_comment c
                 LEFT JOIN biz_users_1 u ON c.wc_id = u.id
        WHERE c.wc_id IS NOT NULL
          AND bu_id = #{bu_id}
          AND bp_id = #{bp_id}
        ORDER BY c.create_time DESC
    &lt;/select&gt;</mapper>

service :

package com.cema.manage.project.manage.comment.service;

/**
 * 评论 服务层
 *
 * @author reasahi
 * @date 2021-04-22
 */
public interface ICommentService extends IService<comment> {

    List<comment> getCommentList(Map<string> map);

}</string></comment></comment>

serviceImpl :
说明：

如果前面都能理解，这里也很好理解，首先调用level1Query拿到父级，循环遍历父级拿到 
bu_id，bp_id存入map给level2Query，再依次遍历子评论，最后将所有父/子都存入集合中， 
返回给前端。

package com.cema.manage.project.manage.comment.service;

/**
 * 评论 服务层实现
 *
 * @author reasahi
 * @date 2021-04-22
 */
@Service
public class CommentServiceImpl extends ServiceImpl<commentmapper comment> implements ICommentService {

    @Resource
    private CommentMapper commentMapper;

    @Override
    public List<comment> getCommentList(Map<string object> map) {
        Map<string object> resultMap = new HashMap();
        List<comment> resultList = new ArrayList();
        List<comment> parentComments = commentMapper.level1Query(map);
        for (Comment c : parentComments) {
            resultMap.put("bu_id",c.getBuId());
            resultMap.put("bp_id",c.getBpId());
            List<comment> subComments = commentMapper.level2Query(resultMap);
            List<comment> reply = new ArrayList();
            for (Comment c1 : subComments) {
                reply.add(c1);
            }
            c.setSubComments(reply);
            resultList.add(c);
        }
        return resultList;
    }

}</comment></comment></comment></comment></string></string></comment></commentmapper>

controller :
说明：
所有用户id都需要通过token来获取，没有的话为了测试可以写死，无所谓的。current为第几页，前端是不会返回0的，因为没谁会看第0页是吧，都是从第一页开始，所以做一个简单的处理。咱们统一返回JSON，便于开发。

    @PostMapping("getCommentList")
    @ResponseBody
    public String getCommentList(HttpServletRequest request) {
        Map<string object> resultMap = new HashMap();
        String token = (String) request.getAttribute("token");
        Users users = (Users) redisService.get(token);
        Integer bu_id = users.getId();
        String current = request.getParameter("current");
        String size = request.getParameter("size");
        String bp_id = request.getParameter("bp_id");
        resultMap.put("bu_id", bu_id);
        resultMap.put("current", (Integer.parseInt(current) - 1) * Integer.parseInt(size));
        resultMap.put("size", Integer.parseInt(size));
        resultMap.put("bp_id", Integer.parseInt(bp_id));
        List<comment> comments = commentService.getCommentList(resultMap);
        JSONObject jsonStr = jsonDataUtilsInterFase.getJsonObject(comments,
                attributeUtilsInterFase.getAttributeName(String.class,
                        TestAttributeUtils.FILTER_PROTECTED), TestJSONDataUtils.SUCCESS_CODE1);
        return jsonStr.toString();
    }</comment></string>

5. 总结

至此代码完结，可以开始测试了，返回的JSON如下：

{
    "code": 1, 
    "datalist": [    父亲评论列表
        {
            "buId": 用户id, 
            "wcId": 回复用户id, 
            "createTime": 创建时间, 
            "subComments": [    // 儿子评论列表
                {
                    "buId": 用户id, 
                    "wcId": 回复用户id, 
                    "createTime": 创建时间, 
                    "subComments": [ 三级的回复 不用管 没数据 ], 
                    "bpId": 文章id, 
                    "id": 主键, 
                    "wcContent": "回复用户的评论"
                }, 
                {
                    "buId": 用户id, 
                    "wcId": 回复用户id, 
                    "createTime": 创建时间, 
                    "subComments": [ 三级的回复 不用管 没数据 ], 
                    "bpId": 文章id, 
                    "id": 主键, 
                    "wcContent": "回复用户的评论"
                }
            ], 
            "bpId": 文章id, 
            "id": 主键, 
            "wcContent": "回复文章的评论"
        }
    ], 
    "timetamp": 1619322835508
}

此接口重点就在于SQL的书写和数据结构。你需要通过SQL筛选出所有父评论和子评论。数据结构是父包着子，你可以用List集合装，也可以用其它的，封装一个vo来装，本文只提供一个思路，你可以撸的更好。

byeBye ^ ^~

到这里，我们也就讲完了《Java + Springboot + myBatis 实现评论以及子回复评论接口》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于mysql的知识点！

mysql MySQL Java springboot mybatis

版本声明

本文转载于：SegmentFault 如有侵犯，请联系study_golang@163.com删除