businessruzhu.java

struts_宾馆管理系统

package service;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.SQLWarning;
import java.sql.Statement;
import java.util.ArrayList;

import link.DAO;

import entities.Ruzhu;
import exception.ReserveException;
import exception.RoomException;
import exception.RuzhuException;

public class BusinessRuzhu {
	
	private static RuzhuException exceptions;
   /*
    * 向数据库中添加一个入住信息
    */	
	public void addRuzhu(Object obj) throws Exception{
		Ruzhu ruzhu = (Ruzhu) obj;
		DAO dao = new DAO();
		// 向数据库中添加对象
		try {
			try {
				// 连接数据库
				dao.connection();

				// 将该用户信息写入数据库中
				PreparedStatement pstmt = dao
						.getConn()
						.prepareStatement(
								"insert jiudian..ruzhu(khname,khsex,gongzuoaddress,idnum,telnum,fax,youbian,email,xingzhengquyu,dengjitime,ruzhutime,beizhu) values(?,?,?,?,?,?,?,?,?,?,?,?)");

				pstmt.setString(1, ruzhu.getKhname());
				pstmt.setString(2, ruzhu.getKhsex());
				pstmt.setString(3, ruzhu.getGongzuoaddress());
				pstmt.setString(4, ruzhu.getIdnum());
				pstmt.setString(5, ruzhu.getTelnum());
				pstmt.setString(6, ruzhu.getFax());
				pstmt.setString(7, ruzhu.getYoubian());
				pstmt.setString(8, ruzhu.getEmail());
				pstmt.setString(9, ruzhu.getXingzhengquyu());
				pstmt.setString(10, ruzhu.getDengjitime());
				pstmt.setString(11, ruzhu.getRuzhutime());
				pstmt.setString(12, ruzhu.getBeizhu());
				pstmt.execute();
			} finally {
				dao.close();
			}
		} catch (SQLWarning e) {

			throw exceptions;
		} catch (SQLException e) {
			e.getErrorCode();
			e.printStackTrace();

			throw new RuzhuException();
		}
		
	}
	/*
	 * 按照客户的名字查询客户的入住信息
	 */
	public ArrayList queryRuzhubykhname(String khname ) throws Exception{
		DAO dao = new DAO();
		ArrayList arrary = new ArrayList();
		try {
			try {
				dao.connection();
				String sql = "select * from jiudian..ruzhu where khname = '"
						+ khname + "'";
				Statement stmt = dao.getConn().createStatement();
				ResultSet rs = stmt.executeQuery(sql);

				while (rs.next()) {
					Ruzhu ruzhu = new Ruzhu();

					ruzhu.setKhname(rs.getString(1));
					ruzhu.setKhsex(rs.getString(2));
					ruzhu.setGongzuoaddress(rs.getString(3));
					ruzhu.setIdnum(rs.getString(4));
					ruzhu.setTelnum(rs.getString(5));
					ruzhu.setFax(rs.getString(6));
					ruzhu.setYoubian(rs.getString(7));
					ruzhu.setEmail(rs.getString(8));
					ruzhu.setXingzhengquyu(rs.getString(9));
					ruzhu.setDengjitime(rs.getString(10));
					ruzhu.setRuzhutime(rs.getString(11));
					ruzhu.setBeizhu(rs.getString(12));
					arrary.add(ruzhu);
				}
				return arrary;
			} finally {
				dao.close();
			}
		} catch (Exception e) {
			throw new RuzhuException(exceptions.isNotExist());
		}
	}
	
