1. 编写index.jsp
1 <%@ page language="java" contentType="text/html; charset=UTF-8" 2 pageEncoding="UTF-8"%> 3 <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> 4 <html> 5 <head> 6 <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> 7 <title>Insert title here</title> 8 </head> 9 <body> 10 <form action="servlet/login?action=add" method="post"> 11 用户名:<input type="text" name="userName" /><br/> 12 密 码:<input type="password" name="passWd" /><br/> 13 年 龄:<input type="text" name="age" /><br/> 14 <input type="submit" /> 15 </form> 16 </body> 17 </html>
2. 设计数据库,确定po包、dao包、bo包、service包
2.1 设计数据库
2.2 确定po包,存放的是永久化对象,即与数据库的表一一对应。
userPO.java
1 package po; 2 3 import java.util.Date; 4 5 public class UserPO { 6 private String userName; 7 private String passWd; 8 private Date birthday; 9 10 public UserPO(){ 11 } 12 13 public UserPO(String userName, String passWd, Date birthday) { 14 super(); 15 this.userName = userName; 16 this.passWd = passWd; 17 this.birthday = birthday; 18 } 19 20 public String getUserName() { 21 return userName; 22 } 23 24 public void setUserName(String userName) { 25 this.userName = userName; 26 } 27 28 public String getPassWd() { 29 return passWd; 30 } 31 32 public void setPassWd(String passWd) { 33 this.passWd = passWd; 34 } 35 36 public Date getBirthday() { 37 return birthday; 38 } 39 40 public void setBirthday(Date birthday) { 41 this.birthday = birthday; 42 } 46 }
2.3 确定dao包,包里存的是操作数据的对象(对数据库的增删改查),一般有接口+实现+工具类.
- UserDAOI.java
1 package dao; 2 3 import java.util.List; 4 5 import po.UserPO; 6 7 public interface UserDAOI { 8 public boolean addUser(UserPO user); 9 public boolean delUser(String userName); 10 public boolean uptUser(UserPO user); 11 public List<UserPO> gets(); 12 13 }
- DBUtil.java
1 package dao; 2 3 import java.beans.PropertyVetoException; 4 import java.sql.Connection; 5 import java.sql.PreparedStatement; 6 import java.sql.ResultSet; 7 import java.sql.SQLException; 8 import java.text.DateFormat; 9 import java.util.ArrayList; 10 import java.util.List; 11 12 import com.mchange.v2.c3p0.ComboPooledDataSource; 13 14 import po.UserPO; 15 16 public class DBUtil { 17 public static ComboPooledDataSource dateSource; 18 19 static{ 20 dateSource=new ComboPooledDataSource(); 21 final String URL="jdbc:mysql://localhost:3306/user?useUnicode=true&characterEncoding=utf-8"; 22 final String USER="root"; 23 final String PASSWD=""; 24 final String Driver="com.mysql.jdbc.Driver"; 25 26 try { 27 dateSource.setDriverClass(Driver); 28 dateSource.setJdbcUrl(URL); 29 dateSource.setUser(USER); 30 dateSource.setPassword(PASSWD); 31 dateSource.setMaxPoolSize(100); 32 dateSource.setMinPoolSize(10); 33 dateSource.setMaxStatements(10000); 34 } catch (Exception e) { 35 e.printStackTrace(); 36 } 37 38 } 39 40 /** 41 * 42 * @return 连接池中的连接 43 */ 44 public static Connection getConn(){ 45 try { 46 return dateSource.getConnection(); 47 } catch (SQLException e) { 48 e.printStackTrace(); 49 } 50 return null; 51 } 52 53 /** 54 * 55 * 增删改方法 56 * @param sql sql语句 57 * @param list sql语句中的?值 58 * @return 59 */ 60 public static boolean cud(String sql,List<Object> list){ 61 boolean flag=false; 62 Connection conn=null; 63 PreparedStatement pstat=null; 64 try{ 65 conn=getConn(); 66 pstat=conn.prepareStatement(sql); 67 68 if(list!=null){ 69 for(int i=0;i<list.size();i++){ 70 pstat.setObject(i+1, list.get(i)); 71 } 72 } 73 74 int res=pstat.executeUpdate(); 75 if(res>0){ 76 flag=true; 77 } 78 79 80 }catch(Exception e){ 81 e.printStackTrace(); 82 }finally{ 83 close(conn, pstat, null); 84 } 85 86 87 return flag; 88 } 89 90 /** 91 * 关闭流 92 * @param conn 连接流 93 * @param pstat sql语句流 94 * @param res 结果集流 95 */ 96 public static void close(Connection conn,PreparedStatement pstat,ResultSet res){ 97 98 try{ 99 if(conn!=null) 100 { 101 conn.close(); 102 } 103 if(pstat!=null) 104 { 105 pstat.close(); 106 }if(res!=null) 107 { 108 res.close(); 109 } 110 } 111 catch(Exception e) 112 { 113 e.printStackTrace(); 114 } 115 116 117 } 118 119 /**查找数据库中所有po对象并返回list
*@param sql sql语句
*@param list 存放sql预处理语句中的?值
*/ 120 public static List<UserPO> gets(String sql,List<Object> list) { 121 List<UserPO> users=new ArrayList<UserPO>(); 122 UserPO user=null; 123 Connection conn=null; 124 PreparedStatement pstat=null; 125 ResultSet res=null; 126 try 127 { 128 conn=DBUtil.getConn(); 129 pstat=conn.prepareStatement(sql); 130 131 if(list!=null) 132 { 133 for(int i=0;i<list.size();i++) 134 { 135 pstat.setObject(i+1, list.get(i)); 136 } 137 138 } 139 140 141 142 res=pstat.executeQuery(); 143 144 while(res.next()) 145 { 146 user=new UserPO(); 147 user.setUserName(res.getString("userName")); 148 user.setBirthday(res.getDate("birthday")); 149 user.setPassWd(res.getString("passWd")); 150 users.add(user); 151 } 152 153 } 154 catch(Exception e) 155 { 156 e.printStackTrace(); 157 }finally 158 { 159 close(conn, pstat, res); 160 } 161 return users; 162 } 163 164 }
- UserDAOImpl.java
package dao; import java.awt.geom.CubicCurve2D; import java.sql.Connection; import java.sql.PreparedStatement; import java.util.ArrayList; import java.util.List; import po.UserPO; public class UserPOImpl implements UserDAOI { public boolean addUser(UserPO user) { String sql="insert into user values(?,?,?)"; List<Object> list=new ArrayList<Object>(); list.add(user.getUserName()); list.add(user.getPassWd()); list.add(user.getBirthday()); return DBUtil.cud(sql, list); } public boolean delUser(String userName) { String sql="delete from user where userName=?"; List<Object> list=new ArrayList<Object>(); list.add(userName); return DBUtil.cud(sql, list); } public boolean uptUser(UserPO user) { String sql="update user set passWd=?,birthday=? where userName=?"; List<Object> list=new ArrayList<Object>(); list.add(user.getPassWd()); list.add(user.getBirthday()); list.add(user.getUserName()); return DBUtil.cud(sql, list); } public List<UserPO> gets() { String sql="select * from user"; return DBUtil.gets(sql, null); } }
2.4 确定bo包,存放的是对象,即与用户提供的信息一一对应。
- userBO.java
1 package bo; 2 3 public class UserBO { 4 private String userName; 5 private String passWd; 6 private String age; 7 8 public UserBO() 9 { 10 11 } 12 13 public UserBO(String userName, String passWd, String age) { 14 super(); 15 this.userName = userName; 16 this.passWd = passWd; 17 this.age = age; 18 } 19 20 public String getUserName() { 21 return userName; 22 } 23 24 public void setUserName(String userName) { 25 this.userName = userName; 26 } 27 28 public String getPassWd() { 29 return passWd; 30 } 31 32 public void setPassWd(String passWd) { 33 this.passWd = passWd; 34 } 35 36 public String getAge() { 37 return age; 38 } 39 40 public void setAge(String age) { 41 this.age = age; 42 } 43 44 45 }
解析: bo对象与po对象不同点在于: bo对象是业务对象,存放的数据是用户直接提供的,以本题为例,用户数据为userName、passWd、age,bo对象成员属性也为这三个,而
po对象则是存放于数据库中的数据,即用户数据经过处理之后才能存放于数据库中(比如用户注册的age数据,如果数据库中直接存放age毫无意义,因为第二年的时候age+1,数据库管理员还得给每个age+1),po对象存放的数据为userName、passWd、birthday。
2.5 确定service包,将servlet得到的原始数据(即用户数据)转换为DAO包里的数据格式。
- userServiceI.java
1 package service; 2 3 import java.util.List; 4 5 import bo.UserBO; 6 7 public interface UserServiceI { 8 public boolean addUser(UserBO user); 9 public boolean delUser(String userName); 10 public boolean uptUser(UserBO user); 11 public List<UserBO> gets(); 12 }
- userServiceImpl.java
1 package service; 2 3 import java.util.ArrayList; 4 import java.util.Date; 5 import java.util.List; 6 7 import bo.UserBO; 8 import dao.UserPOImpl; 9 import po.UserPO; 10 11 public class UserServiceImpl implements UserServiceI { 12 UserPOImpl im=new UserPOImpl(); 13 14 public boolean addUser(UserBO user) { 15 16 return im.addUser(bo2po(user)); 17 } 18 19 public boolean delUser(String userName) { 20 im.delUser(userName); 21 return true; 22 } 23 24 public boolean uptUser(UserBO user) { 25 26 return im.uptUser(bo2po(user)); 27 } 28 29 public List<UserBO> gets() { 30 31 32 List<UserPO> poList=im.gets(); 33 34 return po2bo(poList); 35 } 36 37 /** 38 * 把BO对象转为PO对象,这个方法只适用于增加和修改操作 39 * 40 * @param user 41 * @return 42 */ 43 private UserPO bo2po(UserBO user) 44 { 45 46 UserPO userpo=new UserPO(); 47 48 Date date=new Date(); 49 @SuppressWarnings("deprecation") 50 int year=date.getYear(); //拿到今年第几年 51 int yearDB=year-Integer.parseInt(user.getAge()); //得到存入数据库的年份 52 @SuppressWarnings("deprecation") 53 Date date1=new Date(yearDB,date.getMonth(),date.getDay()); 54 55 userpo.setBirthday(date1); 56 userpo.setUserName(user.getUserName()); 57 userpo.setPassWd(user.getPassWd()); 58 59 return userpo; 60 } 61 /** 62 * 把存有PO对象的List转为存有BO对象的List 63 * 步骤: 64 * 1. 拿到存有PO对象的list容器之后,进行遍历 65 * 2. 每次遍历都要new一个BO对象,然后把PO对象的值对应转化为BO对象 66 * 3. 返回存放BO对象的list 67 * @param userpo 68 * @return BO对象 69 */ 70 private List<UserBO> po2bo(List<UserPO> poList) 71 { 72 List<UserBO> boList=new ArrayList<UserBO>(); 73 UserBO userbo=null; 74 for(int i=0;i<poList.size();i++) 75 { 76 userbo=new UserBO(); 77 userbo.setUserName(poList.get(i).getUserName()); 78 userbo.setPassWd(poList.get(i).getPassWd()); 79 Date birthday=poList.get(i).getBirthday(); 80 Date getYear=new Date(); 81 int age=getYear.getYear()-birthday.getYear(); 82 userbo.setAge(String.valueOf(age)); 83 84 boList.add(userbo); 85 } 86 87 return boList; 88 } 89 90 }
3. 编写servlet包
- LoginServlet.java
package srevlet; 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 bo.UserBO; import service.UserServiceImpl; public class LoginServlet extends HttpServlet { private static final long serialVersionUID = 1L; public LoginServlet() { super(); } protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { this.doPost(request, response); } protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { //拿到用户数据 UserBO user=null; UserServiceImpl userIm=new UserServiceImpl(); String userName=request.getParameter("userName"); String passWd=request.getParameter("passWd"); String age=request.getParameter("age"); String action=request.getParameter("action"); if(action.equals("add")) { //增加一条记录 user=new UserBO(); user.setUserName(userName); user.setPassWd(passWd); user.setAge(age); userIm.addUser(user); } if(action.equals("del")) { //删除一条记录 String name=request.getParameter("userName"); userIm.delUser(name); } if(action.equals("upt")) { user=new UserBO(); user.setAge(request.getParameter("age")); user.setPassWd(request.getParameter("passWd")); user.setUserName(request.getParameter("userName")); userIm.uptUser(user); } if(action.equals("gets")) { //拿到数据库的全部数据 List<UserBO> listbo=userIm.gets(); for(int i=0;i<listbo.size();i++) { System.out.println(listbo.get(i).getUserName()+" "+listbo.get(i).getAge()+" "+listbo.get(i).getPassWd()); } } } }
结果:
解析: 查看servlet 当action=del的时候,会执行servlet的相应操作,request.getParameter("userName"); 可以得到地址栏里的userName的值“nihao”,这样就可以从数据库中删除。