package cn.xwkj.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import cn.xwkj.entity.Admin;
import cn.xwkj.util.DataSourceUtils;

/**
 * 超级管理员
 * @author 84661
 *
 */
public class AdminDao extends BaseDao{

	/**
	 * 校验用户名是否存在
	 * 
	 * @param username
	 * @return
	 * @throws SQLException
	 */
	public long checkUsername(String username) throws SQLException {
		QueryRunner runner = new QueryRunner(DataSourceUtils.getDataSource());
		String sql = "select count(*) from user where username=?";
		long query = (Long) runner.query(sql, new ScalarHandler(), username);
		return query;
	}
   /**
    * 用户登录的方法
    * @param username
    * @param password
 * @return 
 * @throws SQLException 
    */
	public Admin login(String username, String password) throws SQLException {
		 QueryRunner runner = new QueryRunner(DataSourceUtils.getDataSource());
	     String sql = "select * from admin where adminname=? and adminpwd= ?";
		 return runner.query(sql, new BeanHandler<Admin>(Admin.class), username,password);
	}
	
	// 查询方法(返回结果用集合存储)
		public List<Admin> list(String sql, Object... param){
			List<Admin> list=new ArrayList<Admin>();
			ResultSet rs=executeQuery(sql, param);
			try {
				while(rs.next())
				{
					Admin a=new Admin();
					a.setId(rs.getInt(1));
					a.setUsername(rs.getString(2));
					a.setPassword(rs.getString(3));
					list.add(a);
				}
				return list;
			} catch (SQLException e) {
				e.printStackTrace();
			}
			finally
			{
				closeAll();
			}
			return null;
		}

		/**
		 * 添加
		 */
		public int add(String sql, Admin admin) {
			Object [] param = {admin.getUsername(),admin.getPassword()};
			return executeUpdate(sql, param);
		}
}