admindao.java

来自「模拟网上购物系统」· Java 代码 · 共 455 行

package dao;

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

import po.LogonPO;
import po.adminPO;

public class adminDAO {
	
	Connection conn = null;
	Statement state = null;
	ResultSet rs = null;
	
	//判断用户名与密码是否正确
	public adminPO isAdmin(adminPO poo)
	{
		adminPO po = null;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select * from logon where username = '"+poo.getUsername()+"' and password = '"+poo.getPassword()+"'");
		    
			if(rs.next())
			{
				po = new adminPO();
				po.setId(rs.getInt("id"));
				po.setUsername(rs.getString("username"));
				po.setPassword(rs.getString("password"));
				po.setRepassword(rs.getString("repassword"));
				po.setPhone(rs.getInt("phone"));
				po.setAddress(rs.getString("address"));
				po.setEmail(rs.getString("email"));
				po.setName(rs.getString("name"));
				po.setSex(rs.getString("sex"));
				po.setQq(rs.getInt("qq"));
				po.setFlag(rs.getString("flag"));
				po.setJifen(rs.getInt("jifen"));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(rs != null)
					rs.close();
					if(state != null)
					state.close();
					if(conn != null)
					conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
		}
		return po;
	}
	
	//按ID查询记录
	public adminPO isID(adminPO poo)
	{
		adminPO po = null;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select * from logon where id = " + poo.getId());
		    
			if(rs.next())
			{
				po = new adminPO();
				po.setId(rs.getInt("id"));
				po.setUsername(rs.getString("username"));
				po.setPassword(rs.getString("password"));
				po.setRepassword(rs.getString("repassword"));
				po.setPhone(rs.getInt("phone"));
				po.setAddress(rs.getString("address"));
				po.setEmail(rs.getString("email"));
				po.setName(rs.getString("name"));
				po.setSex(rs.getString("sex"));
				po.setQq(rs.getInt("qq"));
				po.setFlag(rs.getString("flag"));
				po.setJifen(rs.getInt("jifen"));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(rs != null)
					rs.close();
					if(state != null)
					state.close();
					if(conn != null)
					conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
		}
		return po;
	}
	
	//修改记录
	public boolean Modify(adminPO po)
	{
		boolean isok = false;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			int i = state.executeUpdate("update logon set username = '"+po.getUsername()+"',password = '"+po.getPassword()+"',repassword = '"+po.getRepassword()+"',name = '"+po.getName()+"',sex = '"+po.getSex()+"',phone = "+po.getPhone()+",address = '"+po.getAddress()+"',email = '"+po.getEmail()+"',qq = "+po.getQq()+" where id = " + po.getId());
		    if(i > 0)
		    {
		    	isok = true;
		    }
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(state != null)
					state.close();
					if(conn != null)
					conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
		}
		return isok;
	}
	
	//自增ID
	public int nextID()
	{
		int id = 0;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select max(id) max from logon");
			
			if(rs.next())
			{
				id = rs.getInt("max");
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(rs != null)
					rs.close();
					if(state != null)
					state.close();
					if(conn != null)
					conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
		}
		return ++id;
	}
	
	//增加纪录
	public boolean Insert(adminPO po)
	{
		boolean isok = false;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			int i = state.executeUpdate("insert into logon values("+po.getId()+",'"+po.getUsername()+"','"+po.getPassword()+"','"+po.getRepassword()+"','"+po.getName()+"','"+po.getSex()+"',"+po.getPhone()+",'"+po.getAddress()+"','"+po.getEmail()+"',"+po.getQq()+")");
		
			if(i > 0)
			{
				isok = true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(rs != null)
					rs.close();
					if(state != null)
					state.close();
					if(conn != null)
					conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
		}
		return isok;
	}
	
//	查询全部
	public ArrayList findAllUser(int pageSize,int startRows,String sql)
	{
		ArrayList array = new ArrayList();
		try {
			conn = Tools.getConnection();
			state = conn.createStatement(
					ResultSet.TYPE_SCROLL_INSENSITIVE,
					ResultSet.CONCUR_READ_ONLY
					);
			rs = state.executeQuery(sql);
			rs.absolute(startRows);
			
			for(int i=0;i<pageSize;i++)
			{
				LogonPO logon = new LogonPO();
				logon.setId(rs.getInt("id"));
				logon.setUsername(rs.getString("username"));
				logon.setAddress(rs.getString("address"));
				logon.setEmail(rs.getString("email"));
				logon.setPhone(rs.getInt("phone"));
				logon.setQq(rs.getInt("qq"));
				logon.setSex(rs.getString("sex"));
				array.add(logon);
				if(!rs.next())
				{
					break;
				}
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally{
			try {
				if(rs != null)
				{
					rs.close();
				}
				if(state != null)
				{
					state.close();
				}
				if(conn != null)
				{
					conn.close();
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return array;
	}
	
//	查询全部行数
	public int count(String sql)
	{
		int ct = 0;
		
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery(sql);
			if(rs.next())
			{
				ct = rs.getShort("count");
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
			try {
				rs.close();
				state.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return ct;
	}
	
//	按用户名查询
	public LogonPO findUserByUsername(String username)
	{
		LogonPO logon = null;		
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select * from logon where username = '"+username+"'");
			if(rs.next())
			{
				logon = new LogonPO();
				logon.setId(rs.getInt("id"));
				logon.setUsername(rs.getString("username"));
				logon.setSex(rs.getString("sex"));
				logon.setPhone(rs.getInt("phone"));
				logon.setAddress(rs.getString("address"));
				logon.setEmail(rs.getString("email"));
				logon.setQq(rs.getInt("qq"));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally{
			try {
				if(rs != null)
				rs.close();
				if(state != null)
				state.close();
				if(conn != null)
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return logon;
	}
	
//	按用户名查询
	public LogonPO findUserByID(int id)
	{
		LogonPO logon = null;		
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select * from logon where id = '"+id+"'");
			if(rs.next())
			{
				logon = new LogonPO();
				logon.setId(rs.getInt("id"));
				logon.setUsername(rs.getString("username"));
				logon.setSex(rs.getString("sex"));
				logon.setPhone(rs.getInt("phone"));
				logon.setAddress(rs.getString("address"));
				logon.setEmail(rs.getString("email"));
				logon.setQq(rs.getInt("qq"));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally{
			try {
				if(rs != null)
				rs.close();
				if(state != null)
				state.close();
				if(conn != null)
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return logon;
	}
	
//	锁定用户
	public boolean suodingUser(int id)
	{
		boolean isok = false;
		conn = Tools.getConnection();
		try {
			state = conn.createStatement();
			int i = state.executeUpdate("update logon set flag='0' where id="+id);
			if(i > 0)
			{
				isok = true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally{
			try {
				if(state != null)
				state.close();
				if(conn != null)
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return isok;
	}
	
//	用户解锁
	public boolean jiesuoUser(int id)
	{
		boolean isok = false;
		conn = Tools.getConnection();
		try {
			state = conn.createStatement();
			int i = state.executeUpdate("update logon set flag='1' where id="+id);
			if(i > 0)
			{
				isok = true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally{
			try {
				if(state != null)
				state.close();
				if(conn != null)
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return isok;
	}
	
//	删除用户
	public boolean deleteUser(int id)
	{
		boolean isok = false;
		conn = Tools.getConnection();
		try {
			state = conn.createStatement();
			int i = state.executeUpdate("delete from logon where id="+id);
			if(i > 0)
			{
				isok = true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally{
			try {
				if(state != null)
				state.close();
				if(conn != null)
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return isok;
	}

}