puserimpl.java

社区文章采用的是平板、树形自由选择的两种展示方式

/* 
 * Created on 2007-6-3
 * Last modified on 2007-6-3
 * Powered by GamVan.com
 */
package com.yeqiangwei.club.passport.dao;

import java.sql.SQLException;

import org.apache.log4j.Logger;

import com.yeqiangwei.club.passport.conn.Config;
import com.yeqiangwei.club.passport.conn.ConnectionCfg;
import com.yeqiangwei.club.passport.conn.JDBCFacade;
import com.yeqiangwei.club.passport.model.PUser;

public class PUserImpl implements PUserDAO{
	
	private static final Logger logger = Logger.getLogger(PUserImpl.class);

	public PUser create(PUser model) {
		JDBCFacade jdbc = new JDBCFacade();
		try {
			jdbc.preparedStatementInstance(ConnectionCfg.SQL_CREATE);
			jdbc.setString(1,model.getUserName());
			jdbc.setString(2, model.getPassword());
			jdbc.setString(3, model.getEmailAddress());
			jdbc.setByte(4, model.getSex());
			jdbc.executeQuery();
			if(jdbc.next()){
				model.setUserId(jdbc.getInt(1));
			}else{
				model =  null;
			}
		} catch (SQLException e) {
			model =  null;
			logger.error(e.toString());
		}finally{
			jdbc.closeAll();
		}
		return model;
	}

	public PUser updateByUserName(PUser model) {
		JDBCFacade jdbc = new JDBCFacade();
		try {
			jdbc.preparedStatementInstance(ConnectionCfg.SQL_UPDATE_USERNAME);
			jdbc.setString(1,model.getUserName());
			jdbc.setString(2, model.getPassword());
			jdbc.setString(3, model.getEmailAddress());
			jdbc.setByte(4, model.getSex());
			jdbc.setInt(5, model.getUserId());
			jdbc.executeUpdate();
		} catch (SQLException e) {
			model =  null;
			logger.error(e.toString());
		}finally{
			jdbc.closeAll();
		}
		return model;
	}

	public PUser login(String userName, String password) {
		Config config =  ConnectionCfg.CONFIG;
		PUser model = null;
		JDBCFacade jdbc = new JDBCFacade();
		try {
			jdbc.preparedStatementInstance(ConnectionCfg.SQL_LOGIN);
			jdbc.setString(1, userName);
			jdbc.setString(2, password);
			jdbc.executeQuery();
			if(jdbc.next()){
				model = new PUser();
				model.setUserId(jdbc.getInt(config.getUserId()));
				model.setUserName(jdbc.getString(config.getUserName()));
				model.setPassword(jdbc.getString(config.getPassword()));
				model.setEmailAddress(jdbc.getString(config.getEmail()));
				model.setSex(jdbc.getByte(config.getSex()));
			}
		} catch (SQLException e) {
			model = null;
			logger.error(e.toString());
		}finally{
			jdbc.closeAll();
		}
		return model;
	}

	public PUser findByUserName(String userName) {
		Config config =  ConnectionCfg.CONFIG;
		PUser model = null;
		JDBCFacade jdbc = new JDBCFacade();
		try {
			jdbc.preparedStatementInstance(ConnectionCfg.SQL_FIND_USERNAME);
			jdbc.setString(1, userName);
			jdbc.executeQuery();
			if(jdbc.next()){
				model = new PUser();
				model.setUserId(jdbc.getInt(config.getUserId()));
				model.setUserName(jdbc.getString(config.getUserName()));
				model.setPassword(jdbc.getString(config.getPassword()));
				model.setEmailAddress(jdbc.getString(config.getEmail()));
				model.setSex(jdbc.getByte(config.getSex()));
			}
		} catch (SQLException e) {
			model = null;
			logger.error(e.toString());
		}finally{
			jdbc.closeAll();
		}
		return model;
	}

	public PUser findByEmail(String email) {
		Config config =  ConnectionCfg.CONFIG;
		PUser model = null;
		JDBCFacade jdbc = new JDBCFacade();
		try {
			jdbc.preparedStatementInstance(ConnectionCfg.SQL_FIND_EMAIL);
			jdbc.setString(1, email);
			jdbc.executeQuery();
			if(jdbc.next()){
				model = new PUser();
				model.setUserId(jdbc.getInt(config.getUserId()));
				model.setUserName(jdbc.getString(config.getUserName()));
				model.setPassword(jdbc.getString(config.getPassword()));
				model.setEmailAddress(jdbc.getString(config.getEmail()));
				model.setSex(jdbc.getByte(config.getSex()));
			}
		} catch (SQLException e) {
			model = null;
			logger.error(e.toString());
		}finally{
			jdbc.closeAll();
		}
		return model;
	}

	public PUser findByUserId(int userId) {
		Config config =  ConnectionCfg.CONFIG;
		PUser model = null;
		JDBCFacade jdbc = new JDBCFacade();
		try {
			jdbc.preparedStatementInstance(ConnectionCfg.SQL_FIND_USERID);
			jdbc.setInt(1, userId);
			jdbc.executeQuery();
			if(jdbc.next()){
				model = new PUser();
				model.setUserId(jdbc.getInt(config.getUserId()));
				model.setUserName(jdbc.getString(config.getUserName()));
				model.setPassword(jdbc.getString(config.getPassword()));
				model.setEmailAddress(jdbc.getString(config.getEmail()));
				model.setSex(jdbc.getByte(config.getSex()));
			}
			
		} catch (SQLException e) {
			model = null;
			logger.error(e.toString());
		}finally{
			jdbc.closeAll();
		}
		return model;
	}
}