repaircontrol.java

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

/*
 *RepairControl.java
 *author:liuhaijing
 */
 
 package mydesign;
 
 import mydesign.*;
 import java.sql.*;
 import java.io.*;
 import java.util.*;
 import mydesign.*;
 public class RepairControl
 {
 	
 	ResultSet rs=null;
 	String sql=null;  //用于操作房间信息表的字符串
    DBConnect dbconnect=new DBConnect();   //JDBC连接Bean
 	
 	public RepairControl() //构造函数
 	{
 	}
 	
 	public void addRepair(Repair repair)  //添加房间
 	{
 		try
 		{
 			sql="insert into repair (donghao,houseid,things,calldate,yuanyin) values ('"+repair.getDonghao()+"','"+repair.getHouseid()+"','"+repair.getThings()+"','"+repair.getCalldate().toString()+"','"+repair.getYuanyin()+"');";
 			dbconnect.executeUpdate(sql);

 		}
 		catch(Exception ex)
 		{
 			System.out.print("RepairControl's AddRepair error:"+ex.getMessage());
 		}
 	}
 			
 	public int getRepairCount(String strsql)  //计算查询结果的行数
 	{
 		int i=0;
 		try
 		{
 			rs=dbconnect.executeQuery(strsql);
 			while(rs.next())
 			{
 				i=rs.getInt(1);
 			}
 		}
 		catch(Exception ex)
 		{
 			System.out.print("RepairControl's getRepairInfo error:"+ex.getMessage());
 		}
 		return i;
 	}
 			
 	public ArrayList getRepairInfo(String strsql)  //得到查询结果
 	{	
 		ArrayList a=new ArrayList();
 		try
 		{
 			rs=dbconnect.executeQuery(strsql);
 			while(rs.next())
 			{
 				Repair repair=new Repair();
 				repair.setID(rs.getInt("id"));
 				if(rs.getString("donghao")!=null) repair.setDonghao(new String(rs.getString("donghao").getBytes("iso-8859-1")));
 				if(rs.getString("houseid")!=null) repair.setHouseid(new String(rs.getString("houseid").getBytes("iso-8859-1")));
 				if(rs.getString("things")!=null) repair.setThings(new String(rs.getString("things").getBytes("iso-8859-1")));
 				if(rs.getString("calldate")!=null) repair.setCalldate(rs.getDate("calldate").toString());
 				if(rs.getString("yuanyin")!=null) repair.setYuanyin(new String(rs.getString("yuanyin").getBytes("iso-8859-1")));
 				if(rs.getString("isrepair")!=null) repair.setIsrepair(new String(rs.getString("isrepair").getBytes("iso-8859-1")));
 				if(rs.getString("expense")!=null) repair.setExpense(new String(rs.getString("expense").getBytes("iso-8859-1")));
 				if(rs.getString("repairdate")!=null) repair.setRepairdate(rs.getDate("repairdate").toString());
 				if(rs.getString("zheren")!=null) repair.setZheren(new String(rs.getString("zheren").getBytes("iso-8859-1")));
 				if(rs.getString("peichang")!=null) repair.setPeichang(new String(rs.getString("peichang").getBytes("iso-8859-1")));
 				a.add(repair);
 			}
 		}
 		catch(Exception ex)
 		{
 			System.out.print("RepairControl's getRepairInfo error:"+ex.getMessage());
 		}
 		return a;
 	}
	
 	public Repair getRepairInfo(Repair r)  //得到查询结果
 	{	
 		Repair repair=new Repair();
 		try
 		{
 		    sql="select * from repair where donghao='"+r.getDonghao()+"' and houseid='"+r.getHouseid()+"' and things='"+r.getThings()+"' and isrepair='否';";
 			rs=dbconnect.executeQuery(sql);
 			if(rs.next())
 			{
 				repair.setID(rs.getInt("id"));
 				repair.setDonghao(new String(rs.getString("donghao").getBytes("iso-8859-1")));
 				repair.setHouseid(new String(rs.getString("houseid").getBytes("iso-8859-1")));
 				repair.setThings(new String(rs.getString("things").getBytes("iso-8859-1")));
 				repair.setCalldate(rs.getDate("calldate").toString());
 				repair.setYuanyin(new String(rs.getString("yuanyin").getBytes("iso-8859-1")));
 				repair.setIsrepair(new String(rs.getString("isrepair").getBytes("iso-8859-1")));
 				repair.setExpense(new String(rs.getString("expense").getBytes("iso-8859-1")));
 				repair.setRepairdate(rs.getDate("repairdate").toString());
 				repair.setZheren(new String(rs.getString("zheren").getBytes("iso-8859-1")));
 				repair.setPeichang(new String(rs.getString("peichang").getBytes("iso-8859-1")));
 			}
 		}
 		catch(Exception ex)
 		{
 			System.out.print("RepairControl's getRepairInfo error:"+ex.getMessage());
 		}
 		return repair;
 	}

 	public boolean isExistRepair(Repair repair) throws Exception  //查询是否存在该房间
 	{
 		boolean a=false;
 		sql="select * from repair where donghao='"+repair.getDonghao()+"' and houseid='"+repair.getHouseid()+"' and things='"+repair.getThings()+"' and isrepair='否';";
 		try
 		{
 			rs=dbconnect.executeQuery(sql);
 			if(rs.next())
 			{
 				a=true;
 			}
 		}
 		catch(Exception ex)
 		{
 			System.out.print("RepairControl's isExistRepair error:"+ex.getMessage());
 		}
 		return a;
 	}
 		
 	public void DelRepair(Repair repair) throws Exception    //删除房间
 	{
 		try
 		{
 			sql="delete from repair where id='"+repair.getID()+"';";
 			dbconnect.executeUpdate(sql);
 		}
 		catch(Exception ex)
 		{
 			System.out.print("RepairControl's DelRepair Error:"+ex.getMessage());
 		}
 	} 		
	
 	public void UpdateRepair(Repair repair) throws Exception   //修改房间信息
 	{
 		try
 		{
 			sql="update repair set things='"+repair.getThings()+"',calldate='"+repair.getCalldate().toString()+"',yuanyin='"+repair.getYuanyin()+"',isrepair='"+repair.getIsrepair()+"',expense='"+repair.getExpense()+"',zheren='"+repair.getZheren()+"',peichang='"+repair.getPeichang()+"' where id='"+repair.getID()+"';";
 			dbconnect.executeUpdate(sql);
 			if(repair.getRepairdate()==null) sql="update repair set repairdate=default where id='"+repair.getID()+"';";
 			else sql="update repair set repairdate='"+repair.getRepairdate().toString()+"' where id='"+repair.getID()+"';";
 			dbconnect.executeUpdate(sql);
 			if(repair.getExpense().equals("")) sql="update repair set expense=default where id='"+repair.getID()+"';";
 			dbconnect.executeUpdate(sql);
 			if(repair.getZheren().equals("")) sql="update repair set zheren=default where id='"+repair.getID()+"';";
 			dbconnect.executeUpdate(sql);
 			if(repair.getPeichang().equals("")) sql="update repair set peichang=default where id='"+repair.getID()+"';";
 			dbconnect.executeUpdate(sql);
 		}
 		catch(Exception ex)
 		{
 			System.out.print("RepairControl's UpdateRepair Error:"+ex.getMessage());
 		}
 	}
 	
 	public PageBean listData(int page,SearchRepair searchrepair) throws Exception 	//获得指定页面的数据，并且封装在PageBean中返回
 	{
 		try
 		{
			int count=getRepairCount(searchrepair.strSQL1);
 			ArrayList result=getRepairInfo(searchrepair.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;
 		}
 	}
 	
 	//close
 	public void close()
 	{
 		dbconnect.close();
 	}
 }