0


【JavaEE】博客系统【前后端分离版本】

笔记【博客系统】

测试网站:小孙的博客系统

  • 测试:admin
  • 测试:123456

实现一个网站,有两种典型的风格:

  1. 服务器渲染
  2. 客户端渲染(前后端分离)

所谓渲染,就是把一个动态页面给构造出来

页面的基本结构+里面的数据

引入前后端分离,就把前端工程师和后端工程师彻底分开了

往后端只是给前端返回数据据———(数据往往是json格式组织了),后端彻底不用关心页面结构和样式。

表白墙就是基于前后端分离的方式来开发的 表白墙

  1. 前端页面
  2. 约定前后端交互接口
  3. 实现服务器代码,处理请求,返回json数据
  4. 实现了客户端代码,发送请求,处理响应

博客系统

  1. 前端页面
  2. 博客系统服务器

准备工作

  1. idea创建maven项目
  2. 引入依赖servlet``````jackson`````` mysql

在这里插入图片描述

  1. 创建必要的目录结构

在这里插入图片描述

  1. 编写代码
  2. 打包部署(直接基于smart tomcat)
  3. 在浏览器中验证

MVC

V

在这里插入图片描述

把前端页面引入到项目中,直接拷贝到 webapp 目录下.

这些文件属于静态资源,后续打包部署的时候,这些静态资源也会一并打包部署。后续也就可以在浏览器中访问到了。


下面就是C和M了,我们先来实现Model层。

M

一、编写数据库的操作代码

  1. 创建数据库/表结构=>数据库设计 【根据需求】 - 博客列表页:显示博客的列表- 博客详情页:点击博客列表页,上面列出博客的条目,跳转到的页面,显示博客的完整内容- 登录页- 博客编辑页,基于editor.md 搞了一个markdown 编辑器 。 基于这个页面来发布博客。
  • 存储博客 当点击发布,博客发布到服务器上,就要被存起来
  • 获取博客 在博客列表页和博客详情页,能够拿到博客的内容
  • 还要能够进行登录校验

博客表+用户表

在这里插入图片描述

二、封装数据库操作

  • 创建DBUtil 完成封装数据库连接操作
  • 创建实体类–使用实体类来表示数据库中的一条记录

在这里插入图片描述

  • 封装针对数据的增删改查 - 提供增删改查这样的类,称为 DAO

在这里插入图片描述
在这里插入图片描述

完成上面的步骤,数据库的基本操作就准备好了。

接下来,我们就来实现服务器中的代码。(Model搞定,写Controller)


此时我们就需要阅读前后端交互接口。

C

针对给各个页面”约定前后端交互接口“,”编写服务器代码“,”编写客户端代码“

1.博客列表页

在页面加载对的时候,让页面通过Ajax访问服务器,获取到数据库中的博客数据,并且填到页面中!

1.1 约定前后端交互接口

  • 博客列表页 能够展示数据库中的博客列表- 请求 GET/blog- 响应 json格式:[{​ blogId :1,​ title:‘这是第一篇博客’,content:'这是博客正文',​ userId: 1,​ postTime :‘2022-05-21 20:00:00’},{​ blogId :2,​ title:‘这是第二篇博客’,content:'这是博客正文',​ userId: 1,​ postTime :‘2022-05-21 20:00:00’},]

接下来就编写服务器和客户端代码。

1.2 编写服务器代码

在这里插入图片描述

在构造响应时,这两行代码顺序不能颠倒!!!

在这里插入图片描述

设置返回时间格式

Linux Shell

M 表示分钟 m 表示月份 h 表示24小时制的 小时

1.3 编写客户端代码

在这里插入图片描述

2.博客详情页

获取博客详情页,发送对的请求,页面显示当前这个给博客的正文内容

通过Ajax来进行获取

2.1 约定前后端交互接口

  • 博客列表页 能够展示数据库中的博客列表- 请求 GET/blog?blogId=1- 响应 HTTP/1.1 200 OKjson格式:{blogId:1,title:'这是第一篇博客', content:'这是博客正文', userId:1,postTime:'2022-05-21 20:00:00'}

