dbmember.java

一套会员管理系统组件

/**
 * Created on 2004-5-9
 *
 */
package com.airinbox.member.profile.database;

import com.airinbox.member.forum.ForumPermissions;
import com.airinbox.member.profile.*;
import com.airinbox.cache.Cacheable;
import java.sql.*;
import com.airinbox.component.authorize.*;
import com.airinbox.component.authorize.concrete.*;

/**
 * @author Frank
 *
 */
public class DbMember implements Member,Cacheable {
	/** 私有变量 **/
	private long id = -1;
	private long memid = -1;
	private String memName;
	private long memcoin = -1;
	private int memrate = -1;
	private java.util.Date createdate;
	private int intmemo1 = -1;
	private int intmemo2 = -1;
	private int intmemo3 = -1;
	private String strmemo1;
	private String strmemo2;
	private String strmemo3;
	
	private MemberManager manager = null;
	
	public static final int ID = 0;
	public static final int MEMBER_ID = 1;
	
	private static final String SQL_SELECT_BY_ID 
					= "select * from " + MemberGlobal.getMemberTable() 
					  + " where id=?";
	private static final String SQL_SELECT_BY_MEM_ID
					= "select * from " + MemberGlobal.getMemberTable() 
					  + " where memid=?";
	
	public DbMember(long id,long memid, String memname, long memcoin, 
					int memrate,java.util.Date createdate,MemberManager manager) {
		this.id = id;
		this.memid = memid;
		this.memName = memname;
		this.memcoin = memcoin;
		this.memrate = memrate;
		this.createdate = createdate;
		this.manager = manager;
	}
	
	public DbMember(long id, int type, MemberManager manager) throws MemberNotFoundException {
		this.manager = manager;
		if(type == ID) {
			this.id = id;
			loadById();
		}
		if(type == MEMBER_ID) {
			this.memid = id;
			loadByMemId();
		}
		throw new MemberNotFoundException();
	}
	
	private void loadById() throws MemberNotFoundException {
		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try {
			con = getConnection();
			pstmt = con.prepareStatement(SQL_SELECT_BY_ID);
			pstmt.setLong(1,id);
			rs = pstmt.executeQuery();
			if(rs.next()) {
				this.memid = rs.getLong("memid");
				this.memName = rs.getString("memname");
				this.memcoin = rs.getLong("memcoin");
				this.memrate = rs.getInt("memrate");
				this.createdate = new java.util.Date(rs.getLong("createdate"));
			}
			else {
				throw new MemberNotFoundException("Member not found whose record_id was " + id);
			}
		} catch(SQLException sqle) {
			sqle.printStackTrace();
			throw new MemberNotFoundException("SQL Exception caused : " + sqle.toString());
		}
	}
	
	private void loadByMemId() throws MemberNotFoundException {
		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		try {
			con = getConnection();
			pstmt = con.prepareStatement(SQL_SELECT_BY_MEM_ID);
			pstmt.setLong(1,memid);
			rs = pstmt.executeQuery();
			if(rs.next()) {
				this.id = rs.getLong("id");
				this.memName = rs.getString("memname");
				this.memcoin = rs.getLong("memcoin");
				this.memrate = rs.getInt("memrate");
				this.createdate = new java.util.Date(rs.getLong("createdate"));
			}
			else {
				throw new MemberNotFoundException("Member not found whose mem_id was " + memid);
			}
		} catch(SQLException sqle) {
			sqle.printStackTrace();
			throw new MemberNotFoundException("SQL Exception caused : " + sqle.toString());
		}
	}
	
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getId()
	 */
	public long getId() {
		return id;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getMemberId()
	 */
	public long getMemberId() {
		return memid;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setMemberId(long)
	 */
	public void setMemberId(long memid) {
		this.memid = memid;
	}
	
	/*
	 *  (non-Javadoc)
	 * @see com.airinbox.member.profile.Member#getUser()
	 */
	public User getUser() {
		UserManager um = XmlUserManager.getInstance();
		User user = null;
		try {
			user = um.getUser(new Long(memid).intValue());
		} catch(Exception e) { 
			e.printStackTrace();
		}
		return user;
	}
	
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getMemberName()
	 */
	public String getMemberName() {
		return memName;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setMemberName(java.lang.String)
	 */
	public void setMemberName(String name) {
		this.memName = name;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getMemberCoin()
	 */
	public long getMemberCoin() {
		return memcoin;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setMemberCoin(long)
	 */
	public void setMemberCoin(long coin) {
		this.memcoin = coin;
	}

	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getMemRate()
	 */
	public int getMemRate() {
		return memrate;
	}	
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setMemRate(int)
	 */
	public void setMemRate(int rate) {
		this.memrate = rate;
	}
	
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getCreateDate()
	 */
	public java.util.Date getCreateDate() {
		return createdate;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setCreateDate(java.util.Date)
	 */
	public void setCreateDate(java.util.Date date) {
		this.createdate = date;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#restore()
	 */
	public void restore() {
		this.memcoin = 0;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#addCoin(long)
	 */
	public long addCoin(long coin) {
		this.memcoin = this.memcoin + coin;
		return memcoin;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#reduceCoin(long)
	 */
	public long reduceCoin(long coin) {
		if(this.memcoin >= coin)
			this.memcoin = this.memcoin - coin;
		else
			this.memcoin = 0;
		return memcoin;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getIntMemo1()
	 */
	public int getIntMemo1() {
		return intmemo1;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setIntMemo1()
	 */
	public void setIntMemo1(int memo) {
		this.intmemo1 = memo;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getIntMemo2()
	 */
	public int getIntMemo2() {
		return intmemo2;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setIntMemo2()
	 */
	public void setIntMemo2(int memo) {
		this.intmemo2 = memo;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getIntMemo3()
	 */
	public int getIntMemo3() {
		return intmemo3;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setIntMemo3()
	 */
	public void setIntMemo3(int memo) {
		this.intmemo3 = memo;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getStrMemo1()
	 */
	public String getStrMemo1() {
		return strmemo1;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setStrMemo1()
	 */
	public void setStrMemo1(String memo) {
		this.strmemo1 = memo;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getStrMemo2()
	 */
	public String getStrMemo2() {
		return strmemo2;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setStrMemo2()
	 */
	public void setStrMemo2(String memo) {
		this.strmemo2 = memo;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#getStrMemo3()
	 */
	public String getStrMemo3() {
		return strmemo3;
	}
	/* (non-Javadoc)
	 * @see com.airinbox.member.Member#setStrMemo3()
	 */
	public void setStrMemo3(String memo) {
		this.strmemo3 = memo;
	}	
	private Connection getConnection() throws SQLException {
		return manager.getConnection();
	}
	
    public int getSize()
    {
        return 1;
    }
	/* (non-Javadoc)
	 * @see com.airinbox.member.profile.Member#getPermissions(com.airinbox.component.authorize.Authorization)
	 */
	public ForumPermissions getPermissions(Authorization auth) {
		// TODO Auto-generated method stub
		return null;
	}
}