usermanager.java

JavaBean+Jsp 开发的《手机商城系统》

package com.test.ps.user;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.sql.Connection;
import java.util.ArrayList;


import com.test.ps.util.DBUtil;


public class userManager 
{   
	//private static final userManager usermanager=new userManager();
	private static userManager usermanager=null;
	DBUtil db=new DBUtil();
	int rowsPerpage=4;//显示用户页面每页行数
	private userManager()
	{
		
	}
	public static userManager getUserManager()
	{
		if(usermanager==null)
			usermanager=new userManager();
		return usermanager;
	}
	public boolean userCheck(userBean user)
	{
		ResultSet rs=DBUtil.getResult("select* from users where username='"+user.getUserName()+"'");
		//System.out.println("test1");
		try {
			if(rs.next())
				//System.out.println("test2");
				return false;
		 } catch (SQLException e) {
			// System.out.println("test3");
			e.printStackTrace();
		 }
			    return true;
	}
	public boolean addUser(userBean user)//用户注册
	{   	
		   Connection con= DBUtil.getConnection();
		        if(userCheck(user))		        
		        {    
		        	//System.out.println("test1");
		        	
		        	String sql="insert into users(username,password,sex,phone,email,address,rdate,zipcode) values(?,?,?,?,?,?,?,?)";
				      PreparedStatement pstmt;
					try {
						//System.out.println("test2");
						  pstmt = con.prepareStatement(sql);
						  pstmt.setString(1, user.getUserName());
					      pstmt.setString(2, user.getpassword());
					      pstmt.setString(3, user.getSex());
					      pstmt.setString(4, user.getPhone());
					      pstmt.setString(5, user.getEmail());
					      pstmt.setString(6, user.getAddress());
					      pstmt.setString(7, user.getRdate() );
					      pstmt.setString(8, user.getZipCode());
					      pstmt.executeUpdate();
					    } catch (SQLException e) 
					      {
					    	//System.out.println("test3");
						        e.printStackTrace();
					      }				     				        
				       	return true;
				 }	
		      
		    return false ;      
	}
	
    public boolean checkLogon(String username,String password) //会员登录
    {   
    	//System.out.println("test5");
    	ResultSet rs=DBUtil.getResult("select username,password from users where username='"+username+"'");
    	
    	try {
			if(rs.next())
			{			
				try {
					    if(password.equals(rs.getString("password")))
					    {					    	
					    	return true;
					    }						
					 } 
				  catch (Exception e) 
				    {						
						e.printStackTrace();
					}
				return false;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		   
	 return false;
    }
    public void changeInfo(userBean user)//修改用户信息
    {

		   Connection con= DBUtil.getConnection();   
		        	//System.out.println("test1");
		        	
		        	String sql="update users set sex=?,phone=?,email=?,address=?,rdate=?,zipcode=? where username='"+user.getUserName()+"'";
		        	//System.out.println(sql);
				      PreparedStatement pstmt;
					try {
						//System.out.println("test2");
						  pstmt = con.prepareStatement(sql);
						 // pstmt.setString(1, user.getUserName());
					      //pstmt.setString(1, user.getpassword());
					      pstmt.setString(1, user.getSex());
					      pstmt.setString(2, user.getPhone());
					      pstmt.setString(3, user.getEmail());
					      pstmt.setString(4, user.getAddress());
					      pstmt.setString(5, user.getRdate() );
					      pstmt.setString(6, user.getZipCode());
					      pstmt.executeUpdate();
					    } catch (SQLException e) 
					      {
					    	//System.out.println("test3");
						        e.printStackTrace();
					      }			        				       	      		    
    }
    public void changePassword(String username,String password) // 修改密码
	{
    	 Connection con= DBUtil.getConnection(); 
    	 String sql="update users set password=? where username='"+username+"'";
    	  PreparedStatement pstmt;
			try {
				//System.out.println("test2");
				  pstmt = con.prepareStatement(sql);
		          pstmt.setString(1, password);
			    
			      pstmt.executeUpdate();
			    } catch (SQLException e) 
			      {
			    	//System.out.println("test3");
				        e.printStackTrace();
			      }
		     
		        
		       	
			    //System.out.println("test4");

	
	
	}
    public static userBean getUser(String userName)
    {
    	userBean user=new userBean();
    	String sql="select * from users where username='"+userName+"'";
    	ResultSet rs=DBUtil.getResult(sql);
     	try {
			while(rs.next())
			{
				 
				 user.setUserId(rs.getInt("userId"));
				 user.setUserName(rs.getString("username"));
				 user.setpassword(rs.getString("password"));
		         user.setPhone(rs.getString("phone"));
		         user.setSex(rs.getString("sex"));
		         user.setZipCode(rs.getString("zipCode"));
		         user.setAddress(rs.getString("address"));
		         user.setEmail(rs.getString("email"));
		         user.setRdate(rs.getString("rdate"));
		       
			}
			
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return user;
    	
    }

    private int getUserCount() //返回users表中的记录数
    {
    	int row=0;
    	String sql="select * from users order by userId";
    	ResultSet rs=DBUtil.getResult(sql);
    	try {
			rs.last();
			row=rs.getRow();
			
		} catch (SQLException e) {
			e.printStackTrace();
		}
    	return row;
    }
    private int countTotalPage(int totalRows)//根据总行数计算总页数
    {
    	if(totalRows%rowsPerpage==0)
    		return totalRows/rowsPerpage;
    	else
    		return totalRows/rowsPerpage+1;
    }
    public PageData getPageData(String page)
    {
    	int totalRows=getUserCount();
    	int totalPage=countTotalPage(totalRows);
    	int pageNum=Integer.parseInt(page);
    	if(pageNum<1)pageNum=1;
    	if(pageNum>totalPage)pageNum=totalPage;
    	PageData pagedata=new PageData();
    	ArrayList<userBean>  data=new ArrayList<userBean> ();
    	int num=(pageNum-1)*rowsPerpage;
    	String sql="select * from users order by userId limit "+num+","+rowsPerpage;
    	ResultSet rs=DBUtil.getResult(sql);
     	try {
				while(rs.next())
				{
					userBean user=new userBean();
					user.setUserId(rs.getInt("userId"));
					user.setUserName(rs.getString("username"));
					data.add(user);
				}
				pagedata.setCurPage(pageNum);
				pagedata.setData(data);
				pagedata.setTotalPage(totalPage);
		  } 
     	catch (SQLException e)
		 {
			e.printStackTrace();
		 }
     	return pagedata;
    }
    
}