接下来就编写服务器和客户端代码。

2.2 编写服务器代码

在这里插入图片描述

当进行程序验证的时候,要时刻牢记,浏览器缓存可能会影响到结果。

在这里插入图片描述

2.3 编写客户端代码

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ypIT68Eo-1669714405451)(C:\Users\17512\AppData\Roaming\Typora\typora-user-images\1668844867105.png)]

3.登录页

3.1 约定前后端交互接口

  • 博客列表页 能够展示数据库中的博客列表- 请求 POST/login- Content-Type:application/x-www-from-urlencoded- username=zhangsan&password=123- 响应HTTP/1.1 302 [登录成功跳转到博客列表页]Location:blog_list.html

在这里插入图片描述

接下来就编写服务器和客户端代码。

3.2 编写服务器代码

在这里插入图片描述

3.3 编写客户端代码

在这里插入图片描述

4.检测用户登录状态

在博客列表页/详情页加载的时候,通过ajax访问一下服务器,获取当前的登录状态,看能不能获取到?

如果获取到了,就说明以及登录,此时就可以留在这个页面了,否则跳转到登录页面。

约定前后端交互接口

请求:

GET/login

响应:

HTTP/1.1 200 OK

Content-Type:application/json

{

​ userId:1,

​ username:‘zahngsan’

}

登录了就直接返回当前登录的用户信息

未登录就直接返回一个userId为0的对象(也可以使用403来表示当前未登录)

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

5.能够正确显示用户信息

在这里插入图片描述

  • 在博客列表页显示用户信息就是当前登录的用户信息
  • 在博客详情页显示当前文章的作者信息
  • 登录的用户与文章作者可能是一个人,有可能不是一个人

针对博客列表页

在这里插入图片描述

在这里插入图片描述

目前只实现了用户名根据登录用户名更新。文章、分类、gitee链接、头像在实现上方法也是一样的。

针对博客详情页

在这里插入图片描述

在这里插入图片描述

设置新接口,让客户端指定blogId,获取指定blogId的作者信息

请求:

GET/authorInfo?blogId=4

响应:

{

​ userId :3;

​ username:‘金雷’

}

用 postman 发送一个get请求测试接口

在这里插入图片描述

为了安全期间,让密码隐藏起来。

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

服务器端代码:

在这里插入图片描述

客户端代码:

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-qX90DO5u-1669714405461)(C:\Users\17512\AppData\Roaming\Typora\typora-user-images\1669165459341.png)]

6.实现“注销”功能

当用户点击注销之后,就会在服务器是取消登录状态,并且能够跳转到登录页面。

约定前后端间交互接口

请求:

GET/logout

响应:

HTTP/1.1 302

Location:login.html

注销逻辑的服务器代码

在这里插入图片描述

检测登录状态的代码之前有,要求同时具备user属性和session对象,才可实现登录,而注销则是移除user属性,所以就不在登录状态了。
在这里插入图片描述

注销逻辑客户端代码

在这里插入图片描述

上述核心逻辑

  1. 约定前后端交互接口
  2. 实现服务器代码a. 写controller层,写servlet来实现apib. 写model层,通过jdbc来操作数据据
  3. 实现客户端代码ajax/from/a标签跳转

7.实现发布博客

在这里插入图片描述

约定前后端接口

请求:

POST/blog

Context-Type:application/x-www-form-urlencoded

tittle=这是标题&content=这是正文 【urlencoded】

响应:

HTTP/1.1 302

Location:blog_list.html

实现服务器代码,在BlogServlet里面吗添加一个doPost方法,来处理上述post请求

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-uKy2Gd0A-1669714405463)(C:\Users\17512\AppData\Roaming\Typora\typora-user-images\1669167684333.png)]

实现客户端代码

在这里插入图片描述

点击发布文章按钮
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-i7Ad6TAN-1669714405464)(C:\Users\17512\AppData\Roaming\Typora\typora-user-images\1669169430510.png)]

点击查看全文

在这里插入图片描述

8.删除博客

约定:自己删除自己的博客(此处不考虑管理员)

界面处理

