基于Servlet+Jsp+mysql实现的留言管理系统【源码+数据库】

package com.java1234.web; import java.io.IOException; import java.sql.Connection; import java.util.List; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpSession; import com.java1234.dao.MessageDao; import com.java1234.dao.UserDao; import com.java1234.entity.PageBean; import com.java1234.entity.User; import com.java1234.util.DbUtil; import com.java1234.util.PageUtil; import com.java1234.util.ResponseUtil; import com.java1234.util.StringUtil; /** * 用户Servlet实现类 * @author Administrator * */ public class UserServlet extends HttpServlet{ /** * */ private static final long serialVersionUID = 1L; DbUtil dbUtil=new DbUtil(); UserDao userDao=new UserDao(); MessageDao messageDao=new MessageDao(); @Override protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { this.doPost(request, response); } @Override protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { request.setCharacterEncoding("utf-8"); String action=request.getParameter("action"); if("login".equals(action)){ login(request,response); }else if("logout".equals(action)){ logout(request,response); }else if("register".equals(action)){ register(request,response); }else if("list".equals(action)){ list(request,response); }else if("preSave".equals(action)){ preSave(request,response); }else if("save".equals(action)){ save(request,response); }else if("delete".equals(action)){ delete(request,response); }else if("preModifyPassword".equals(action)){ preModifyPassword(request,response); }else if("modifyPassword".equals(action)){ modifyPassword(request,response); } } /** * 用户登录 * @param request * @param response * @throws ServletException * @throws IOException */ private void login(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String userName=request.getParameter("userName"); String password=request.getParameter("password"); HttpSession session=request.getSession(); Connection con=null; try{ con=dbUtil.getCon(); User user=new User(userName,password); User currentUser=userDao.login(con, user); if(currentUser==null){ request.setAttribute("error", "用户名或者密码错误！"); request.setAttribute("user", user); request.getRequestDispatcher("/login.jsp").forward(request, response); }else{ session.setAttribute("currentUser", currentUser); request.getRequestDispatcher("/index?action=list").forward(request, response); } }catch(Exception e){ e.printStackTrace(); }finally{ try { dbUtil.closeCon(con); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } /** * 用户注销 * @param request * @param response * @throws ServletException * @throws IOException */ private void logout(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { request.getSession().invalidate(); response.sendRedirect(request.getContextPath()+"/login.jsp"); } /** * 用户注册 * @param request * @param response * @throws ServletException * @throws IOException */ private void register(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String userName=request.getParameter("userName"); String password=request.getParameter("password"); String repassword=request.getParameter("repassword"); Connection con=null; try{ con=dbUtil.getCon(); User user=new User(userName,password); boolean flag=userDao.exist(con, userName); if(flag){ user.setRepassword(repassword); request.setAttribute("user", user); request.setAttribute("info", "用户名已经存在，请换一个试试！"); }else{ int n=userDao.add(con, user); if(n>0){ request.setAttribute("info", "恭喜，注册成功！"); }else{ request.setAttribute("info", "注册失败，请联系管理员！"); } } request.getRequestDispatcher("/register.jsp").forward(request, response); }catch(Exception e){ e.printStackTrace(); }finally{ try { dbUtil.closeCon(con); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } /** * 分页查询用户信息 * @param request * @param response * @throws ServletException * @throws IOException */ private void list(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String page=request.getParameter("page"); // 当前页 String s_userName=request.getParameter("s_userName"); // 搜索参数 用户名 if(StringUtil.isEmpty(page)){ page="1"; } User s_user=new User(); if(StringUtil.isNotEmpty(s_userName)){ s_user.setUserName(s_userName); }else{ s_userName=""; } Connection con=null; try{ con=dbUtil.getCon(); PageBean pageBean=new PageBean(Integer.parseInt(page),5); List<User> userList=userDao.list(con, s_user, pageBean); int total=userDao.getCount(con, s_user); request.setAttribute("userList", userList); request.setAttribute("pageCode", PageUtil.getPagation(request.getContextPath()+"/user?action=list&s_userName="+s_userName, total, Integer.parseInt(page), 5)); request.setAttribute("mainPage", "user/list.jsp"); request.setAttribute("modeName", "用户管理"); request.setAttribute("s_userName", s_userName); request.getRequestDispatcher("/admin/main.jsp").forward(request, response); }catch(Exception e){ e.printStackTrace(); }finally{ try { dbUtil.closeCon(con); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } /** * 添加或者修改用户信息 * @param request * @param response * @throws ServletException * @throws IOException */ private void save(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String id=request.getParameter("id"); // 编号 String userName=request.getParameter("userName"); // 用户名 String password=request.getParameter("password"); // 密码 User user=new User(userName,password); if(StringUtil.isNotEmpty(id)){ user.setId(Integer.parseInt(id)); } Connection con=null; try{ con=dbUtil.getCon(); if(StringUtil.isEmpty(id)){ userDao.add(con, user); }else{ userDao.update(con, user); } request.getRequestDispatcher("/user?action=list").forward(request, response); }catch(Exception e){ e.printStackTrace(); }finally{ try { dbUtil.closeCon(con); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } } /** * 修改用户密码 * @param request * @param response * @throws ServletException * @throws IOException */ private void modifyPassword(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String id=request.getParameter("id"); // 编号 String password=request.getParameter("password"); // 密码 User user=new User(); user.setId(Integer.parseInt(id)); user.setPassword(password); Connection con=null; boolean delFlag; try{ con=dbUtil.getCon(); int delNums=userDao.modifyPassword(con, user); if(delNums==1){ delFlag=true; }else{ delFlag=false; } ResponseUtil.write(response,delFlag); }catch(Exception e){ e.printStackTrace(); }finally{ try { dbUtil.closeCon(con); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTr