package com.qm.shishang.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;

import com.qm.shishang.util.DBUtil;
import com.qm.shishang.view.User;
/**
 * 用户Dao层
 * @author quanmin
 *
 */
public class UserDao extends DBUtil {

	/**
	 * 通过用户名密码找到用户
	 * @param userName
	 * @param userPassWord
	 * @return
	 */
	@SuppressWarnings("unchecked")
	public User findOne(String userName,String userPassWord){
		Connection conn=null;
		User user=null;
		try {
			conn=getConn();
			QueryRunner qr=new QueryRunner();
			String sql="select *from user where userName = ? and userPassword = ? ";
			user=qr.query(conn,sql,new BeanHandler(User.class),userName,userPassWord);
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			closeConn(null, conn);
		}
		return user;
	}
	
	/**
	 * 增加一个对象
	 */
	public int addOne(User user){
		Connection conn=null;
		PreparedStatement stat=null;
		int rowCount=0;
		try {
			conn=getConn();
			String sql="insert into user(userName, userPassword, userEmail, userNicheng) value(?,?,?,?)";
			stat=conn.prepareStatement(sql);
			//设置值
			stat.setString(1, user.getUserName());
			stat.setString(2, user.getUserPassword());
			stat.setString(3, user.getUserEmail());
			stat.setString(4, user.getUserNicheng());
			//执行
			rowCount=stat.executeUpdate();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			closeConn(stat, conn);
		}
		return rowCount;
	}
}