在博客详情页,判断当前博客的作者是否就是登录的用户,如果是,就在导航栏里显示删除按钮,如果不是就不显示。外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传![(img-Wu08pLrx-1669714405465)(C:\Users\17512\AppData\Roaming\Typora\typora-user-images\1669169949912.png)]

服务器处理

用户点击删除按钮,触发一个HTTP请求,HTTP请求会让服务器删除指定的博客

服务器收到请求之后,就会把这个博客从数据库中删除

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-IhZP25Ft-1669714405465)(C:\Users\17512\AppData\Roaming\Typora\typora-user-images\1669171437720.png)]

当前登录用户为 金雷

所以[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-r9rremlx-1669714405466)(C:\Users\17512\AppData\Roaming\Typora\typora-user-images\1669171480750.png)]

请求:

GET/blogDelete?blogId=9

响应:

直接跳转到 博客列表页 即可

在这里插入图片描述
在这里插入图片描述

删除博客测试

在这里插入图片描述
在这里插入图片描述

博客列表中就不存在 111 的博客。

结语

到这也就差不多完成了一个简单的博客系统【增删改查的的功能】

MySQL,JDBC, Servlet,Http,Ajax,JS

配置目录结构

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-czmqi1FP-1669714405467)(C:\Users\17512\AppData\Roaming\Typora\typora-user-images\1669172504317.png)]

源代码:

AuthorServlet

packagecontroller;importcom.fasterxml.jackson.databind.ObjectMapper;importmodel.Blog;importmodel.BlogDao;importmodel.User;importmodel.UserDao;importjavax.servlet.ServletException;importjavax.servlet.annotation.WebServlet;importjavax.servlet.http.HttpServlet;importjavax.servlet.http.HttpServletRequest;importjavax.servlet.http.HttpServletResponse;importjava.io.IOException;@WebServlet("/authorInfo")publicclassAuthorServletextendsHttpServlet{privateObjectMapper objectMapper =newObjectMapper();@OverrideprotectedvoiddoGet(HttpServletRequest req,HttpServletResponse resp)throwsServletException,IOException{
        resp.setContentType("application/json;charset=utf-8");String param = req.getParameter("blogId");if(param ==null||"".equals(param)){
            resp.getWriter().write("{\"ok\":false,\"reason\":\"当前参数缺失\"}");return;}BlogDao blogDao =newBlogDao();Blog blog = blogDao.selectOne(Integer.parseInt(param));if(blog ==null){
            resp.getWriter().write("{\"ok\":false,\"reason\":\"当前查询博客不存在\"}");return;}UserDao userDao =newUserDao();User author = userDao.selectById(blog.getUserId());if(author ==null){
            resp.getWriter().write("{\"ok\":false,\"reason\":\"当前查询用户不存在\"}");return;}//把author 信息返回到浏览器中
        author.setPassword("");
        resp.getWriter().write(objectMapper.writeValueAsString(author));}}

BlogDeleteServlet

packagecontroller;importmodel.Blog;importmodel.BlogDao;importmodel.User;importjavax.servlet.ServletException;importjavax.servlet.annotation.WebServlet;importjavax.servlet.http.HttpServlet;importjavax.servlet.http.HttpServletRequest;importjavax.servlet.http.HttpServletResponse;importjavax.servlet.http.HttpSession;importjava.io.IOException;@WebServlet("/blogDelete")publicclassBlogDeleteServletextendsHttpServlet{@OverrideprotectedvoiddoGet(HttpServletRequest req,HttpServletResponse resp)throwsServletException,IOException{// 1. 检查当前用户是否登录HttpSession session = req.getSession(false);if(session ==null){
            resp.setContentType("text/html; charset=utf8");
            resp.getWriter().write("当前尚未登录, 不能删除!");return;}User user =(User) session.getAttribute("user");if(user ==null){
            resp.setContentType("text/html; charset=utf8");
            resp.getWriter().write("当前尚未登录, 不能删除!");return;}// 2. 获取到参数中的 blogIdString blogId = req.getParameter("blogId");if(blogId ==null||"".equals(blogId)){
            resp.setContentType("text/html; charset=utf8");
            resp.getWriter().write("当前 blogId 参数不对!");return;}// 3. 获取要删除的博客信息.BlogDao blogDao =newBlogDao();Blog blog = blogDao.selectOne(Integer.parseInt(blogId));if(blog ==null){
            resp.setContentType("text/html; charset=utf8");
            resp.getWriter().write("当前要删除的博客不存在!");return;}// 4. 再次校验, 当前的用户是否就是博客的作者if(user.getUserId()!= blog.getUserId()){// 这一点在前端这里其实也处理过~~ 但是此处还是再校验一次, 不是坏事!!!
            resp.setContentType("text/html; charset=utf8");
            resp.getWriter().write("当前登录的用户不是作者, 没有权限删除!");return;}// 5. 确认无误, 开始删除
        blogDao.delete(Integer.parseInt(blogId));// 6. 重定向到博客列表页
        resp.sendRedirect("blog_list.html");}}

