userbean.java

项目名称eShop

/*
 * 创建日期：2006-7-16 16:31:57
 *
 * 代码作者：Administrator
 * 
 * 项目名称：eShop
 * 
 * Copyright 2005 Metarnet, Inc. All right reserved.
 */
package eshop.business;
import java.sql.*;

import eshop.common.*;

/**
 * <h5>功能说明:</h5>
 *
 * <h5>对应需求:</h5>
 * 
 *
 * @version 1.0
 * @author Administrator
 */
public class UserBean
{
    /** @param UserVO
     *  @添加用户信息 */
    public int addUserInfo(UserVO aUser)throws Exception
    {
        int intResult=0; 
        Connection conn=DBConnection.getConnection();        
        Statement stmt=conn.createStatement();
        ResultSet rs=null;
        try
        {   
            String strUserCode=aUser.getUserCode();
            String strUserPassWord=aUser.getUserPassWord();
            String strRealName=aUser.getUserRealName();
            String strAddress=aUser.getUserAddress();
            String strPostCode=aUser.getUserPostCode();
            String strTel=aUser.getUserTel();
            String strIsAdmin=aUser.getUserIsAdmin();
            String strRegTime=aUser.getUserRegTime();
            
            String strSQL="select * from T_USER where F_USERCODE='"+strUserCode+"'";
            
            rs=stmt.executeQuery(strSQL);
            if(rs.next())
            {
                intResult=-1;
            }
            else
            {
                strSQL="insert into T_USER(F_USERCODE,F_PASSWORD,F_REALNAME" +
        		",F_ADDRESS,F_ISADMIN,F_REGTIME,F_POSTCODE,F_TEL)" +
        		" values('"+strUserCode+"','"+strUserPassWord+
        		"','"+strRealName+"','"+strAddress+
        		"','"+strIsAdmin+"','"+strRegTime+
        		"','"+strPostCode+"','"+strTel+"')";
        
                 intResult=stmt.executeUpdate(strSQL); //返回成功执行的行计数 
            }
           
            		
        }
        catch(SQLException e)
        {
            intResult=0;
            e.printStackTrace();
            throw e;
            
        }
        finally
        {
            conn.close();             
        }
       
        return intResult;  
    }
    
    /** @修改指定用户名的用户的信息 */
    public int modifyUserInfo()
    {
       // TODO: implement
       return 0;
    }
    

    
    /** @获得指定用户名的用户的信息 */
    public UserVO getUserInfo(String strUserCode) throws Exception
    {
        UserVO aUser=new UserVO();
        Connection conn=DBConnection.getConnection();        
        Statement stmt=conn.createStatement();
        ResultSet rs=null;
        try
        {   
                       
            String strSQL="select * from T_USER where F_USERCODE='"+strUserCode+"'";
            
            rs=stmt.executeQuery(strSQL);
            if(rs.next())
            {
                String strRealName=rs.getString(3);
                String strAddress=rs.getString(4);
                String strPostCode=rs.getString(7);
                String strEmail=rs.getString(1);
                String strTel=rs.getString(8);
                
                aUser.setUserRealName(strRealName);
                aUser.setUserAddress(strAddress);
                aUser.setUserPostCode(strPostCode);
                aUser.setUserCode(strEmail);
                aUser.setUserTel(strTel);
            }
          
            		
        }
        catch(SQLException e)
        {
            e.printStackTrace();
            throw e;
            
        }
        finally
        {
            conn.close();             
        }
        
        return aUser;
    }
    
    
    public int getHasUser(UserVO aUser)throws Exception
    {
       
        int intResult=0; 
        Connection conn=DBConnection.getConnection();        
        Statement stmt=conn.createStatement();
        ResultSet rs=null;
        try
        {   
            String strUserCode=aUser.getUserCode();
            String strUserPassWord=aUser.getUserPassWord();
                       
            String strSQL="select * from T_USER where F_USERCODE='"+strUserCode+"'";
            
            rs=stmt.executeQuery(strSQL);
            if(rs.next())
            {
                if(strUserPassWord.equals(rs.getString(2)))
                {
                    intResult=1;  //成功
                }
                else
                {
                    intResult=-102;//密码不正确
                }
            }
            else
            {
                intResult=-101;//该用户不存在       
                
            }
           
            		
        }
        catch(SQLException e)
        {
            intResult=0; //数据库出错
            e.printStackTrace();
            throw e;
            
        }
        finally
        {
            conn.close();             
        }
        
        return intResult;
    }
}