初识Java EE经典MVC框架Struts.rar

package com.struts.model; import java.sql.*; import javax.sql.*; import org.apache.struts.validator.DynaValidatorForm; import java.util.*; public class ProcessBean { //定义操作数据库所需的变量 DataSource ds = null; Connection con = null; Statement stat = null; PreparedStatement pstat = null; ResultSet rs = null; String sql = null; //构造函数，初始化数据库连接 public ProcessBean(DataSource ds){ try{ this.ds = ds; con = ds.getConnection(); }catch(Exception ex){ ex.printStackTrace(); } } //新增一个注册会员 public void addMember(DynaValidatorForm addMemberForm){ try{ sql = "insert into users(phone,password,address,username,email,birthday,regdate) values(?,?,?,?,?,?,?)"; pstat = con.prepareStatement(sql); pstat.setString(1,addMemberForm.get("phone").toString()); pstat.setString(2,addMemberForm.get("password").toString()); pstat.setString(3,addMemberForm.get("address").toString()); pstat.setString(4,addMemberForm.get("username").toString()); pstat.setString(5,addMemberForm.get("email").toString()); pstat.setDate(6,new java.sql.Date(new java.util.Date(addMemberForm.get("birthday").toString().replaceAll("-","/")).getTime())); pstat.setDate(7,new java.sql.Date(new java.util.Date().getTime())); pstat.executeUpdate(); }catch(Exception ex){ ex.printStackTrace(); } } //装载所有会员数据 public List allMember(){ List result = new ArrayList(); try{ sql = "select * from users order by id desc"; stat = con.createStatement(); rs = stat.executeQuery(sql); Map member = null; while (rs.next()){ member = new HashMap(); member.put("id",rs.getString("id").trim()); member.put("phone",rs.getString("phone").trim()); member.put("address",rs.getString("address").trim()); member.put("username",rs.getString("username").trim()); member.put("email",rs.getString("email").trim()); member.put("birthday",rs.getString("birthday").trim()); member.put("regdate",rs.getString("regdate").trim()); result.add(member); } }catch(Exception ex){ ex.printStackTrace(); } return result; } //删除会员 public void delMember(String id){ try{ sql = "delete from users where id="+id; stat = con.createStatement(); stat.executeUpdate(sql); }catch(Exception ex){ ex.printStackTrace(); } } //会员登录验证 public boolean loginCheck(String username,String password){ try{ sql = "select * from users where username=? and password=?"; pstat = con.prepareStatement(sql); pstat.setString(1,username); pstat.setString(2,password); rs = pstat.executeQuery(); if (rs.next())return true; else return false; }catch(Exception ex){ ex.printStackTrace(); return false; } } }