BlogServlet

packagecontroller;importcom.fasterxml.jackson.databind.ObjectMapper;importmodel.Blog;importmodel.BlogDao;importmodel.User;importjavax.servlet.ServletException;importjavax.servlet.annotation.WebServlet;importjavax.servlet.http.HttpServlet;importjavax.servlet.http.HttpServletRequest;importjavax.servlet.http.HttpServletResponse;importjavax.servlet.http.HttpSession;importjava.io.IOException;importjava.util.List;// 通过这个类, 来处理 /blog 路径对应的请求@WebServlet("/blog")publicclassBlogServletextendsHttpServlet{privateObjectMapper objectMapper =newObjectMapper();// 这个方法用来获取到数据库中的博客列表.@OverrideprotectedvoiddoGet(HttpServletRequest req,HttpServletResponse resp)throwsServletException,IOException{
        resp.setContentType("application/json; charset=utf8");BlogDao blogDao =newBlogDao();// 先尝试获取到 req 中的 blogId 参数. 如果该参数存在, 说明是要请求博客详情// 如果该参数不存在, 说明是要请求博客的列表.String param = req.getParameter("blogId");if(param ==null){// 不存在参数, 获取博客列表List<Blog> blogs = blogDao.selectAll();// 把 blogs 对象转成 JSON 格式.String respJson = objectMapper.writeValueAsString(blogs);
            resp.getWriter().write(respJson);}else{// 存在参数, 获取博客详情int blogId =Integer.parseInt(param);Blog blog = blogDao.selectOne(blogId);String respJson = objectMapper.writeValueAsString(blog);
            resp.getWriter().write(respJson);}}@OverrideprotectedvoiddoPost(HttpServletRequest req,HttpServletResponse resp)throwsServletException,IOException{HttpSession session = req.getSession(false);if(session ==null){// 当前用户未登录, 不能提交博客!
            resp.setContentType("text/html;charset=utf8");
            resp.getWriter().write("当前用户未登录, 不能提交博客!");return;}User user =(User) session.getAttribute("user");if(user ==null){// 当前用户未登录, 不能提交博客!
            resp.setContentType("text/html;charset=utf8");
            resp.getWriter().write("当前用户未登录, 不能提交博客!");return;}// 一定要先指定好请求按照哪种编码来解析
        req.setCharacterEncoding("utf8");// 先从请求中, 取出参数(博客的标题和正文)String title = req.getParameter("title");String content = req.getParameter("content");if(title ==null||"".equals(title)|| content ==null||"".equals(content)){// 直接告诉客户端, 请求参数不对
            resp.setContentType("text/html;charset=utf8");
            resp.getWriter().write("提交博客失败! 缺少必要的参数!");return;}// 构造 Blog 对象, 把当前的信息填进去, 并插入数据库中// 此处要给 Blog 设置的属性, 主要是 title, content, userId (作者信息)// postTime 和 blogId 都不需要手动指定, 都是插入数据库的时候自动生成的.Blog blog =newBlog();
        blog.setTitle(title);
        blog.setContent(content);// 作者 id 就是当前提交这个博客的用户的身份信息!!
        blog.setUserId(user.getUserId());BlogDao blogDao =newBlogDao();
        blogDao.insert(blog);// 重定向到, 博客列表页!
        resp.sendRedirect("blog_list.html");}}

