.#merg58692cvs

Athena酒店小组_Athena酒店管理系统

/*
 * RoomAccess.java
 *
 * Created on 2007年6月5日, 上午1:39
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package lambert;

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

import plugin.*;
import helper.*;

/**
 *
 * @author Lambert
 */
public class RoomAccess {
    private IDBResource dbRes;
    
    /** Creates a new instance of EmployeeAccess */
    public RoomAccess(IDBResource dbRes) {
        this.dbRes = dbRes;
    }
    
    public int insert(Room room) {
        try {
            Connection conn = dbRes.getConnection();
            String sql = "INSERT INTO Room(RoomNum, RoomType, EngrossDetail, Remark) " +
                    " VALUES(?, ?, ?, ?)";
            PreparedStatement ps = conn.prepareStatement(sql);
            
            ps.setString(1, room.getRoomNum());
            ps.setString(2, room.getRoomType());
            ps.setString(3, room.getEngrossDetail());
            ps.setString(4, room.getRemark());
            
            int rs = ps.executeUpdate();
            return rs;
        } catch (SQLException ex) {
            ex.printStackTrace();
            return -1;
        }
    }
    
    public int update(Room room) {
        try {
            Connection conn = dbRes.getConnection();
            String sql = "UPDATE Room SET RoomNum = ?, RoomType = ?, EngrossDetail = ?, Remark = ? " +
                    "WHERE RoomNum = ?";
            PreparedStatement ps = conn.prepareStatement(sql);
            
            ps.setString(1, room.getRoomNum());
            ps.setString(2, room.getRoomType());
            ps.setString(3, room.getEngrossDetail());
            ps.setString(4, room.getRemark());
            
            int rs = ps.executeUpdate();
            return rs;
        } catch (SQLException ex) {
            ex.printStackTrace();
            return -1;
        }
    }
    
    public int delete(Room room) {
        try {
            Connection conn = dbRes.getConnection();
            String sql = "DELETE FROM Room WHERE RoomNum = ?";
            PreparedStatement ps = conn.prepareStatement(sql);
            
            ps.setString(1, room.getRoomNum());
            
            int rs = ps.executeUpdate();
            return rs;
        } catch (SQLException ex) {
            ex.printStackTrace();
            return -1;
        }
    }
    
    public Room getRoomByRoomNum(String roomNum) {
        try {
            Connection conn = dbRes.getConnection();
            String sql = "SELECT * FROM Room WHERE RoomNum = ?";
            PreparedStatement ps = conn.prepareStatement(sql);
            ps.setString(1, roomNum);
            ResultSet rs = ps.executeQuery();
            ArrayList<Room> rooms = new ArrayList<Room>();
 	    readData(rooms, rs);
            if (rooms.size() != 1) {
                return null;
            }
            return rooms.get(0);
        } catch (SQLException ex) {
            ex.printStackTrace();
            return null;
        }
    }
    
    public ArrayList<Room> getAllRooms() {
        try {
            Connection conn = dbRes.getConnection();
            String sql = "SELECT * FROM Room";
            PreparedStatement ps = conn.prepareStatement(sql);
            ResultSet rs = ps.executeQuery();
            ArrayList<Room> rooms = new ArrayList<Room>();
            readData(rooms, rs);
            return rooms;
        } catch (SQLException ex) {
            ex.printStackTrace();
            return null;
        }
    } 
    
    public ArrayList<Room> getAllCleanRooms() {
        try {
            Connection conn = dbRes.getConnection();
            String sql = "SELECT * FROM Room where EngrossDetail='空净房'";
            PreparedStatement ps = conn.prepareStatement(sql);
            ResultSet rs = ps.executeQuery();
            ArrayList<Room> rooms = new ArrayList<Room>();
            readData(rooms, rs);
            return rooms;
        } catch (SQLException ex) {
            ex.printStackTrace();
            return null;
        }
    }

    private void readData(ArrayList<Room> rooms, ResultSet rs) throws SQLException {
        while(rs.next()) {
                Room room = new Room();
                room.setRoomNum(rs.getString("RoomNum"));
                room.setRoomType(rs.getString("RoomType"));
                room.setEngrossDetail(rs.getString("EngrossDetail"));
                room.setRemark(rs.getString("Remark"));
                rooms.add(room);
        }
    }
    
    
    
    
    
    
    
}