businessreserve.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.Reserve;
import exception.ReserveException;
import exception.RoomException;

public class BusinessReserve {
	private static ReserveException exceptions;

	/*
	 * 向数据库中添加一个预定对象
	 */
	public void addReserve(Object obj) throws Exception {
		Reserve reserve = (Reserve) obj;
		DAO dao = new DAO();
		// 向数据库中添加对象
		try {
			try {
				// 连接数据库
				dao.connection();

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

				pstmt.setString(1, reserve.getKhname());
				pstmt.setString(2, reserve.getKhsex());
				pstmt.setString(3, reserve.getGzaddress());
				pstmt.setString(4, reserve.getIdnum());
				pstmt.setString(5, reserve.getTelnum());
				pstmt.setString(6, reserve.getFax());
				pstmt.setString(7, reserve.getDengjitime());
				pstmt.setString(8, reserve.getRuzhutime());
				pstmt.setString(9, reserve.getBeizhu());
				pstmt.setString(10, reserve.getRoomnum());
				pstmt.setString(11, reserve.getRoomtype());
				
				pstmt.execute();
			} finally {
				dao.close();
			}
		} catch (SQLWarning e) {

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

			throw new ReserveException();
		}
	}

	/*
	 * 按照客户姓名查询预定信息
	 */
	public ArrayList queryreservebykhname(String khname) throws Exception {
		DAO dao = new DAO();
		ArrayList arrary = new ArrayList();
		try {
			try {
				dao.connection();
				String sql = "select * from jiudian..reserve where khname = '"
						+ khname + "'";
				Statement stmt = dao.getConn().createStatement();
				ResultSet rs = stmt.executeQuery(sql);

				while (rs.next()) {
					Reserve reserve = new Reserve();

					reserve.setKhname(rs.getString(1));
					reserve.setKhsex(rs.getString(2));
					reserve.setGzaddress(rs.getString(3));
					reserve.setIdnum(rs.getString(4));
					reserve.setTelnum(rs.getString(5));
					reserve.setFax(rs.getString(6));
					reserve.setDengjitime(rs.getString(7));
					reserve.setRuzhutime(rs.getString(8));
					reserve.setBeizhu(rs.getString(9));
					reserve.setRoomnum(rs.getString(10));
					reserve.setRoomtype(rs.getString(11));
					arrary.add(reserve);
				}
				return arrary;
			} finally {
				dao.close();
			}
		} catch (Exception e) {
			throw new ReserveException(exceptions.isNotExist());
		}

	}

	/*
	 * 按照客户的身份证号查询预定信息
	 */
	public ArrayList queryreservebyidnum(String idnum) throws Exception {
		DAO dao = new DAO();
		ArrayList arrary = new ArrayList();
		try {
			try {
				dao.connection();
				String sql = "select * from jiudian..reserve where idnum = '"
						+ idnum + "'";
				Statement stmt = dao.getConn().createStatement();
				ResultSet rs = stmt.executeQuery(sql);

				while (rs.next()) {
					Reserve reserve = new Reserve();

					reserve.setKhname(rs.getString(1));
					reserve.setKhsex(rs.getString(2));
					reserve.setGzaddress(rs.getString(3));
					reserve.setIdnum(rs.getString(4));
					reserve.setTelnum(rs.getString(5));
					reserve.setFax(rs.getString(6));
					reserve.setDengjitime(rs.getString(7));
					reserve.setRuzhutime(rs.getString(8));
					reserve.setBeizhu(rs.getString(9));
					reserve.setRoomnum(rs.getString(10));
					reserve.setRoomtype(rs.getString(11));
					arrary.add(reserve);
				}
				return arrary;
			} finally {
				dao.close();
			}
		} catch (Exception e) {
			throw new ReserveException(exceptions.isNotExist());
		}

	}