LoginServlet

packagecontroller;importcom.fasterxml.jackson.databind.ObjectMapper;importmodel.User;importmodel.UserDao;importjavax.servlet.ServletException;importjavax.servlet.annotation.WebServlet;importjavax.servlet.http.HttpServlet;importjavax.servlet.http.HttpServletRequest;importjavax.servlet.http.HttpServletResponse;importjavax.servlet.http.HttpSession;importjava.io.IOException;@WebServlet("/login")publicclassLoginServletextendsHttpServlet{privateObjectMapper objectMapper =newObjectMapper();@OverrideprotectedvoiddoPost(HttpServletRequest req,HttpServletResponse resp)throwsServletException,IOException{
        req.setCharacterEncoding("utf8");
        resp.setCharacterEncoding("utf8");// 1. 获取到请求中的参数String username = req.getParameter("username");String password = req.getParameter("password");System.out.println("username="+ username +", password="+ password);if(username ==null||"".equals(username)|| password ==null||"".equals(password)){// 请求的内容缺失, 肯定是登录失败!!
            resp.setContentType("text/html; charset=utf8");
            resp.getWriter().write("当前的用户名或密码为空!");return;}// 2. 和数据库中的内容进行比较UserDao userDao =newUserDao();User user = userDao.selectByName(username);if(user ==null||!user.getPassword().equals(password)){// 用户没有查到或者密码不匹配, 也是登录失败!
            resp.setContentType("text/html; charset=utf8");
            resp.getWriter().write("用户名或密码错误!");return;}// 3. 如果比较通过, 就创建会话.HttpSession session = req.getSession(true);// 把刚才的用户信息, 存储到会话中.
        session.setAttribute("user", user);// 4. 返回一个重定向报文, 跳转到博客列表页.
        resp.sendRedirect("blog_list.html");}// 这个方法用来让前端检测当前的登录状态.@OverrideprotectedvoiddoGet(HttpServletRequest req,HttpServletResponse resp)throwsServletException,IOException{
        resp.setContentType("application/json;charset=utf8");HttpSession session = req.getSession(false);if(session ==null){// 检测下会话是否存在, 不存在说明未登录!User user =newUser();
            resp.getWriter().write(objectMapper.writeValueAsString(user));return;}User user =(User) session.getAttribute("user");if(user ==null){// 虽然有会话, 但是会话里没有 user 对象, 也视为未登录.
            user =newUser();
            resp.getWriter().write(objectMapper.writeValueAsString(user));return;}// 已经登录的状态!!// 注意, 此处不要把密码给返回到前端~~
        user.setPassword("");
        resp.getWriter().write(objectMapper.writeValueAsString(user));}}

LogoutServlet

packagecontroller;importjavax.servlet.ServletException;importjavax.servlet.annotation.WebServlet;importjavax.servlet.http.HttpServlet;importjavax.servlet.http.HttpServletRequest;importjavax.servlet.http.HttpServletResponse;importjavax.servlet.http.HttpSession;importjava.io.IOException;@WebServlet("/logout")publicclassLogoutServletextendsHttpServlet{@OverrideprotectedvoiddoGet(HttpServletRequest req,HttpServletResponse resp)throwsServletException,IOException{HttpSession session  =  req.getSession(false);if(session==null){
            resp.getWriter().write("当前用户尚未登录无法注销!");return;}

        session.removeAttribute("user");
        resp.sendRedirect("blog_login.html");}}

Blog

packagemodel;importjava.sql.Timestamp;importjava.text.SimpleDateFormat;//每个Blog对应blog表中的每一条记录publicclassBlog{privateint blogId;privateString title;privateString content;privateint userId;privateTimestamp postTime;publicintgetBlogId(){return blogId;}publicvoidsetBlogId(int blogId){this.blogId = blogId;}publicStringgetTitle(){return title;}publicvoidsetTitle(String title){this.title = title;}publicStringgetContent(){return content;}publicvoidsetContent(String content){this.content = content;}publicintgetUserId(){return userId;}publicvoidsetUserId(int userId){this.userId = userId;}//    public Timestamp getPostTime() {//        return postTime;//    }//不返回时间戳 返回一个 String(格式化好的时间)publicStringgetPostTime(){//使用 SimpleDateFormat 完成世纪初格式化日期时间的转化SimpleDateFormat simpleDateFormat =newSimpleDateFormat("yyyy-MM-dd HH:mm:ss");return simpleDateFormat.format(postTime);}publicvoidsetPostTime(Timestamp postTime){this.postTime = postTime;}}

