package com.rainnie.dao.impl;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.rainnie.dao.UserDao;
import com.rainnie.pojo.User;
import com.rainnie.util.JdbcUtil;

public class UserDaoImpl implements UserDao{
	//根据用户名和密码查询用户信息
	@Override
	public User checkUserLogin(String uname, String pwd) {
		Connection con=null;
		PreparedStatement ps=null;
		ResultSet rs=null;
		User u=null;
		try {
		
			
			con=JdbcUtil.getConnection();
			String sql="select * from t_user where uname=? and pwd=?";
			ps=con.prepareStatement(sql);
			ps.setString(1, uname);
			ps.setString(2, pwd);
			rs=ps.executeQuery();
			while(rs.next()) {
				u=new User();
				u.setUid(rs.getInt("uid"));
				u.setUname(rs.getString("uname"));
				u.setPwd(rs.getString("pwd"));
				u.setSex(rs.getString("sex"));
				u.setAge(rs.getInt("age"));
				u.setBirth(rs.getString("birth"));
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			JdbcUtil.free(rs, ps, con);
		}
		 
		return u;
	}

	@Override
	public int userChangePwdDao(String newPwd, int uid) {
		Connection con=null;
		PreparedStatement ps=null;
		
		int index=-1;
		
		try {
			con=JdbcUtil.getConnection();
			String sql="update t_user set pwd=? where uid=?";
			ps=con.prepareStatement(sql);
			ps.setString(1, newPwd);
			ps.setInt(2, uid);
			
			index=ps.executeUpdate();
		} catch (Exception e) {
			
		}finally {
			 JdbcUtil.free(null, ps, con);
		}
		
		return index;
	}

	//获取所有的用户信息
	@Override
	public List<User> userShowDao() {
		 
		Connection con=null;
		PreparedStatement ps=null;
		ResultSet rs=null;
		List<User> lu=null;
		try {
			con=JdbcUtil.getConnection();
			String sql="select * from t_user";
			
			ps=con.prepareStatement(sql);
			
			rs=ps.executeQuery();
			
			lu=new ArrayList<User>();
			
			while(rs.next()) {
				User u=new User();
				u.setUid(rs.getInt("uid"));
				u.setUname(rs.getString("uname"));
				u.setPwd(rs.getString("pwd"));
				u.setSex(rs.getString("sex"));
				u.setAge(rs.getInt("age"));
				u.setBirth(rs.getString("birth"));
				
				
				lu.add(u);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			 JdbcUtil.free(rs, ps, con);
		}
		 
		
		return lu;
	}

	//用户注册
	@Override
	public int userRegDao(User u) {
		
		Connection con=null;
		PreparedStatement ps=null;
		
		int index=-1;
		try {
		 
			con=JdbcUtil.getConnection();
			
			String sql="insert into t_user values(default,?,?,?,?,?)";
			
			ps=con.prepareStatement(sql);
			
			 ps.setString(1, u.getUname());
			 ps.setString(2, u.getPwd());
			 ps.setString(3, u.getSex());
			 ps.setInt(4, u.getAge());
			 ps.setString(5, u.getBirth());
			 
			 index=ps.executeUpdate();
		 
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			JdbcUtil.free(null, ps, con);
		}
		 
		
		return index;
	}

}