logo资料库

javaWeb-连接mysql数据库增删改查.docx

第1页 / 共30页
第2页 / 共30页
第3页 / 共30页
第4页 / 共30页
第5页 / 共30页
第6页 / 共30页
第7页 / 共30页
第8页 / 共30页
资料共30页,剩余部分请下载后查看
连接 MYSQL 数据库的简单增删改查 项目框架如图所示: 所需工具: 所需工具: 所需工具: 所需工具: 程序代码:package com.user.action;
import java.io.IOException; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.user.bean.UserBean; import com.user.dao.UserDao; public class InsertOrUpdateAction extends HttpServlet { /** * */ private static final long serialVersionUID = 1L; private UserDao userDao ; public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { doPost(request, response); } response) public void doPost(HttpServletRequest request, HttpServletResponse throws ServletException, IOException { request.setCharacterEncoding("utf-8"); response.setCharacterEncoding("utf-8"); userDao = new UserDao(); String str = request.getRequestURI(); str = str.substring(str.lastIndexOf("/")+1); String yx = request.getParameter("yx"); String zy = request.getParameter("zy"); String age = request.getParameter("age"); String dh = request.getParameter("dh"); String qq = request.getParameter("qq"); String sex = request.getParameter("sex"); UserBean userBean = new UserBean(); userBean.setYx(yx);
userBean.setZy(zy); if(!"".equals(age)&&age!=null) { userBean.setAge(Integer.valueOf(age)); }else{ userBean.setAge(0); } userBean.setDh(dh); userBean.setQq(qq); userBean.setSex(sex); if("InsertUserAction".equals(str)){ if(userDao.insertUser(userBean)){ response.sendRedirect("SelectAllUser"); response.sendRedirect("SelectAllUser"); }else{ } }else{ }else{ }else if("UpdateUserAction".equals(str)){ String strId = request.getParameter("id"); if(!"".equals(strId)&&strId!=null){ userBean.setId(Integer.valueOf(strId)); userBean.setId(-1); } if(userDao.updateUser(userBean)){ response.sendRedirect("SelectAllUser"); response.sendRedirect("SelectAllUser"); } } } } package com.user.action; import java.io.IOException; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; public class LoginAction extends HttpServlet { /** * */ private static final long serialVersionUID = 1L; public void doGet(HttpServletRequest request, HttpServletResponse throws ServletException, IOException { doPost(request, response); response) } response) public void doPost(HttpServletRequest request, HttpServletResponse throws ServletException, IOException { String name= request.getParameter("name"); String password = request.getParameter("password"); if("".equals(name)||"".equals(password)) { response.sendRedirect("/javaWebTest/index.jsp"); if("123".equals(name)&&"123".equals(password)) { response.sendRedirect("SelectAllUser"); }else{ }else{ response.sendRedirect("/javaWebTest/index.jsp"); } } } } package com.user.action; import java.io.IOException;
import java.util.List; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.user.bean.UserBean; import com.user.dao.UserDao; public class UserAction extends HttpServlet { /** * */ private static final long serialVersionUID = 1L; private UserDao userDao ; public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { doPost(request, response); } public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { request.setCharacterEncoding("utf-8"); response.setCharacterEncoding("utf-8"); userDao = new UserDao(); String str = request.getRequestURI(); str = str.substring(str.lastIndexOf("/")+1); if("SelectAllUser".equals(str.trim())) { List list = userDao.getAllUser(); request.setAttribute("UserList", list); request.getRequestDispatcher("/userList.jsp").forward(request, response); }else if("SelectOneUser".equals(str)) {
String strId = request.getParameter("id"); int id = Integer.valueOf(strId); UserBean userBean = userDao.selectUserById(id); request.setAttribute("userBean", userBean); request.getRequestDispatcher("/updateUser.jsp").forward(request, }else if("DeleteUserById".equals(str)){ String strId = request.getParameter("id"); int id = Integer.valueOf(strId); if(userDao.deleteUser(id)){ response.sendRedirect("SelectAllUser"); }else{ response.sendRedirect("SelectAllUser"); response); } } } } package com.user.dao; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.user.bean.UserBean; import com.util.DBUtils; public class UserDao { private DBUtils dbUtil; /** * 查询所有的 user * @return */ public List getAllUser() { dbUtil = new DBUtils(); List list = new ArrayList(); String sql = "select * from user"; ResultSet rs = dbUtil.exceteSQl(sql);
try { while(rs.next()) { int i =1; UserBean userBean = new UserBean(); userBean.setId(rs.getInt(i++)); userBean.setName(rs.getString(i++)); userBean.setYx(rs.getString(i++)); userBean.setZy(rs.getString(i++)); userBean.setAge(rs.getInt(i++)); userBean.setDh(rs.getString(i++)); userBean.setQq(rs.getString(i++)); userBean.setSex(rs.getString(i++)); list.add(userBean); } } catch (SQLException e) { e.printStackTrace(); dbUtil.close(); }finally{ } return list; } /** * 根据 id 查询 user * @param id * @return */ public UserBean selectUserById(int id){ dbUtil = new DBUtils(); UserBean userBean = new UserBean(); String sql = "select * from user where id = '"+id+"'"; ResultSet rs = dbUtil.exceteSQl(sql); try { if(rs.next()) { int i =1; userBean.setId(rs.getInt(i++)); userBean.setYx(rs.getString(i++)); userBean.setZy(rs.getString(i++)); userBean.setAge(rs.getInt(i++)); userBean.setDh(rs.getString(i++));
userBean.setQq(rs.getString(i++)); userBean.setSex(rs.getString(i++)); } } } catch (SQLException e) { e.printStackTrace(); return userBean; } /** * 插入用户 * @param userBean * @return */ public boolean insertUser(UserBean userBean){ if(row>0){ return true; } return false; } /** * 删除用户 * @param id * @return */ public boolean deleteUser(int id){ dbUtil = new DBUtils(); String sql = "insert into user (yx,zy,age,dh,qq,sex) values(?,?,?,?,?,?)"; int row = dbUtil.excete(sql, new Object[]{userBean.getYx(),userBean.getZy(),userBean.getAge(),userBean.getDh(),use rBean.getQq(),userBean.getSex()}); dbUtil = new DBUtils(); String sql = "delete from user where id = '"+id+ "'"; int row = dbUtil.excete(sql); if(row>0) { return true; } return false; } /** * 修改 user * @param userBean
分享到:
收藏