BlogDao

packagemodel;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.sql.SQLException;importjava.util.ArrayList;importjava.util.List;// 这个类用于去封装博客表的基本操作publicclassBlogDao{// 1. 往博客表里, 插入一个博客.publicvoidinsert(Blog blog){// JDBC 基本代码~~Connection connection =null;PreparedStatement statement =null;try{// 1) 和数据库建立连接.
            connection =DBUtil.getConnection();// 2) 构造 SQL 语句String sql ="insert into blog values(null, ?, ?, ?, now())";
            statement = connection.prepareStatement(sql);
            statement.setString(1, blog.getTitle());
            statement.setString(2, blog.getContent());
            statement.setInt(3, blog.getUserId());// 3) 执行 SQL
            statement.executeUpdate();}catch(SQLException e){
            e.printStackTrace();}finally{// 4) 关闭连接, 释放资源DBUtil.close(connection, statement,null);}}// 2. 能够获取到博客表中的所有博客的信息 (用于在博客列表页, 此处每篇博客不一定会获取到完整的正文)publicList<Blog>selectAll(){List<Blog> blogs =newArrayList<>();Connection connection =null;PreparedStatement statement =null;ResultSet resultSet =null;try{
            connection =DBUtil.getConnection();String sql ="select * from blog order by postTime desc";
            statement = connection.prepareStatement(sql);
            resultSet = statement.executeQuery();while(resultSet.next()){Blog blog =newBlog();
                blog.setBlogId(resultSet.getInt("blogId"));
                blog.setTitle(resultSet.getString("title"));// 这里需要针对内容进行截断(太长了, 就去掉后面)String content = resultSet.getString("content");// 这个 50 纯属拍脑门出来的!! 这个数字具体写多少, 都可以灵活应对!!if(content.length()>50){
                    content = content.substring(0,50)+"...";}
                blog.setContent(content);
                blog.setUserId(resultSet.getShort("userId"));
                blog.setPostTime(resultSet.getTimestamp("postTime"));
                blogs.add(blog);}}catch(SQLException throwables){
            throwables.printStackTrace();}finally{DBUtil.close(connection, statement, resultSet);}return blogs;}// 3. 能够根据博客 id 获取到指定的博客内容 (用于在博客详情页)publicBlogselectOne(int blogId){Connection connection =null;PreparedStatement statement =null;ResultSet resultSet =null;try{
            connection =DBUtil.getConnection();String sql ="select * from blog where blogId = ?";
            statement = connection.prepareStatement(sql);
            statement.setInt(1, blogId);
            resultSet = statement.executeQuery();// 此处我们是使用 主键 来作为查询条件的. 查询结果, 要么是 1 , 要么是 0.if(resultSet.next()){Blog blog =newBlog();
                blog.setBlogId(resultSet.getInt("blogId"));
                blog.setTitle(resultSet.getString("title"));
                blog.setContent(resultSet.getString("content"));
                blog.setUserId(resultSet.getShort("userId"));
                blog.setPostTime(resultSet.getTimestamp("postTime"));return blog;}}catch(SQLException throwables){
            throwables.printStackTrace();}finally{DBUtil.close(connection, statement, resultSet);}returnnull;}// 4. 从博客表中, 根据博客 id 删除博客.publicvoiddelete(int blogId){Connection connection =null;PreparedStatement statement =null;try{
            connection =DBUtil.getConnection();String sql ="delete from blog where blogId = ?";
            statement = connection.prepareStatement(sql);
            statement.setInt(1, blogId);
            statement.executeUpdate();}catch(SQLException throwables){
            throwables.printStackTrace();}finally{DBUtil.close(connection, statement,null);}}// 注意, 上述操作是 增删查, 没有改~~}

