userdao.java

简单的企业宣传的网站

package dao;
import java.sql.*;
import java.util.*;

import entity.*;
public class UserDao extends BaseDao{
	private Connection conn=null;
	private PreparedStatement pstmt=null;
	private ResultSet rs=null;
	
	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 (ClassNotFoundException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally
		{
			this.closeAll(conn, pstmt, rs);
		}
		return user;
	}
	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 (ClassNotFoundException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally
		{
			this.closeAll(conn, pstmt, rs);
		}
		return false;
	}
	public int insertUser(String userName, String password,int status)
	{
		String sql="insert into users values(?,?,?)";
		String []param=new String []{userName, password ,status+""};
		return this.excuteSQL(sql, param);
	}
	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 (ClassNotFoundException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally
		{
			this.closeAll(conn, pstmt, rs);
		}
		return list;
	}
	public int deleteUserByID(String userID)
	{
		String sql="delete from users where userID = ? ";
		String []param=new String[]{userID};
		return this.excuteSQL(sql, param);
	}
}