userdao.java

企业宣传网站

package s2jsp.bysj.dao;

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

import s2jsp.bysj.entity.Users;

public class UserDao extends BaseDao {
	
	
	private Connection conn;

	private PreparedStatement pstmt;

	private ResultSet rs;

	/**
	 * 根据用户名和密码，查找相关用户信息
	 * 
	 * @param userName
	 * @param password
	 * @return 用户对象
	 */
	public Users findUsers(String userName, String password) {
		Users user = null;
		String sql = "select * from users where userName=? and password=? ";
		try {
			conn = this.getConn();
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, userName);
			pstmt.setString(2, password);

			rs = pstmt.executeQuery();
			if (rs.next()) {
				user = new Users();
				user.setUserID(rs.getInt("userID"));
				user.setUserName(userName);
				user.setPassword(password);
				user.setStatus(rs.getInt("status"));

			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			this.closeAll(conn, pstmt, rs);
		}
		return user;
	}
	
	/**
	 * 判断数据库中当前用户名是否存在
	 * @param userName 用户名
	 * @return 存在返回true,否则返回false
	 */
	public boolean findUsers(String userName){
		String sql = "select * from users where userName=? ";
		try {
			conn = this.getConn();
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, userName);

			rs = pstmt.executeQuery();
			if (rs.next()) {
				return true;
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			this.closeAll(conn, pstmt, rs);
		}
		return false;
	}
	
	/**
	 * 添加用户信息
	 * @param userName
	 * @param password
	 * @return 操作数据库影响行数
	 */
	public int insertUser(String userName, String password,int status) {

		String sql = "insert into users values(?,?,?) ";
		String[] params = new String[] { userName, password ,status+""};
		return this.executeSQL(sql, params);
	}
	
	/**
	 * 查找所有的注册用户信息
	 * @return 用户列表
	 */
	public List selectAllUser(){
		List list=new ArrayList();
		String sql = "select * from users ";
		try {
			conn = this.getConn();
			pstmt = conn.prepareStatement(sql);
			rs = pstmt.executeQuery();
			while(rs.next()) {
				Users user = new Users();
				user.setUserID(rs.getInt("userID"));
				user.setUserName(rs.getString("userName"));
				user.setPassword(rs.getString("password"));
				user.setStatus(rs.getInt("status"));
				
				list.add(user);

			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			this.closeAll(conn, pstmt, rs);
		}
		return list;
	}
	
	/**
	 * 根据用户ID,进行删除操作
	 * @param userID
	 * @return 执行SQL语句所影响的数据库行数
	 */
	public int deleteUserByID(String userID){
		String sql="delete from users where userID = ? ";
		String[] param = new String[]{ userID };
		return this.executeSQL(sql, param);
	}
}