admindao.java

一个简单的BBS论坛

package com.dao;

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


import com.bean.User;
import com.util.DBUtil;

public class AdminDAO {
	
	/*
	 * 管理员登录
	 * */
	public boolean findAdmin(User user)
	{
		boolean flag = false;
		
		Connection conn = null;
		
		conn = DBUtil.getJDBCConnection();
		
		String sql = "select username,password from bbsuser where username = ? and password = ? and usergrade='管理员'";
		
		try {
			PreparedStatement stmt = conn.prepareStatement(sql);
			stmt.setString(1, user.getUsername());
			stmt.setString(2, user.getPassword());
			ResultSet rs = stmt.executeQuery();
			if(rs.next())
			{

				flag = true;				
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			flag = false;
			e.printStackTrace();
		}
		finally
		{
			DBUtil.closeConnection(conn);
		}
		
		return flag;
	}
	/*
	 * 管理员的用户管理
	 * */
	public ArrayList<User> find()
	{
		ArrayList<User> userlist = new ArrayList<User>();
		
		Connection conn = null;
		conn = DBUtil.getJDBCConnection();
		String sql = "select username,usergrade from bbsuser where usergrade='普通用户'";
			try {
				PreparedStatement stmt = conn.prepareStatement(sql);
				ResultSet rs = stmt.executeQuery();
					while(rs.next())
					{
						String username = rs.getString(1);
						String usergrade = rs.getString(2);
						User user = new User();
						user.setUsername(username);
						user.setUsergrade(usergrade);
						userlist.add(user);
					}			
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			finally
			{
				DBUtil.closeConnection(conn);
			}
		return userlist;
	}
	/*
	 * 用户名的模糊查询来查询消息
	 * */
	public ArrayList<User> findUser(String str)
	{
		ArrayList<User> userlist = new ArrayList<User>();
		
		Connection conn = null;
		conn = DBUtil.getJDBCConnection();
		
		String s = "%"+str+"%";
		String sql = "select username,usergrade from bbsuser where usergrade='普通用户' and username like ?";
			try {
				PreparedStatement stmt = conn.prepareStatement(sql);
				stmt.setString(1, s);
				ResultSet rs = stmt.executeQuery();
					while(rs.next())
					{
						String username = rs.getString(1);
						String usergrade = rs.getString(2);
						User user = new User();
						user.setUsername(username);
						user.setUsergrade(usergrade);
						userlist.add(user);
					}			
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
			finally
			{
				DBUtil.closeConnection(conn);
			}
		return userlist;
	}

}