	/*
	 * 按照联系电话查询客户的入住信息
	 */
	public ArrayList queryRuzhubytelnum(String telnum) throws Exception{
		DAO dao = new DAO();
		ArrayList arrary = new ArrayList();
		try {
			try {
				dao.connection();
				String sql = "select * from jiudian..ruzhu where telnum = '"
						+ telnum + "'";
				Statement stmt = dao.getConn().createStatement();
				ResultSet rs = stmt.executeQuery(sql);

				while (rs.next()) {
					Ruzhu ruzhu = new Ruzhu();

					ruzhu.setKhname(rs.getString(1));
					ruzhu.setKhsex(rs.getString(2));
					ruzhu.setGongzuoaddress(rs.getString(3));
					ruzhu.setIdnum(rs.getString(4));
					ruzhu.setTelnum(rs.getString(5));
					ruzhu.setFax(rs.getString(6));
					ruzhu.setYoubian(rs.getString(7));
					ruzhu.setEmail(rs.getString(8));
					ruzhu.setXingzhengquyu(rs.getString(9));
					ruzhu.setDengjitime(rs.getString(10));
					ruzhu.setRuzhutime(rs.getString(11));
					ruzhu.setBeizhu(rs.getString(12));
					arrary.add(ruzhu);
				}
				return arrary;
			} finally {
				dao.close();
			}
		} catch (Exception e) {
			throw new RuzhuException(exceptions.isNotExist());
		}
	}
	/*
	 * 按照客户的身份证号码查询客户的入住信息
	 */
	public ArrayList queryRuzhubyidnum(String idnum) throws Exception{
		DAO dao = new DAO();
		ArrayList arrary = new ArrayList();
		try {
			try {
				dao.connection();
				String sql = "select * from jiudian..ruzhu where idnum = '"
						+ idnum + "'";
				Statement stmt = dao.getConn().createStatement();
				ResultSet rs = stmt.executeQuery(sql);

				while (rs.next()) {
					Ruzhu ruzhu = new Ruzhu();

					ruzhu.setKhname(rs.getString(1));
					ruzhu.setKhsex(rs.getString(2));
					ruzhu.setGongzuoaddress(rs.getString(3));
					ruzhu.setIdnum(rs.getString(4));
					ruzhu.setTelnum(rs.getString(5));
					ruzhu.setFax(rs.getString(6));
					ruzhu.setYoubian(rs.getString(7));
					ruzhu.setEmail(rs.getString(8));
					ruzhu.setXingzhengquyu(rs.getString(9));
					ruzhu.setDengjitime(rs.getString(10));
					ruzhu.setRuzhutime(rs.getString(11));
					ruzhu.setBeizhu(rs.getString(12));
					arrary.add(ruzhu);
				}
				return arrary;
			} finally {
				dao.close();
			}
		} catch (Exception e) {
			throw new RuzhuException(exceptions.isNotExist());
		}
	}
	/*
	 * 查询所有的客户入住信息
	 */
	public ArrayList queryallruzhu() throws Exception{
		DAO dao = new DAO();
		   ArrayList arrary = new ArrayList();		
			try{
				try{				
					dao.connection();
					String sql = "select * from jiudian..ruzhu " ;
					Statement stmt = dao.getConn().createStatement();
					ResultSet rs = stmt.executeQuery(sql);
					
					while(rs.next()){
						Ruzhu ruzhu = new Ruzhu();

						ruzhu.setKhname(rs.getString(1));
						ruzhu.setKhsex(rs.getString(2));
						ruzhu.setGongzuoaddress(rs.getString(3));
						ruzhu.setIdnum(rs.getString(4));
						ruzhu.setTelnum(rs.getString(5));
						ruzhu.setFax(rs.getString(6));
						ruzhu.setYoubian(rs.getString(7));
						ruzhu.setEmail(rs.getString(8));
						ruzhu.setXingzhengquyu(rs.getString(9));
						ruzhu.setDengjitime(rs.getString(10));
						ruzhu.setRuzhutime(rs.getString(11));
						ruzhu.setBeizhu(rs.getString(12));
						arrary.add(ruzhu);
					}
					return arrary;
				}
				finally{
					dao.close();
				}
			}
			catch(Exception e){
				throw new RoomException(exceptions.isNotExist());
			}
		
	}
	/*
	 * 按照身份证号查询唯一的id号
	 * queryidbyidnum(String idnum)
	 */
	public String queryIdByidnum(String idnum) throws Exception{
		DAO dao = new DAO();
	   	String id = null;
	   	try{
	   		try{
	   			dao.connection();
	   			String sql = "select * from jiudian..ruzhu where idnum = '" + idnum + "'";
	   			Statement stmt = dao.getConn().createStatement();
	   			ResultSet rs = stmt.executeQuery( sql );
	   			
	   			if(rs.next()){
	   				id = rs.getString("id");
	   			}
	   			else{
	   				throw new RoomException(exceptions.isNotExist());
	   			}				
	   		}
	   		finally{
	   			dao.close();
	   		}
	   	}
	   	catch(SQLException e){
	   		throw new RoomException(exceptions.isNotExist());
	   	}
	   	return id;
	}

