membercontrollerimpl.java

JSP开发的完整的网络商店.包含源代码和开发文档等

/*
 * Created on 2005-10-28
 * Author 曹汕
 * Version 1.0
 * Copyright by CS.SSPKU Inc. All rights reserved. 
 */
package com.struts.controller.impl;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.struts.business.Member;
import com.struts.controller.MemberController;


/**
 * @author cs
 * 
 * TODO To change the template for this generated type comment go to Window -
 * Preferences - Java - Code Style - Code Templates
 */
public class MemberControllerImpl extends ControllerImpl implements MemberController{

	private static MemberControllerImpl _instance;

	/**
	 * 单例模式，只创建唯一一个实例 
	 * @return 返还MemberController 类的惟一实例
	 */
	public static synchronized MemberControllerImpl getInstance() {
		if (_instance == null)
			_instance = new MemberControllerImpl();
		return _instance;
	}
	
	public MemberControllerImpl(){
			super();
		}
	/**
	 * 校验登录信息,校验通过返回会员的ID
	 */

	public int getMemberID(String name, String pwd) {
		String strSql;
		ResultSet rs;
		strSql = "select * from member where username='" + name + "' and password='" + pwd + "'";
		rs = selectRecord(strSql);
		try {
			if (rs.next())
				return rs.getInt("id");
		} catch (SQLException e) {
			e.printStackTrace();
		} 

		return 0;
	}

	/**
	 * 根据ID获取会员的信息
	 */
	public  Member getMemberInfo(int id) throws Exception {
		String strSql;
		ResultSet rs;
		strSql = "select * from member where id=" + id;
		rs = selectRecord(strSql);
		Member member = new Member();
		if (rs.next()) {
			member.setId(id);
			member.setUsername(rs.getString("username"));
			member.setPassword(rs.getString("password"));
			member.setName(rs.getString("name"));
			member.setAddress(rs.getString("address"));
			member.setPhone(rs.getString("phone"));
			member.setGender(rs.getString("gender"));
			member.setPostcode(rs.getString("postcode"));
			member.setEmail(rs.getString("mail"));
		}
		return member;
	}

	/**
	 * 会员帐号唯一性检验。
	 * true表示存在帐号；
	 * false表示不存在
	 * @param username
	 * @return true or flase
	 */
	public boolean checkMemberExist(String username) throws Exception {
		String strSql;
		ResultSet rs = null;
		strSql = "select * from member where username='" + username + "'";
		rs = selectRecord(strSql);
		if (rs.next())
			return true;
		return false;
	}

	/**
	 * 会员注册
	 */
	public  boolean registerMember(Member member) throws SQLException{
		int memberId=getId("MEMBERSEQ");
		String strSql=null;
		strSql="insert into member values("
			+memberId+",'"
			+member.getUsername()+"','"
			+member.getPassword()+"','"
			+member.getName()+"','"
			+member.getGender()+"','"
			+member.getPhone()+"','"
			+member.getEmail()+"','"
			+member.getPostcode()+"','"
			+member.getAddress()+"',"
			+"SYSDATE,0)";
		System.out.println("SQL>>>>>>>"+strSql);
//		DBLink db = new DBLink();
//		try {
//			Statement stmt = db.createStatement();
//			Connection conn = stmt.getConnection();
//			CallableStatement cstmt=conn.prepareCall("{call MEMBERFUNCTION.MEMBER_REGISTER(?,?,?,?,?,?,?,?)}");
//	    	cstmt.setString(1,"Hello");
//	    	cstmt.setString(2,"Hello1");
//	    	cstmt.setString(3,"name");
//	    	cstmt.setString(4,"female");
//	    	cstmt.setInt(5,100000);
//	    	cstmt.setString(6,"aafd");
//	    	cstmt.setString(7,"aafd");
//	    	cstmt.setString(8,"aafd");
//	    	cstmt.execute();
//	    	cstmt.close();
//		} catch (SQLException e1) {
//			// TODO Auto-generated catch block
//			e1.printStackTrace();
//		}
		if(insertRecord(strSql))
			return true;
		else return false;
	};

	/**
	 * 会员密码修改
	 * @param password
	 * @param memberId
	 * @return true or false
	 */
	public  boolean changeMemberPwd(String password,int memberId) throws SQLException {
		String strSql=null;
		strSql="update member set password='"
			+password+"' where id="
			+memberId;
		System.out.println("SQL>>>>>>>"+strSql);
		if(updateRecord(strSql))
			return true;
		else return false;
	}
	
	/**
	 * 会员信息修改
	 */
	
	public  boolean updateMemberInfo(Member member) throws SQLException{
		String strSql=null;
		strSql="update member set name='"
			+member.getName()+"',gender='"
			+member.getGender()+"',phone='"
			+member.getPhone()+"',mail='"
			+member.getEmail()+"',postcode='"
			+member.getPostcode()+"',address='"
			+member.getAddress()+"' where id="
			+member.getId();
		System.out.println("SQL>>>>>>>"+strSql);
		if(updateRecord(strSql))
			return true;
		else return false;
	}
}