buyerbean.java

一个简单实用的网上书城,可当作原型使用

package czm;
import java.sql.*;
public class BuyerBean {
        private String adid=null;
        private int order_ID=0;
        private int Adminnum=0;
        private int memberID2=0;
        private int memberID3=0;
        private int memberID1=0;
        private String menber_Address=null;
        private String menber_youx=null;
        private String menber_phone=null;
        private String menber_youzheng=null;        
        private String adpwd=null;
	private String memberID = null ;     //会员ID
	private String memberName = null;   //会员姓名
	private String pwd = null;			//密码
	private int logontimes = -1;			//登录的次数
	//private static String strDBDriver = "sun.jdbc.odbc.JdbcOdbcDriver";  //JDBC驱动
	//private static String strDBUrl = "jdbc:odbc:bookstore";   //数据源 ，
        private static opendb dbo=new opendb();
        
	private Connection conn =null;             //连接
	private ResultSet rs = null;					//结果集	
	public BuyerBean (){
            /*
		//加载JDBC-ODBC驱动
		try {
			Class.forName(strDBDriver );
		}
		//捕获异常
		catch(java.lang.ClassNotFoundException e){
			System.err.println("BuyerBean():" + e.getMessage());
		}
             */	
	}	
	//获得登录次数，登录的会员的名字也在该方法调用时获得
	public int getLogontimes(){
		String strSql = null;
		try{
                       /*
			conn = DriverManager.getConnection(strDBUrl);
			Statement stmt = conn.createStatement();
                        */
	                strSql = "Select logonTimes,membername from buyerInfo where memberID = '" + 
			memberID + "' and pwd ='" + pwd + "'";
			rs = dbo.executeQuery(strSql);
			while (rs.next()){				
				// 登录的次数
				logontimes = rs.getInt("logonTimes");
				//会员姓名
				 memberName = rs.getString("membername"); 						
			}			
			rs.close();
			//如果是合法会员则将其登录次数加1
			if (logontimes != -1 ) {
				strSql = "Update buyerInfo set logonTimes = logonTimes +1 where memberID = '" + memberID + "'";
                                String[] strs=new String[1];
                                strs[0]=strSql;
				dbo.executeUpdates(strs);
			}
			//stmt.close();
			//conn.close();
			
		}
		//捕获异常
		catch(SQLException e){
			System.err.println("BuyerBean.getLogontimes():" + e.getMessage());
		}
		return logontimes ;
	}
	//设置memberID属性；
	public  void setMemberID(String ID){
		this.memberID = ID;
	}
	//设置pwd 属性
	public void  setPwd(String password){
		this.pwd = password;
	}
	//获得该会员的真实姓名，必须在取该会员登录的次数之后才能被赋予正确的值
	public String getMemberName(){
		return memberName;
	}
	//测试Bean中的各个方法是否能够正常工作
	public void setAdminID(String ID){
              this.adid=ID;
        }
        public void setMenberAddress(String ad){
              this.menber_Address=ad;
        }
        public void setMenberYoux(String yx){
                this.menber_youx=yx;
        }
        public void setMenberYouZ(String yz){
                this.menber_youzheng=yz;
        }
        public void setMenberPhone(String ph){
                this.menber_phone=ph;
        }
        public void setMenberName(String name){
                this.memberName=name;
        }
        public void setAdminPwd(String pwd){
              this.adpwd=pwd;
        }
        public void setOrderID(int id){
                this.order_ID=id;
        }
        public int findAdmin(){
                 try{  
                       String strA="select * from Admin where Admin_ID='"+adid+"' and  Admin_pwd='"+adpwd+"'";
                       //conn=DriverManager.getConnection(strDBUrl);
                       //Statement stmt=conn.createStatement();
                      rs=dbo.executeQuery(strA);
                      while(rs.next()){
                          Adminnum++;
                      }
                      rs.close();
                 }catch(Exception ex){}
                 return Adminnum;
        }
        public ResultSet getAdminInfo(){
                   try{  
                       String strA="select * from Admin where Admin_ID='"+adid+"'";
                       //conn=DriverManager.getConnection(strDBUrl);
                       //Statement stmt=conn.createStatement();
                       rs=dbo.executeQuery(strA);
                   }catch(Exception ex){}
                   return rs;
        }
          public ResultSet getBuyerInfo(){
                   try{  
                       String strA="select * from buyerInfo";
                       //conn=DriverManager.getConnection(strDBUrl);
                       //Statement stmt=conn.createStatement();
                       rs=dbo.executeQuery(strA);
                   }catch(Exception ex){}
                   return rs;
        }
           public int deleBuyerInfo(){
                   try{  
                       String strA="delete from buyerInfo where memberID='"+memberID+"'";
                       String strB="delete from orderdetail where orderdetail.memberID='"+memberID+"'";
                       String strC="delete from orderInfo where orderInfo.memberID='"+memberID+"'";
                       //conn=DriverManager.getConnection(strDBUrl);
                       //Statement stmt=conn.createStatement();
                       String[] strs=new String[3];
                       strs[0]=strA;
                       strs[1]=strB;
                       strs[2]=strC;
                       
                       dbo.executeUpdates(strs);
                       
                        //.executeUpdate(strC);
                        //stmt.executeUpdate(strB);
                       //memberID2=stmt.executeUpdate(strA);
                       //stmt.close();
                       //conn.close();
                   }catch(Exception ex){}
                   //return memberID2;
                   return memberID2=1;
        }
           public int deleOrderInfo(){
                   try{  
                       
                       String strB="delete from orderdetail where orderdetail.orderID="+order_ID;
                       String strC="delete from orderInfo where orderInfo.orderID="+order_ID;
                       
                       String[] strs=new String[2];
                       strs[0]=strB;
                       strs[1]=strC;
                       
                       dbo.executeUpdates(strs);
                       
                       //conn=DriverManager.getConnection(strDBUrl);
                       //Statement stmt=conn.createStatement();
                        //stmt.executeUpdate(strB);
                        //memberID1=stmt.executeUpdate(strC);                      
                       //stmt.close();
                       //conn.close();
                   }catch(Exception ex){}
                   //return memberID1;
                   return memberID1=1;
           }
            public int addMenber(){
                   try{  
                       
                       String strB="insert into buyerInfo values('"+memberID+"','"+memberName+"',null,'"+pwd+"','"+menber_phone+"','"+menber_youzheng+"','"+menber_Address+"','"+menber_youx+"',0)";                     
                       
                       String[] strs=new String[1];
                       strs[0]=strB;
                       
                       if(dbo.executeUpdates(strs)==false)return 0;
                       
                       //conn=DriverManager.getConnection(strDBUrl);
                       //Statement stmt=conn.createStatement();
                        //memberID3=stmt.executeUpdate(strB);                                  
                       //stmt.close();
                       //conn.close();
                   }catch(Exception ex){}
                   return memberID3=0;
           }
}