DBUtil

packagemodel;//使用这个类建立数据库连接importcom.mysql.jdbc.jdbc2.optional.MysqlDataSource;importjavax.sql.DataSource;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.sql.SQLException;publicclassDBUtil{privatestaticfinalStringURL="jdbc:mysql://127.0.0.1:3306/blog_system?characterEncoding=utf8&useSSL=false";privatestaticfinalStringUSERNAME="root";privatestaticfinalStringPASSWORD="111111";//连接流程privatestaticvolatileDataSource dataSource =null;privatestaticDataSourcegetDataSource(){if(dataSource==null){synchronized(DBUtil.class){if(dataSource ==null){
                    dataSource =newMysqlDataSource();((MysqlDataSource) dataSource).setUrl(URL);((MysqlDataSource) dataSource).setUser(USERNAME);((MysqlDataSource) dataSource).setPassword(PASSWORD);}}}return dataSource;}publicstaticConnectiongetConnection()throwsSQLException{returngetDataSource().getConnection();}//关闭流程publicstaticvoidclose(Connection connection,PreparedStatement statement,ResultSet resultSet){if(resultSet!=null){try{
                resultSet.close();}catch(SQLException e){
                e.printStackTrace();}}if(statement!=null){try{
                statement.close();}catch(SQLException e){
                e.printStackTrace();}}if(connection!=null){try{
                connection.close();}catch(SQLException e){
                e.printStackTrace();}}}}

User

packagemodel;//每个User对象表示user表中的一条记录publicclassUser{privateint userId =0;privateString username ="";privateString password ="";publicintgetUserId(){return userId;}publicvoidsetUserId(int userId){this.userId = userId;}publicStringgetUsername(){return username;}publicvoidsetUsername(String username){this.username = username;}publicStringgetPassword(){return password;}publicvoidsetPassword(String password){this.password = password;}}

UserDao

packagemodel;importjava.sql.Connection;importjava.sql.PreparedStatement;importjava.sql.ResultSet;importjava.sql.SQLException;//用于封装用户表的基本操作publicclassUserDao{// 需要实现的操作//针对这个类简化 注册/注销功能 未考虑// 主要实现// 1. 根据用户名查找用户信息 会在登录逻辑中使用publicUserselectByName(String username){Connection connection =null;PreparedStatement statement =null;ResultSet resultSet =null;try{
            connection =DBUtil.getConnection();String sql ="select * from user where username =?";
            statement = connection.prepareStatement(sql);
            statement.setString(1,username);
            resultSet = statement.executeQuery();//此处username使用unique约数if(resultSet.next()){User user =newUser();
                user.setUserId(resultSet.getInt("userId"));
                user.setUsername(resultSet.getString("username"));
                user.setPassword(resultSet.getString("password"));return user;}}catch(SQLException e){
            e.printStackTrace();}finally{DBUtil.close(connection,statement,resultSet);}returnnull;}// 2. 根据用户id来找用户信息,会在博客详情页根据用户id查询作者名字,把作者名字显示出来。publicUserselectById(int userId){Connection connection =null;PreparedStatement statement =null;ResultSet resultSet =null;try{
            connection =DBUtil.getConnection();String sql ="select * from user where userId =?";
            statement = connection.prepareStatement(sql);
            statement.setInt(1,userId);
            resultSet = statement.executeQuery();//此处username使用unique约数if(resultSet.next()){User user =newUser();
                user.setUserId(resultSet.getInt("userId"));
                user.setUsername(resultSet.getString("username"));
                user.setPassword(resultSet.getString("password"));return user;}}catch(SQLException e){
            e.printStackTrace();}finally{DBUtil.close(connection,statement,resultSet);}returnnull;}}

前端部分放到了我的码云https://gitee.com/sun-yuhang-bite/blog-system-project


本文转载自: https://blog.csdn.net/weixin_53939785/article/details/128102197
版权归原作者 小孙的代码分享 所有, 如有侵权,请联系我们删除。

“【JavaEE】博客系统【前后端分离版本】”的评论:

还没有评论