	/*
	 * 按照房间号查询预定信息
	 */
	public ArrayList queryreservebyroomnum(String roomnum) throws Exception {
		DAO dao = new DAO();
		ArrayList arrary = new ArrayList();
		try {
			try {
				dao.connection();
				String sql = "select * from jiudian..reserve where roomnum = '"
						+ roomnum + "'";
				Statement stmt = dao.getConn().createStatement();
				ResultSet rs = stmt.executeQuery(sql);

				while (rs.next()) {
					Reserve reserve = new Reserve();

					reserve.setKhname(rs.getString(1));
					reserve.setKhsex(rs.getString(2));
					reserve.setGzaddress(rs.getString(3));
					reserve.setIdnum(rs.getString(4));
					reserve.setTelnum(rs.getString(5));
					reserve.setFax(rs.getString(6));
					reserve.setDengjitime(rs.getString(7));
					reserve.setRuzhutime(rs.getString(8));
					reserve.setBeizhu(rs.getString(9));
					reserve.setRoomnum(rs.getString(10));
					reserve.setRoomtype(rs.getString(11));
					arrary.add(reserve);
				}
				return arrary;
			} finally {
				dao.close();
			}
		} catch (Exception e) {
			throw new ReserveException(exceptions.isNotExist());
		}

	}
     /*
      * 按照房间类型查询预定信息
      */
	public ArrayList queryreservebyroomtype(String roomtype) throws Exception{
		DAO dao = new DAO();
		ArrayList arrary = new ArrayList();
		try {
			try {
				dao.connection();
				String sql = "select * from jiudian..reserve where roomtype = '"
						+ roomtype + "'";
				Statement stmt = dao.getConn().createStatement();
				ResultSet rs = stmt.executeQuery(sql);

				while (rs.next()) {
					Reserve reserve = new Reserve();

					reserve.setKhname(rs.getString(1));
					reserve.setKhsex(rs.getString(2));
					reserve.setGzaddress(rs.getString(3));
					reserve.setIdnum(rs.getString(4));
					reserve.setTelnum(rs.getString(5));
					reserve.setFax(rs.getString(6));
					reserve.setDengjitime(rs.getString(7));
					reserve.setRuzhutime(rs.getString(8));
					reserve.setBeizhu(rs.getString(9));
					reserve.setRoomnum(rs.getString(10));
					reserve.setRoomtype(rs.getString(11));
					arrary.add(reserve);
				}
				return arrary;
			} finally {
				dao.close();
			}
		} catch (Exception e) {
			throw new ReserveException(exceptions.isNotExist());
		}
		
	}
	/*
	 * 查询所有的预定信息
	 */
	public ArrayList queryallreserve() throws Exception{
		DAO dao = new DAO();
		   ArrayList arrary = new ArrayList();		
			try{
				try{				
					dao.connection();
					String sql = "select * from jiudian..reserve " ;
					Statement stmt = dao.getConn().createStatement();
					ResultSet rs = stmt.executeQuery(sql);
					
					while(rs.next()){
						Reserve reserve = new Reserve();

						reserve.setKhname(rs.getString(1));
						reserve.setKhsex(rs.getString(2));
						reserve.setGzaddress(rs.getString(3));
						reserve.setIdnum(rs.getString(4));
						reserve.setTelnum(rs.getString(5));
						reserve.setFax(rs.getString(6));
						reserve.setDengjitime(rs.getString(7));
						reserve.setRuzhutime(rs.getString(8));
						reserve.setBeizhu(rs.getString(9));
						reserve.setRoomnum(rs.getString(10));
						reserve.setRoomtype(rs.getString(11));
						arrary.add(reserve);
					}
					return arrary;
				}
				finally{
					dao.close();
				}
			}
			catch(Exception e){
				throw new RoomException(exceptions.isNotExist());
			}
		
	}
	/*
	 * 按照身份证号查询预定信息的唯一id号
	 */
	public String queryid(String idnum) throws Exception{
		
		DAO dao = new DAO();
	   	String id = null;
	   	try{
	   		try{
	   			dao.connection();
	   			String sql = "select * from jiudian..reserve 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号进行修改预定信息
	 *  updatereserve
	 */
	public void updatereserve(Object obj,String idnum) throws Exception{
		BusinessReserve bus = new BusinessReserve();
		String id =(String) bus.queryid(idnum);
		Reserve reserve = (Reserve)obj;
		DAO dao = new DAO();
		try{
			try{                                                          
				dao.connection();                                        
				PreparedStatement pstmt = dao.getConn().prepareStatement("update jiudian..reserve set khname=(?), khsex=(?),gzaddress=(?),idnum=(?),telnum=(?),fax=(?),dengjitime=(?),ruzhutime=(?),beizhu=(?),roomnum =(?),roomtype =(?)where id='"+id+"'");
				pstmt.setString(1, reserve.getKhname());
				pstmt.setString(2, reserve.getKhsex());
				pstmt.setString(3, reserve.getGzaddress());
				pstmt.setString(4, reserve.getIdnum());
				pstmt.setString(5, reserve.getTelnum());
				pstmt.setString(6, reserve.getFax());
				pstmt.setString(7, reserve.getDengjitime());
				pstmt.setString(8, reserve.getRuzhutime());
				pstmt.setString(9, reserve.getBeizhu());
				pstmt.setString(10, reserve.getRoomnum());
				pstmt.setString(11, reserve.getRoomtype());
				
				pstmt.executeUpdate();
				
				
				pstmt.executeUpdate();
			}
			finally{
				dao.close();
			}
		}
		catch( SQLException e){
			throw new RoomException( exceptions.getMessage());
		}
		
	}
	/*
	 * 按照客户的身份证号删除相应的预定信息
	 */
	public void deletereserve(String idnum) throws Exception{
		DAO dao =new DAO();
		try{
			try{
				dao.connection();
				String sql = "delete from jiudian..reserve 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{
		Reserve reserve = new Reserve();
		BusinessReserve bs = new BusinessReserve();
		reserve.setBeizhu("123123123123");
		reserve.setDengjitime("123");
		reserve.setFax("e23");
		reserve.setGzaddress("ewer");
		reserve.setIdnum("werewr");
		reserve.setKhname("梁咏hgjhgj");
		reserve.setKhsex("女");
		reserve.setRoomnum("dfdsf");
		reserve.setRoomtype("12");
		reserve.setRuzhutime("asdsa");
		reserve.setTelnum("werew");
		String id = bs.queryid("werewr");
		System.out.println(id);
		bs.updatereserve(reserve, "werewr");
		//System.out.print(reserve.getRoomtype());
		//bs.addReserve(reserve);
	//ArrayList list = new ArrayList();
		//list= bs.queryreservebytelnum("werew");
		//reserve = (Reserve)list.get(0);
		//System.out.println(reserve.getFax());
	  
	}
	
}