package com.wang.dao;

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

import com.wang.bean.UserBean;
import com.wang.util.MysqlDbManager;




public class UserDao {
	//登录
	public int loginUser(UserBean user)throws Exception{
		int  res=0;
		
		String sql = null;
		Connection con = null;
		ResultSet rs = null;
		PreparedStatement ps = null;
		try {
			con = MysqlDbManager.getConnection();
			sql = "select * from jingtable where loginName='" + user.getLoginName() + "' and loginWord='"+ user.getLoginWord() + "'";
			System.out.println(sql);
			ps = con.prepareStatement(sql);
			rs = ps.executeQuery();
			while (rs.next()) {
				res++;
				System.out.println("找到了");
			}
		} finally {
			ps.close();
			rs.close();
			MysqlDbManager.closeConnection(con);
		}
		if(res>0){
			return 101;
		}else{
			return 99;
		}
	}
	
	
	
	
	
	//   注册  写入  userbean
	public int insert(UserBean user) throws Exception{
		String sql = null;
		Connection con = null;
		PreparedStatement ps = null;
		int rowCount=0;
		try {
			con = MysqlDbManager.getConnection();
			sql="insert into jingtable(loginName, loginWord) value(?,?)";
			System.out.println(sql);
			ps=con.prepareStatement(sql);
			//设置值
			ps.setString(1, user.getLoginName());
			ps.setString(2, user.getLoginWord());

			//执行
			rowCount=ps.executeUpdate();
			
		}finally{
			ps.close();
			MysqlDbManager.closeConnection(con);;
		}
		if(rowCount>0){
			return 101;//
		}else{
			return 99;
			
		}
	}
	
	
	
	//通过id  查询 userBean
	public UserBean getUserBeanByid( Integer id) throws Exception {
		UserBean resUser = new UserBean();
		String sql = null;
		Connection con = null;
		ResultSet rs = null;
		PreparedStatement ps = null;
		try {
			con = MysqlDbManager.getConnection();
			sql = "select * from jingtable where uid='" + id + "'";
			System.out.println(sql);
			ps = con.prepareStatement(sql);
			rs = ps.executeQuery();
			while (rs.next()) {
				resUser.setUid(rs.getString(1));
				resUser.setLoginName(rs.getString(2));
				resUser.setLoginWord(rs.getString(3));
			}
		} finally {
			ps.close();
			rs.close();
			MysqlDbManager.closeConnection(con);
		}
		return resUser;
	}
	
	
	
	public static void main(String[] args) throws Exception {
//		System.out.println(new TDao().getUserBeanByid(12));
		
		
		UserBean  user=new UserBean("233232", "RRRR");
		int  x=new UserDao().loginUser(user);
		
		System.out.println(x);
	}
}