usersdao.java

来自「java带进度条上传尽量不要让站长把时间都花费在为您修正说明上」· Java 代码 · 共 858 行 · 第 1/2 页

		try {
			PreparedStatement ps = connDB.prepareStatement(sql);
			ps.setString(1, nick_name);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
				logcount=rs.getInt(1);
			}
		} catch (SQLException e) {
			throw new BlogException("查询昵称记录总数出错!");
		}
		return logcount;
	}
	
	
	/**
	 * 通过用户昵称nickname查询userslogin表用户all信息,分页
	 * @param nickname
	 * @return
	 * @throws BlogException
	 */
	public List selectUsersloginByNickName(String nick_name,int curpage,int pagelog) throws BlogException{
		String sql="select * from userslogin where nickName=? limit ?,?";
		int first=(curpage-1)*pagelog;
		List list=new ArrayList();
		try {
			PreparedStatement ps= this.getConn().prepareStatement(sql);
			ps.setString(1, nick_name);
			ps.setInt(2, first);
			ps.setInt(3, pagelog);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
				UsersLoginVO userloginvo = new UsersLoginVO();
				userloginvo.setU_id(rs.getInt("uId"));
				userloginvo.setLogin_name(rs.getString("loginName"));
				userloginvo.setNick_name(rs.getString("nickName"));
				userloginvo.setUser_password(rs.getString("userPassword"));
				userloginvo.setPower(rs.getInt("power"));
				userloginvo.setState(rs.getInt("state"));
				userloginvo.setFace(rs.getString("face"));
				userloginvo.setLastlogin_time(rs.getString("lastLoginTime"));
				userloginvo.setRegister_time(rs.getString("registerTime"));
				userloginvo.setCounter(rs.getInt("counter"));
				userloginvo.setBlog_name(rs.getString("blogName"));
				list.add(userloginvo);
			}
		} catch (SQLException e) {
			throw new BlogException("查询用户失败！");
		}
		return list;
	}
	
	
	/**
	 * 通过性别area查询userslogin表中的记录信息数
	 * @param sex
	 * @return
	 * @throws BlogException
	 */
	public int getLogCountByArea(String area) throws BlogException{
		int logcount=0;
		Connection connDB = this.getConn();
		String sql="select count(*) from usersinfo,userslogin where usersinfo.area=? and userslogin.uId=usersinfo.usersloginId";
		try {
			PreparedStatement ps = connDB.prepareStatement(sql);
			ps.setString(1, area);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
				logcount=rs.getInt(1);
			}
		} catch (SQLException e) {
			throw new BlogException("查询地区记录总数出错!");
		}
		return logcount;
	}
	
	/**
	 * 通过用户地区usersinfo.area查询userslogin表用户基本信息,分页
	 * @param area
	 * @return
	 * @throws BlogException
	 */	
	public List selectUsersLoginByArea(String area,int curpage,int pagelog) throws BlogException{
		String sql="select userslogin.* from usersinfo,userslogin where usersinfo.area=? and userslogin.uId=usersinfo.usersloginId limit ?,?";
		int first=(curpage-1)*pagelog;
		List list=new ArrayList();
		try {
			PreparedStatement ps=this.getConn().prepareStatement(sql);
			ps.setString(1, area);
			ps.setInt(2, first);
			ps.setInt(3, pagelog);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
				UsersLoginVO userloginvo = new UsersLoginVO();
				userloginvo.setU_id(rs.getInt("uId"));
				userloginvo.setLogin_name(rs.getString("loginName"));
				userloginvo.setNick_name(rs.getString("nickName"));
				userloginvo.setUser_password(rs.getString("userPassword"));
				userloginvo.setPower(rs.getInt("power"));
				userloginvo.setState(rs.getInt("state"));
				userloginvo.setFace(rs.getString("face"));
				userloginvo.setLastlogin_time(rs.getString("lastLoginTime"));
				userloginvo.setRegister_time(rs.getString("registerTime"));
				userloginvo.setCounter(rs.getInt("counter"));
				userloginvo.setBlog_name(rs.getString("blogName"));
				list.add(userloginvo);
			}
		} catch (SQLException e) {
			throw new BlogException("查询用户失败！");
		}
		return list;
		
	}
	

	/**
	 * 通过性别usersinfo.sex查询userslogin表中的基本信息,分页
	 * @param sex
	 * @param curpage
	 * @param pagelog
	 * @return
	 * @throws BlogException
	 */
	public List selectUsersLoginBySex(int sex,int curpage,int pagelog) throws BlogException{
		int first=(curpage-1)*pagelog;
		String sql="select userslogin.* from usersinfo,userslogin where usersinfo.sex=? and userslogin.uId=usersinfo.usersloginId limit ?,?";
		List list=new ArrayList();
		try {
			PreparedStatement ps=this.getConn().prepareStatement(sql);
			ps.setInt(1, sex);
			ps.setInt(2, first);
			ps.setInt(3, pagelog);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
				UsersLoginVO userloginvo = new UsersLoginVO();
				userloginvo.setU_id(rs.getInt("uId"));
				userloginvo.setLogin_name(rs.getString("loginName"));
				userloginvo.setNick_name(rs.getString("nickName"));
				userloginvo.setUser_password(rs.getString("userPassword"));
				userloginvo.setPower(rs.getInt("power"));
				userloginvo.setState(rs.getInt("state"));
				userloginvo.setFace(rs.getString("face"));
				userloginvo.setLastlogin_time(rs.getString("lastLoginTime"));
				userloginvo.setRegister_time(rs.getString("registerTime"));
				userloginvo.setCounter(rs.getInt("counter"));
				userloginvo.setBlog_name(rs.getString("blogName"));
				list.add(userloginvo);
			}
		} catch (SQLException e) {
			e.printStackTrace();
			throw new BlogException("简单查询用户，分页失败！");
		}
		return list;
	}
	
	/**
	 * 通过性别usersinfo.sex查询userslogin表中的记录信息数
	 * @param sex
	 * @return
	 * @throws BlogException
	 */
	public int getLogCountBySex(int sex) throws BlogException{
		int logcount=0;
		Connection connDB = this.getConn();
		String sql="select count(*) from usersinfo,userslogin where usersinfo.sex=? and userslogin.uId=usersinfo.usersloginId";
		try {
			PreparedStatement ps = connDB.prepareStatement(sql);
			ps.setInt(1, sex);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
				logcount=rs.getInt(1);
			}
		} catch (SQLException e) {
			throw new BlogException("查询性别记录总数出错!");
		}
		return logcount;
	}
	
	/**
	 * 通过用户ID修改密码
	 * @param password
	 * @param uid
	 * @return
	 * @throws SQLException
	 */	
	public boolean updatePassword(String password, int uid)throws BlogException {
		boolean b = false;
		Connection con = this.getConn();
		String sql = "UPDATE userslogin set password=? where uId=?";
		PreparedStatement ps;
		try {
			ps = con.prepareStatement(sql);
			ps.setString(1, password);
			ps.setInt(2, uid);
			int i = ps.executeUpdate();
			if (i == 1)
				b = true;
		} catch (SQLException e) {
			throw new BlogException("修改密码失败！");
		}
		return b;
	}
	
	/**
	 * 通过id修改userslogin中的blogname
	 * @param blog_name
	 * @param uid
	 * @return
	 * @throws BlogException
	 */
	public boolean updateBlogName(String blog_name,int uid) throws BlogException
	{
		boolean b = false;
		Connection con = this.getConn();
		String sql = "UPDATE userslogin set blogName=? where uid = ?";
		PreparedStatement ps;
		try {
			ps = con.prepareStatement(sql);
			ps.setString(1, blog_name);
			ps.setInt(2,uid );
			int i = ps.executeUpdate();
			if(i==1)
				b = true;
		} catch (SQLException e) {
			throw new BlogException("修改博客名称失败！");
		}
		return b;	
	}
	
	
	/**
	 * 通过用户ID修改称昵
	 * @param nickName
	 * @param uid
	 * @return
	 * @throws SQLException
	 */
	public boolean updateNickName(String nickName,int uid) throws BlogException
	{
		boolean b = false;
		Connection con = this.getConn();
		String sql = "UPDATE userslogin set nickName=? where uid = ?";
		PreparedStatement ps;
		try {
			ps = con.prepareStatement(sql);
			ps.setString(1, nickName);
			ps.setInt(2,uid );
			int i = ps.executeUpdate();
			if(i==1)
				b = true;
		} catch (SQLException e) {
			throw new BlogException("修改昵称失败！");
		}
		return b;	
	}
	
	
	/**
	 * 通过用户ID修改权限
	 * @param power
	 * @param uid
	 * @return
	 * @throws SQLException
	 */
	public boolean updatePower(int power,int uid) throws BlogException
	{
		boolean b = false;
		Connection con = this.getConn();
		String sql = "UPDATE userslogin set power=? where uId = ?";
		PreparedStatement ps;
		try {
			ps = con.prepareStatement(sql);
			ps.setInt(1,power);
			ps.setInt(2,uid );
			int i = ps.executeUpdate();
			if(i==1)
				b = true;
		} catch (SQLException e) {
			throw new BlogException("修改权限失败！");
		}
		return b;	
	}
	
	
	/**
	 * 
	 * 通过用户ID修改状态
	 * @param state
	 * @param uid
	 * @return
	 * @throws SQLException
	 */
	public boolean updateState(int state,int uid) throws BlogException
	{
		boolean b = false;
		Connection con = this.getConn();
		String sql = "UPDATE userslogin set state=? where uId = ?";
		PreparedStatement ps;
		try {
			ps = con.prepareStatement(sql);
			ps.setInt(1,state);
			ps.setInt(2,uid);
			int i = ps.executeUpdate();
			if(i==1)
				b = true;
		} catch (SQLException e) {
			throw new BlogException("修改用户状态失败！");
		}
		return b;	
	}
	
	
	/**
	 * 通过用户ID修改图象
	 * @param face
	 * @param uid
	 * @return
	 * @throws SQLException
	 */
	public boolean updateFace(String face,int uid) throws BlogException
	{
		boolean b = false;
		Connection con = this.getConn();
		String sql = "UPDATE userslogin set face=? where uid = ?";
		PreparedStatement ps;
		try {
			ps = con.prepareStatement(sql);
			ps.setString(1, face);
			ps.setInt(2,uid );
			int i = ps.executeUpdate();
			if(i==1)
				b = true;
		} catch (SQLException e) {
			throw new BlogException("修改用户图像失败！");
		}
		return b;	
	}
	
	
	/**
	 * 对查询userslogin表中的数据总数
	 * @return
	 * @throws BlogException
	 */
	public int getLogCount() throws BlogException{
		int logcount=0;
		Connection connDB = this.getConn();
		String sql="select count(*) from userslogin";
		try {
			PreparedStatement ps = connDB.prepareStatement(sql);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
				logcount=rs.getInt(1);
			}
		} catch (SQLException e) {
			throw new BlogException("查询记录总数出错!");
		}
		return logcount;
	}
	

	/**
	 * 对表userslogin中的数据进行分页
	 * @param curpage
	 * @param pagelog
	 * @return
	 * @throws BlogException
	 */
	public List getPagination(int curpage,int pagelog) throws BlogException{
		Connection connDB = this.getConn();
		int first=(curpage-1)*pagelog;
		String sql="select * from userslogin limit ?,?";	
		List list=new ArrayList();
		try {
			PreparedStatement ps = connDB.prepareStatement(sql);
			ps.setInt(1, first);
			ps.setInt(2, pagelog);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
				UsersLoginVO usersloginvo=new UsersLoginVO();
				usersloginvo.setU_id(rs.getInt("uId"));
				usersloginvo.setLogin_name(rs.getString("loginName"));
				usersloginvo.setNick_name(rs.getString("nickName"));
				usersloginvo.setUser_password(rs.getString("userPassword"));
				usersloginvo.setPower(rs.getInt("power"));
				usersloginvo.setState(rs.getInt("state"));
				usersloginvo.setFace(rs.getString("face"));
				usersloginvo.setLastlogin_time(rs.getString("lastLoginTime"));
				usersloginvo.setRegister_time(rs.getString("registerTime"));
				usersloginvo.setCounter(rs.getInt("counter"));
				usersloginvo.setBlog_name(rs.getString("blogName"));
				list.add(usersloginvo);
			}
		} catch (SQLException e) {
			e.printStackTrace();
			throw new BlogException("分页出错");
		}
		return list;
	}
	
	/**
	 * 通过积分查询用户前n名用户
	 * @param num
	 * @return
	 * @throws BlogException
	 */
	public List getUsersByCounter(int num)throws BlogException{
		Connection connection=this.getConn();
		String sql="select uId,blogName from userslogin order by counter desc limit 0,?";
		PreparedStatement ps;
		List list=new ArrayList();
		try {
			ps = connection.prepareStatement(sql);
			ps.setInt(1, num);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
				UsersLoginVO usersloginvo=new UsersLoginVO();
				usersloginvo.setU_id(rs.getInt("uId"));
				usersloginvo.setBlog_name(rs.getString("blogName"));
				list.add(usersloginvo);
			}
		} catch (SQLException e) {
			throw new BlogException("积分排列出错");
			
		}
		return list;
	}
	
}