【SpringBoot】论坛项目中如何进行实现发布文章,以及更新对应数据库的数据更新_springboot论坛如何实现发帖功能
前言
🌟🌟本期讲解关于websocket的相关知识介绍~~~
🌈感兴趣的小伙伴看一看小编主页:GGBondlctrl-CSDN博客
🔥 你的点赞就是小编不断更新的最大动力
🎆那么废话不多说直接开整吧~~
目录
📚️1.数据库设计
🚀1.1数据库
🚀1.2板块数据库SQL语句编写
1.2.1用户表更新数据
1.2.2板块表更新数据
1.2.3文章表发布数据
📚️2.Dao层的设计
📚️3.Service层的设计
🚀3.1用户service层
🚀3.2板块service层
🚀3.3文章service层
📚️4.Controller层的设计
📚️5.测试
📚️6.总结
前言:前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站: 前言 – 人工智能教程
📚️1.数据库设计
🚀1.1数据库
小编使用的是navicat,具体的数据库如下所示,由于发表文章设计三个数据库:
文章数据库,板块数据库,作者数据库(这里指的就是用户数据库)
文章数据库:
包含了文章id,文章属于那个板块,所以板块id,谁发表的就是用户id,以及文章题目,内容,以及点赞数,回复数,浏览量等等,可以看看表的英文解释;
用户数据库:
这里就包含了用户id(与文章里的对应),以及username,password,包含比较重要的一些用户数据;
板块数据库:
这里就是每个板块的信息,板块名字,板块内发布的文章的数量,先后顺序等等.....
🚀1.2板块数据库SQL语句编写
分析:
我们要发布一篇文章,那么发布文章后,对应发布文章的作者对应的发布数量要增加,以及文章属于那个板块,那么板块包含的数量也要增加,所以这里涉及到三个数据库的操作;
1.2.1用户表更新数据
这里很明显是动态更新,具体的SQL语句如下所示:
update t_user username = #{username,jdbcType=VARCHAR}, password = #{password,jdbcType=VARCHAR}, nickname = #{nickname,jdbcType=VARCHAR}, phoneNum = #{phoneNum,jdbcType=VARCHAR}, email = #{email,jdbcType=VARCHAR}, gender = #{gender,jdbcType=TINYINT}, salt = #{salt,jdbcType=VARCHAR}, avatarUrl = #{avatarUrl,jdbcType=VARCHAR}, articleCount = #{articleCount,jdbcType=INTEGER}, isAdmin = #{isAdmin,jdbcType=TINYINT}, remark = #{remark,jdbcType=VARCHAR}, state = #{state,jdbcType=TINYINT}, deleteState = #{deleteState,jdbcType=TINYINT}, createTime = #{createTime,jdbcType=TIMESTAMP}, updateTime = #{updateTime,jdbcType=TIMESTAMP}, where id = #{id,jdbcType=BIGINT}
1.2.2板块表更新数据
很明显这里肯定也是动态更新的过程:
update t_board name = #{name,jdbcType=VARCHAR}, articleCount = #{articleCount,jdbcType=INTEGER}, sort = #{sort,jdbcType=INTEGER}, state = #{state,jdbcType=TINYINT}, deleteState = #{deleteState,jdbcType=TINYINT}, createTime = #{createTime,jdbcType=TIMESTAMP}, updateTime = #{updateTime,jdbcType=TIMESTAMP}, where id = #{id,jdbcType=BIGINT}
1.2.3文章表发布数据
这里发布,那么就是往数据库中插入数据:
insert into t_article id, boardId, userId, title, visitCount, replyCount, likeCount, state, deleteState, createTime, updateTime, content, #{id,jdbcType=BIGINT}, #{boardId,jdbcType=BIGINT}, #{userId,jdbcType=BIGINT}, #{title,jdbcType=VARCHAR}, #{visitCount,jdbcType=INTEGER}, #{replyCount,jdbcType=INTEGER}, #{likeCount,jdbcType=INTEGER}, #{state,jdbcType=TINYINT}, #{deleteState,jdbcType=TINYINT}, #{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP}, #{content,jdbcType=LONGVARCHAR},
📚️2.Dao层的设计
这里很简单就是设计接口与数据库进行连接,种类小编将三种接口的设计一起写入到下方:
//板块数据的动态更新int updateByPrimaryKeySelective(Board record);//用户数据的动态更新 int updateByPrimaryKeySelective(User record);//文章的发布(插入)int insertSelective(Article record);
注意:每个方法的名字要和上述SQL在xml中的id要保持一致,不然会出现无法找到我们所需要的SQL语句来操作数据库;
📚️3.Service层的设计
🚀3.1用户service层
这里先规定service接口,在使用实现类进行实现
/** * 用户发布帖子后进行帖子数量的增加 * @param id */ void addOneArticleCountById(Long id);
对应的实现类的代码如下所示:
@Override public void addOneArticleCountById(Long id) { //校验参数 if(id == null || id <= 0){ log.warn(ResultCode.FAILED_BOARD_ARTICLE_COUNT.toString()); throw new ApplicationException(AppResult.fail(ResultCode.FAILED_BOARD_ARTICLE_COUNT)); } //进行获取对象 User user = userMapper.selectByPrimaryKey(id); //校验这里的对象是否存在 if(user == null){ log.warn(ResultCode.ERROR_IS_NULL.toString() + \", user id = \" + id); // 抛出异常 throw new ApplicationException(AppResult.fail(ResultCode.ERROR_IS_NULL)); } //然后通过更新这里的文章数量 User updataUser = new User(); updataUser.setId(user.getId()); updataUser.setArticleCount(user.getArticleCount() + 1); //更新 int result = userMapper.updateByPrimaryKeySelective(updataUser); if(result != 1){ log.warn(ResultCode.FAILED.toString()); throw new ApplicationException(AppResult.fail(ResultCode.FAILED)); } }
大体的步骤就是:对于id进行参数的校验,然后通过id拿到这里的用户的对象;再次进行非空的校验,最后就是设修改的对象,传入用户要修改的信息即可;那么最后一步就是判断这里的修改行数是否是1即可;
🚀3.2板块service层
大致和用户差不多,service实现类如下所示:
@Override public void addOneArticleCountById(Long id) { //首先判断id参数的合法性 if(id == null || id <= 0){ log.warn(\"没有找到对应的板块,id:\" + id); throw new ApplicationException(AppResult.fail(ResultCode.FAILED_BOARD_ARTICLE_COUNT)); } //根据id查询对应的板块 Board board = boardMapper.selectByPrimaryKey(id); //校验是否正确 if(board == null){ //此时板块为空 log.warn(ResultCode.ERROR_IS_NULL.toString()); throw new ApplicationException(AppResult.fail(ResultCode.ERROR_IS_NULL)); } //更新这里的文章的数量 Board updataBoard = new Board(); updataBoard.setId(board.getId()); updataBoard.setArticleCount(board.getArticleCount() + 1); int result = boardMapper.updateByPrimaryKeySelective(updataBoard); //判断这里的更新是否出现了的错误 if(result != 1){ log.warn(ResultCode.FAILED.toString()); throw new ApplicationException(AppResult.fail(ResultCode.FAILED)); } }
和用户板块差不多,那么这里抛出异常主要是为了事务进行准备;
🚀3.3文章service层
在接口中由于这里涉及三个表的设计,所以为了保证安全性,这里使用事务,保证三个数据库更改一起成功或者一起失败:
@Transactional void create(Article article);
那么至于service层代码来说:
public void create(Article article) { //进行参数的校验 if(article == null || article.getUserId() == null || article.getBoardId() == null || !StringUtils.hasLength(article.getContent()) || !StringUtils.hasLength(article.getTitle())){ log.warn(ResultCode.FAILED_PARAMS_VALIDATE.toString()); throw new ApplicationException(AppResult.fail(ResultCode.FAILED_PARAMS_VALIDATE)); } //设置默认值 article.setVisitCount(0); // 访问数 article.setReplyCount(0); // 回复数 article.setLikeCount(0); // 点赞数 article.setDeleteState((byte) 0); article.setState((byte) 0); Date date = new Date(); article.setCreateTime(date); article.setUpdateTime(date); //进行创建文章的操作 int result = articleMapper.insertSelective(article); if(result != 1){ throw new ApplicationException(AppResult.fail(ResultCode.FAILED_CREATE)); } //更新这里的用户表数据以及板块表数据 //这里要进行校验的操作,利用事务进行轮滚或者是提交 User user = userServiceImp.selectById(article.getUserId()); if(user == null){ throw new ApplicationException(AppResult.fail(ResultCode.FAILED_CREATE)); } userServiceImp.addOneArticleCountById(user.getId()); Board board = boardServiceImp.selectById(article.getBoardId()); if(board == null){throw new ApplicationException(AppResult.fail(ResultCode.FAILED_CREATE)); } boardServiceImp.addOneArticleCountById(board.getId()); }
大致就是在进行数据校验的判断后,设置要传递的对象实现数据修改,并进行是否成功的判断,然后对于两个板块和用户对象来说,这里还需要进行对应的service层方法的调用实现对应数据库的数据更改;(前提也是进行获得的对象的非空的校验);
这里上述三个service层来说一但抛出异常后,那么事务就会回滚,而不会提交 ,保证了数据的准确性以及正确性;
📚️4.Controller层的设计
这里是发表文章,牵连到三个数据库的设计,所以只需要设计发表文章的控制类即可
具体的代码如下所示:
@RequestMapping(value = \"/create\" ,method = RequestMethod.POST) public AppResult create(HttpServletRequest request, @RequestParam(\"boardId\") @NonNull Long boardId, @RequestParam(\"title\") @NonNull String title, @RequestParam(\"content\") @NonNull String content){ //判断用户是否禁言,用户对象从session中进行获取 HttpSession session = request.getSession(false); User user =(User) session.getAttribute(ContentConfig.USER_SESSION); if(user.getState() == 1){ //说明此时用户处于禁言的状态 return AppResult.fail(ResultCode.FAILED_USER_BANNED); } //设置传递参数 Article article = new Article(); article.setUserId(user.getId()); article.setBoardId(boardId); article.setContent(content); article.setTitle(title); articleServiceImp.create(article); return AppResult.success(\"发表文章成功\"); }
解释:首先设置路由,以及需要的方法,然后设置的三个参数来说,直接是使用lombok中的NunNull进行非空的校验,然后从session中获取用户对象,设置这里传递的对象,最后调用service层的代码即可;
📚️5.测试
最后我们使用pastman进行测试这里的代码,是否能成功修改我们的数据库:
注意:由于要使用这里的session来获取对象,那么我们首先进行登录,然后再进行测试:
那么此时我们检查一下我们navicat中的数据库:
很明显这里输入的2指的就是板块2,这里的文章数量很明显进行了加一的操作;
然后这里的文章板块也进行了对应的发布操作;
对应的用户发布的文章也进行了加一的操作;
📚️6.总结
本期主要讲解了关于发布文章,牵连的三个数据库表的设计操作,从SQL的编写到Dao层,Service层,Controller层的程序设计;以及最后的结果展示;
🌅🌅🌅~~~~最后希望与诸君共勉,共同进步!!!
💪💪💪以上就是本期内容了, 感兴趣的话,就关注小编吧。
😊😊 期待你的关注~~~