package com.ghy.bookstore.user.dao;

import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import com.ghy.base.dao.BaseDao;
import com.ghy.bookstore.user.model.UserVO;

public class UserDao extends BaseDao {
	
	public boolean checkUserName(String name) throws IOException, InstantiationException, IllegalAccessException, ClassNotFoundException, SQLException
	{
		Connection conn=this.getDatamanager().getConnection();
		String sql="select * from USERS where name='"+name+"'";
		PreparedStatement statement=conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
		ResultSet rt=statement.executeQuery();
		rt.last();
		int row=rt.getRow();
		if(row>0)
			return true;
		else
			return false;
	}
	public void createUser(UserVO user) throws IOException, InstantiationException, IllegalAccessException, ClassNotFoundException, SQLException
	{
		Connection conn=this.getDatamanager().getConnection();
		String sql="insert into USERS(ID,"+"NAME,REALNAME,PASSWORD,TYPE,ADDRESS,CODE,EMAINL)"+" values(?,?,?,?,?,?,?,?)";
		PreparedStatement statement=conn.prepareStatement(sql);
		statement.setString(1, this.generateId(conn));
		statement.setString(2, user.getName());
		statement.setString(3, user.getRealname());
		statement.setString(4, user.getPassword());
		statement.setString(5, user.getType());
		statement.setString(6, user.getAddress());
		statement.setInt(7, user.getCode());
		statement.setString(8, user.getEmail());
		statement.execute();
		this.getDatamanager().closeDBConnection();
	}
	public boolean login(UserVO user) throws IOException, InstantiationException, IllegalAccessException, ClassNotFoundException, SQLException
	{
		Connection conn=this.getDatamanager().getConnection();
		String sql="select * from USERS where name='"+user.getName()+"' and password='"+user.getPassword()+"'";
		PreparedStatement statment=conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
		ResultSet rt=statment.executeQuery();
		rt.last();
		int row =rt.getRow();
		if(row>0)
			return true;
		else
			return false;
	}
	public UserVO findUserByName(String name) throws IOException, InstantiationException, IllegalAccessException, ClassNotFoundException, SQLException
	{
		Connection conn=this.getDatamanager().getConnection();
		String sql="select * from USERS where name='"+name+"'";
		PreparedStatement statement=conn.prepareStatement(sql);
		ResultSet rt=statement.executeQuery();
		UserVO user=new UserVO();
		while(rt.next())
		{
			    user.setId(rt.getString("ID"));
	            user.setName(rt.getString("NAME"));
	            user.setRealname(rt.getString("REALNAME"));
	            user.setPassword(rt.getString("PASSWORD"));
	            user.setEmail(rt.getString("EMAINL"));
	            user.setType(rt.getString("TYPE"));
	            user.setAddress(rt.getString("ADDRESS"));
	            user.setCode(rt.getInt("CODE"));
		}
		getDatamanager().closeDBConnection();
		return user;
		
	}

}