admincontrol.java

利用java编写的一个学生宿舍管理系统

/*
 *AdminControl.java
 *author:liuhaijing
 */
 
 package mydesign;
 
 import mydesign.*;
 import java.sql.*;
 import java.io.*;
 import java.util.*;//Vector在这个包里
 import mydesign.*;
 public class AdminControl
 {
 	
 	ResultSet rs=null;
 	String sql=null;
    DBConnect dbconnect=new DBConnect();
 	
 	public AdminControl()
 	{
 	}
 		
 	public String isAdmin(Admin admin) throws Exception 
 	{
 		String a=null; 	
 		sql="select * from admin where username='"+admin.getUserName()+"' and password='"+admin.getPassword()+"';";
 		rs=dbconnect.executeQuery(sql);	  
 	    if(rs.next())
 	    {
 	    	a=new String(rs.getString("manage").getBytes("iso-8859-1"));
 	    }
 	    rs.close();
 	    return a;		
 	}
 	 	
 	//add the admin
 	public void addAdmin(Admin admin)
 	{
 		try
 		{
 			sql="insert into admin (username,password,manage) values ('"+admin.getUserName()+"','"+admin.getPassword()+"','"+admin.getManage()+"');";
 			dbconnect.executeUpdate(sql);
 		}
 		catch(Exception ex)
 		{
 			System.out.print("AddAdmin Bean error:"+ex.getMessage());
 		}
 	}
 		
 		
 		
 	public ArrayList getAllAdmin()
 	{
 			
 		ArrayList a=new ArrayList();
 		try
 		{
 			sql="select * from admin;";
 			rs=dbconnect.executeQuery(sql);
 			while(rs.next())
 			{
 				Admin admin=new Admin();
 				admin.setManage(rs.getString("manage"));
 				admin.setPassword(rs.getString("username"));
 				admin.setUserName(rs.getString("password"));
 				a.add(admin);
 			}
 			rs.close();
 		}catch(Exception ex)
 		{
 			System.out.print("AdminControl's allAdmin error:"+ex.getMessage());
 		}
 		return a;
 	}
 		
 	//isExist admin uername
 	public boolean isExistAdmin(String username) throws Exception
 	{
 		boolean a=false;
 		String sql="select * from admin where username='"+username+"';";
 		rs=dbconnect.executeQuery(sql);
 		if(rs.next())
 		{
 			a=true;
 		}
 		rs.close();
 		return a;
 	}
 		
 	///del admin	
 	public void DelAdmin(String username) throws Exception
 	{
 		try
 		{
 			sql="delete from admin where username='"+username+"';";
 			dbconnect.executeUpdate(sql);
 		}
 		catch(Exception ex)
 		{
 			System.out.print("DelAdmin Error:"+ex.getMessage());
 		}
 	}

 	public int getAdminCount(String strsql)  //计算查询结果的行数
 	{
 		int i=0;
 		try
 		{
 			rs=dbconnect.executeQuery(strsql);
 			while(rs.next())
 			{
 				i=rs.getInt(1);
 			}
 		}
 		catch(Exception ex)
 		{
 			System.out.print("AdminControl's getAdminInfo error:"+ex.getMessage());
 		}
 		return i;
 	}
 			
 	public ArrayList getAdminInfo(String strsql)  //得到查询结果
 	{	
 		ArrayList a=new ArrayList();
 		try
 		{
 			rs=dbconnect.executeQuery(strsql);
 			while(rs.next())
 			{
 				Admin admin=new Admin();
 				admin.setManage(new String(rs.getString("manage").getBytes("iso-8859-1")));
 				admin.setUserName(new String(rs.getString("username").getBytes("iso-8859-1")));
 				admin.setPassword(new String(rs.getString("password").getBytes("iso-8859-1")));
 				a.add(admin);
 			}
 		}
 		catch(Exception ex)
 		{
 			System.out.print("AdminControl's getAdminInfo error:"+ex.getMessage());
 		}
 		return a;
 	}
	
 		
 	//UpdateAdmin
 	public void UpdateAdmin(Admin admin) throws Exception
 	{
 		try
 		{
 			sql="update admin set password='"+admin.getPassword()+"' manage='"+admin.getManage()+"' where username='"+admin.getUserName()+"';";
 			dbconnect.executeUpdate(sql);
 		}
 		catch(Exception ex)
 		{
 			System.out.print("UpdateAdmin Error:"+ex.getMessage());
 		}
 	}
 	
 	public PageBean listData(int page,SearchAdmin searchadmin) throws Exception 	//获得指定页面的数据，并且封装在PageBean中返回
 	{
 		try
 		{
			int count=getAdminCount(searchadmin.strSQL1);
 			ArrayList result=getAdminInfo(searchadmin.strSQL);
			PageBean pagebean=new PageBean(count,result);
 			ArrayList v=new ArrayList();
 			int x=(pagebean.maxRowCount<page*pagebean.rowsPerPage?pagebean.maxRowCount:page*pagebean.rowsPerPage);
 			for(int i=pagebean.rowsPerPage*(page-1);i<x;i++)
 			{
 				v.add(result.get(i));
 			}
 			pagebean.curPage=page;
 			pagebean.data=v;
 			return pagebean;
 		}
 		catch(Exception ex)
 		{
 			ex.printStackTrace();
 			throw ex;
 		}
 	}


 	public void close()
 	{
 		dbconnect.close();
 	}
 	
 }