usersdao.java

企业宣传网 用JSP+SQLSERVER开发 商品展示 在线聊天 留言板 新闻发布 后台管理

package com.accpedu.LHcompany.dao;

import java.util.*;
import java.sql.*;

import com.accpedu.LHcompany.entity.message;
import com.accpedu.LHcompany.entity.users;

public class usersDao {

	
	Connection con=null;
	PreparedStatement ps=null;
	DBAccess dba=new DBAccess();
	
	
	public int selectLogin(users u)
	{
		int x=0;
		con=dba.DBOpen();
		try
		{
			ps=con.prepareStatement("select count(*) from users where username=? and password=?");
			ps.setString(1, u.getUserName());
			ps.setString(2, u.getPassword());
			ResultSet rs=ps.executeQuery();
			while(rs.next())
			{
				x=rs.getInt(1);
			}
			rs.close();
			ps.close();
			dba.DBClose();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		
		return x;
	}
	
	public int insert(users u)
	{
		int x=0;
		con=dba.DBOpen();
		try
		{
			ps=con.prepareStatement("insert into users values(?,?,0)");
			ps.setString(1, u.getUserName());
			ps.setString(2, u.getPassword());
			x =ps.executeUpdate();
			ps.close();
			dba.DBClose();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		
		return x;
	}
	
	
	public int adminLogin(users u)
	{
		int x=0;
		con=dba.DBOpen();
		users us=new users();
		try
		{
			ps=con.prepareStatement("select * from users where username=? and password=?");
			ps.setString(1, u.getUserName());
			ps.setString(2, u.getPassword());
			ResultSet rs=ps.executeQuery();
			while(rs.next())
			{
				us.setUserName(rs.getString("userName"));
				us.setPassword(rs.getString("password"));
				us.setStatus(rs.getInt("status"));
			}
			rs.close();
			ps.close();
			dba.DBClose();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		
		if(us.getUserName()==null)
		{
			return 0;
		}else
		{
			if(us.isStatus()==1)
			{
				return 1;
			}else
			{
				return 2;
			}
		}
	}
	
	public int delete(int id)
	{
		int x=0;
		con=dba.DBOpen();
		try
		{
			ps=con.prepareStatement("delete from users where userId="+id);
			x=ps.executeUpdate();
			dba.DBClose();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		return x;
	}
	
	public ArrayList<users> select()
	{
		ArrayList<users> al=new ArrayList<users>();
		con=dba.DBOpen();
		try
		{
			ps=con.prepareStatement("select * from users");
			ResultSet rs=ps.executeQuery();
			while(rs.next())
			{
				users u=new users();
				u.setUserId(rs.getInt("userID"));
				u.setUserName(rs.getString("userName"));
				u.setPassword(rs.getString("password"));
				u.setStatus(rs.getInt("status"));
				al.add(u);
			}
			rs.close();
			dba.DBClose();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		
		return al;	
	}
	
	public int insertManager(users u)
	{
		int x=0;
		con=dba.DBOpen();
		try
		{
			ps=con.prepareStatement("insert into users values(?,?,1)");
			ps.setString(1, u.getUserName());
			ps.setString(2, u.getPassword());
			x =ps.executeUpdate();
			ps.close();
			dba.DBClose();
		}catch(SQLException ce)
		{
			System.out.println(ce.getMessage());
		}
		
		return x;
	}
}