add.jsp
<body>
<!-- -->
<form action="<c:url value='/AddSerclet'/>" method="post">
姓 名：<input type="text" name="dname" /><br />
年 龄：<input type="text" name="age" /><br />
<input type="submit" value="确定" />
</form>
</body>
select.jsp
<body> <form action="<c:url value='/SelectServlet'/>" method="post"> 输入要查找的姓名：<input type="text" name="cname" /> <input type="submit" value="查找" /> </form> </body>
delete.jsp
<body> <form action="<c:url value='/DeleteServlet'/>" method="post"> 输入要删除的姓名：<input type="text" name="sname" /> <input type="submit" value="确定" /> </form> </body>
show.jsp
<body> <h3 align="center">查询结果</h3> <table align="center" border="1px" bordercolor="Blue"> <tr> <td>姓名</td> <td>年龄</td> </tr> <tr> <td><%=request.getAttribute("username") %></td> <td><%=request.getAttribute("userage") %></td> </tr> </table> <a href="/Jdbcuser/index.jsp" >返回主页</a> </body>
JdbcUserDaoImpl
package user.dao; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import javax.persistence.Temporal; import org.junit.Test; import com.mysql.jdbc.Connection; import user.domain.User; public class JdbcUserDaoImpl implements UserDao { public void JdbcInsert(User user) { Connection con = null; PreparedStatement pstmt = null; try { // 得到数据库的连接 con = JdbcUtils.getConnercion(); // 定义sql语句 得到pstmt String sql = "INSERT INTO d_user VALUES(?,?)"; pstmt = con.prepareStatement(sql); // 给sql语句中的问好赋值 pstmt.setString(1, user.getDname()); pstmt.setString(2, user.getAge()); // 执行sql语句 pstmt.executeUpdate(); } catch (Exception e) { throw new RuntimeException(e); } finally { // 关闭（倒关） try { if (pstmt != null) pstmt.close(); if (con != null) con.close(); } catch (SQLException e) { } } } public User findByUsername(String username) { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; try { // 得到数据库的连接 con = JdbcUtils.getConnercion(); // 定义sql语句 得到pstmt String sql = "SELECT * FROM d_user WHERE dname=?"; pstmt = con.prepareStatement(sql); // 给sql语句中的问好赋值 pstmt.setString(1, username); // 执行sql语句 rs = pstmt.executeQuery(); // 把rs转换成user类 if (rs == null) return null; if (rs.next()) { // 转换成user类 User user = new User(); user.setDname(rs.getString("dname")); user.setAge(rs.getString("age")); return user; } else { return null; } } catch (Exception e) { throw new RuntimeException(e); } finally { try { if (pstmt != null) pstmt.close(); if (con != null) con.close(); } catch (SQLException e) { } } } @Override public void DeleteUser(String username) { Connection con = null; PreparedStatement pstmt = null; try { // 得到数据库的连接 con = JdbcUtils.getConnercion(); // 定义sql语句 得到pstmt //DELETE FROM 表名 [WHERE 条件 String sql = "DELETE FROM d_user WHERE dname=?"; pstmt = con.prepareStatement(sql); // 给sql语句中的问好赋值 pstmt.setString(1, username); // 执行sql语句 pstmt.executeUpdate(); } catch (Exception e) { throw new RuntimeException(e); } finally { // 关闭（倒关） try { if (pstmt != null) pstmt.close(); if (con != null) con.close(); } catch (SQLException e) { } } } }
UserService
package user.service; import user.dao.DaoFactory; import user.dao.UserDao; import user.domain.User; public class UserService { private UserDao userDao = DaoFactory.getUserDao(); public void add(User user) { userDao.JdbcInsert(user); } public User FindByName(String username) { return userDao.findByUsername(username); } public void Delete(String username) { userDao.DeleteUser(username); } }
AddServlet
package user.web.servlet; import java.io.IOException; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import user.domain.User; import user.service.UserService; public class AddSerclet extends HttpServlet { public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { response.setContentType("text/html;charset=UTF-8");// 处理响应编码 request.setCharacterEncoding("UTF-8"); UserService userService = new UserService(); String dname = request.getParameter("dname"); String age = request.getParameter("age"); User form = new User(); form.setDname(dname); form.setAge(age); userService.add(form); response.getWriter().print( "<h1>添加成功</h1><br/><a href='http://localhost:8080" + request.getContextPath() + "/user/select.jsp" + "'>点击这里去查询页面</a>"); } }
SelectServlet
package user.web.servlet; import java.io.IOException; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import user.domain.User; import user.service.UserService; public class SelectServlet extends HttpServlet { public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { response.setContentType("text/html;charset=UTF-8");// 处理响应编码 request.setCharacterEncoding("UTF-8"); UserService userService = new UserService(); String cname = request.getParameter("cname"); User _user = userService.FindByName(cname); if (_user != null) { request.setAttribute("username", _user.getDname()); request.setAttribute("userage", _user.getAge()); request.getRequestDispatcher("/user/show.jsp").forward(request, response); } response.getWriter().print( "<h1>查询的结果不存在，请重新查询</h1><br/><a href='http://localhost:8080" + request.getContextPath() + "/user/select.jsp" + "'>点击这里去查询页面</a>"); } }
DeleteServlet
package user.web.servlet; import java.io.IOException; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import user.domain.User; import user.service.UserService; public class SelectServlet extends HttpServlet { public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { response.setContentType("text/html;charset=UTF-8");// 处理响应编码 request.setCharacterEncoding("UTF-8"); UserService userService = new UserService(); String cname = request.getParameter("cname"); User _user = userService.FindByName(cname); if (_user != null) { request.setAttribute("username", _user.getDname()); request.setAttribute("userage", _user.getAge()); request.getRequestDispatcher("/user/show.jsp").forward(request, response); } response.getWriter().print( "<h1>查询的结果不存在，请重新查询</h1><br/><a href='http://localhost:8080" + request.getContextPath() + "/user/select.jsp" + "'>点击这里去查询页面</a>"); } }
配置文件
