roominfodao.java

一个KTV管理系统

package dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Vector;

import common.dbconnection.DbConnection;
import vo.Room;
import vo.RoomType;

public class RoomInfoDao {
  //构造添加包间是否成功的方法
  public boolean addRoom(Room value){
    boolean flag = false;
    Connection con = null;
    PreparedStatement pstmt = null;
    String sql = "insert into ktv_room_info values(" + "'" + value.getRoomNumber()  + "'," + "'" + 
    value.getRoomType()  + "'," + "'" + value.getRoomPrice()  + "'," + "'" + value.getRoomName() + "'," + "'" +
    value.getRoomStatement()  + "'," + "'" + value.getRoomCapacity() + "'," + "'" + value.getConsumedId() + "')" ;
    
  try {
    con = new DbConnection().getConnection();
    Statement st = con.createStatement();
    st.execute(sql);
    flag = true;
  } catch (Exception e) {
    System.out.println(e.getMessage());
  }
  return flag;
}
  
//构造从数据库得到数据库得到包间信息的方法
  
  
  public Vector findRoomInfo() {
    Vector v = null;
    Connection con = null;
    Statement stmt = null;
    ResultSet set = null;
    String sql = "select * from ktv_room_info ";
    // System.out.println(sql);
    try {
      con = new DbConnection().getConnection();
      stmt = con.createStatement();
      set = stmt.executeQuery(sql);
      v = new Vector();
      while (set.next()){
         String roomNumber = set.getString(1);
         String roomType = set.getString(2);
         int roomPrice = set.getInt(3);
         String roomName = set.getString(4);
         String roomStatement = set.getString(5);
         int roomCapacity = set.getInt(6);
         long consumedId = set.getLong(7);
         
         v.addElement(new Room(roomNumber, roomType, roomPrice ,roomName ,roomStatement,
                      roomCapacity,consumedId));
      }
      }catch(Exception e){
        System.out.println("异常信息: " + e.getMessage());
      }
      return v;
      }
  
//构造从数据库得到数据库得到包间类型的方法
  
  
  public Vector findRoomType() {
    Vector v = null;
    Connection con = null;
    Statement stmt = null;
    ResultSet set = null;
    String sql = "select * from ktv_room_type ";
    // System.out.println(sql);
    try {
      con = new DbConnection().getConnection();
      stmt = con.createStatement();
      set = stmt.executeQuery(sql);
      v = new Vector();
      while (set.next()){
         String roomType = set.getString(1);
         int roomPrice = set.getInt(2);
         String chargePlan = set.getString(3);
         int roomCapacity = set.getInt(4);
      
         
         v.addElement(new RoomType( roomType, roomPrice , chargePlan,
                      roomCapacity));
      }
      }catch(Exception e){
        System.out.println("异常信息: " + e.getMessage());
      }
      return v;
      }
//  构造判断删除包间是否成功的方法
  public boolean deleteRoomInfo(String RoomId) {
    boolean flag = false;
    Connection con = null;
    PreparedStatement stmt = null;
    ResultSet set = null;
    String sql = "delete from ktv_room_info where Room_number =?";
    // System.out.println(sql);
    try {
      con = new DbConnection().getConnection();
      stmt = con.prepareStatement(sql);
      stmt.setString(1, RoomId);
      stmt.executeUpdate();
      flag = true;
    } catch (Exception e) {
      System.out.println("异常信息: " + e.getMessage());
    }
    return flag;
  }
  /**
   * 构造用于判断将要编辑的记录是否选中的方法
   * 
   * @return
   */
  public boolean findModifyColumn(String RoomId) {
    boolean flag = false;
    Connection con = null;
    PreparedStatement stmt = null;
    ResultSet set = null;
    String sql = "select * from ktv_room_info where Room_Number =?";
    // System.out.println(sql);
    try {
      con = new DbConnection().getConnection();
      stmt = con.prepareStatement(sql);
      stmt.setString(1, RoomId);
      stmt.executeUpdate();
      flag = true;
    } catch (Exception e) {
      System.out.println("异常信息: " + e.getMessage());
    }
    return flag;
  }
  /**
   * 构造用于判断房间资料修改是否成功的方法
   * 
   * @return
   */
  public boolean modifyRoom(Room value) {
    boolean flag = false;
    Vector v = null;
    Connection con = null;
    Statement stmt = null;
    ResultSet set = null;
    String sql = "update employee_info set " + "room_number = '" + value.getRoomNumber() + "',"
                 + "room_type = '" + value.getRoomType() + "'," + "room_price = '" + value.getRoomPrice()
                 + "'," + "room_name = '" + value.getRoomName() + "'," + "room_statement = '" + value.getRoomStatement()
                 + "'," + "room_capacity = '" + value.getRoomCapacity() + "'," + "consumed_id = '" +
                 value.getConsumedId() + "'" ;
    System.out.println(sql);
    try {
      con = new DbConnection().getConnection();
      stmt = con.createStatement();
      stmt.execute(sql);
      flag = true;

    } catch (Exception e) {
      System.out.println("异常信息: " + e.getMessage());
    }
    return flag;
  
  }
  /**
   * 构造用于根据包间编号从数据库中取得数据的方法
   * 
   * @return
   */
  public Vector searchRoomInfo(String number) {
    Vector v = null;
    Connection con = null;
    Statement pstmt = null;
    ResultSet set = null;
    String sql = "select * from ktv_room_info where room_number = '" + number
        + "'";
    System.out.println(sql);
    try {
      con = new DbConnection().getConnection();
      pstmt = con.createStatement();
      set = pstmt.executeQuery(sql);
      v = new Vector();
      while (set.next()){
         String roomNumber = set.getString(1);
         String roomType = set.getString(2);
         int roomPrice = set.getInt(3);
         String roomName = set.getString(4);
         String roomStatement = set.getString(5);
         int roomCapacity = set.getInt(6);
         long consumedId = set.getLong(7);
         
         v.addElement(new Room(roomNumber, roomType, roomPrice ,roomName ,roomStatement,
                      roomCapacity,consumedId));
      }
      }catch(Exception e){
        System.out.println("异常信息: " + e.getMessage());
      }
      return v;
      }
    
  }