	 /*
	  * 修改客户的入住信息，按照客户的身份证号查询出唯一的id号后，按照
	  * 查出的id号对数据库中的相应数据进行修改
	  * updateRuzhu(Object obj,String num)
	  */
	public void updateRuzhu(Object obj,String idnum) throws Exception{
		BusinessRuzhu  bus = new BusinessRuzhu();
		String id =(String) bus.queryIdByidnum(idnum);
		Ruzhu ruzhu = (Ruzhu)obj;
		DAO dao = new DAO();
		try{
			try{                                                          
				dao.connection();                                                                  
				PreparedStatement pstmt = dao.getConn().prepareStatement("update jiudian..ruzhu set khname=(?), khsex=(?),gongzuoaddress=(?),idnum=(?),telnum=(?),fax=(?),youbian=(?),email=(?),xingzhengquyu=(?),dengjitime =(?),ruzhutime =(?),beizhu =(?)where id='"+id+"'");
				pstmt.setString(1, ruzhu.getKhname());
				pstmt.setString(2, ruzhu.getKhsex());
				pstmt.setString(3, ruzhu.getGongzuoaddress());
				pstmt.setString(4, ruzhu.getIdnum());
				pstmt.setString(5, ruzhu.getTelnum());
				pstmt.setString(6, ruzhu.getFax());
				pstmt.setString(7, ruzhu.getYoubian());
				pstmt.setString(8, ruzhu.getEmail());
				pstmt.setString(9, ruzhu.getXingzhengquyu());
				pstmt.setString(10, ruzhu.getDengjitime());
				pstmt.setString(11, ruzhu.getRuzhutime());
				pstmt.setString(12, ruzhu.getBeizhu());
				
				pstmt.executeUpdate();
				
				
				pstmt.executeUpdate();
			}
			finally{
				dao.close();
			}
		}
		catch( SQLException e){
			throw new RuzhuException( exceptions.getMessage());
		}
		
	}
	/*
	 *  按照客户的身份证号找到数据库中唯一的
	 *  用户入住信息然后进行删除
	 *  deleteRuzhuByidnum(String idnum)
	 */
	public void deleteRuzhu(String idnum) throws Exception{
		DAO dao =new DAO();
		try{
			try{
				dao.connection();
				String sql = "delete from jiudian..ruzhu where idnum = '" + idnum + "'";
				Statement stmt = dao.getConn().createStatement();
				
				stmt.executeUpdate( sql );
				System.out.print("删除成功！");
			}finally{
				dao.close();
				
			}
		}catch(SQLException e){
			throw new ReserveException( exceptions.getMessage());
		}
	} 
	
	public static  void main(String[]arges) throws Exception{
		Ruzhu ruzhu = new Ruzhu();
		BusinessRuzhu bs = new BusinessRuzhu();
		
		ruzhu.setDengjitime("167886723");
		ruzhu.setFax("e27686763");
		ruzhu.setGongzuoaddress("werewr");
		ruzhu.setIdnum("3723259459");
		ruzhu.setKhname("梁iuoui");
		ruzhu.setKhsex("女hj");
		ruzhu.setBeizhu("wewewew");
		ruzhu.setEmail("ewrewr");
		ruzhu.setRuzhutime("asdsa");
		ruzhu.setXingzhengquyu("werewr");
		ruzhu.setYoubian("wewewerew45");
		ruzhu.setTelnum("werew");
		bs.updateRuzhu(ruzhu, "3723259459");
       bs.addRuzhu(ruzhu);
		//System.out.println(id);
		//bs.updatereserve(reserve, "werewr");
		//System.out.print(reserve.getRoomtype());
		//bs.addReserve(reserve);
	//ArrayList list = new ArrayList();
		//list= bs.queryallruzhu();
		//ruzhu = (Ruzhu)list.get(0);
		//String id = bs.queryIdByidnum("372321198608159459");
		//System.out.println(id);
	  
	}
}