bookaccess.java

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

/*
 * BookAccess.java
 *
 * Created on 2007年6月18日, 上午11:57
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package dennis;

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

import plugin.*;
/**
 *
 * @author Administrator
 */
public class BookAccess {
    private IDBResource dbRes;
    /** Creates a new instance of BookAccess */
    public BookAccess(IDBResource dbRes) 
    {
        this.dbRes=dbRes;
    }
    
     public int insert(BookInfo bookInfo)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "INSERT INTO BookInfo(GuestName,TableId, ConsumeDate,Phone,Remark) " +
		    " VALUES(?, ?,?,?,?)";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, bookInfo.getGuestName());
	    ps.setString(2, bookInfo.getTableId());
            ps.setObject(3, bookInfo.getConsumeDate());
            ps.setString(4, bookInfo.getPhone());
            ps.setString(5, bookInfo.getRemark());
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}
     }
    public int update(int bookId)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "UPDATE BookInfo SET isConsume = ? WHERE BookId = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, "yes");
	    ps.setInt(2, bookId);
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}		
    }   
    public int delete(int bookId)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "DELETE FROM BookInfo WHERE BookId = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);	   
	    ps.setInt(1, bookId);
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}		
    }

    public ArrayList<BookInfo> getAllBooks()
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM BookInfo";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ResultSet rs = ps.executeQuery();
	    ArrayList<BookInfo> books = new ArrayList<BookInfo>();
	    while(rs.next())
	    {
		BookInfo book = new BookInfo();
		book.setBookId(rs.getInt("BookId"));
		book.setGuestName(rs.getString("GuestName"));
		book.setTableId(rs.getString("TableId"));
                book.setConsumeDate(rs.getDate("ConsumeDate"));
                book.setPhone(rs.getString("Phone"));
                book.setRemark(rs.getString("Remark"));
                book.setIsConsume(rs.getString("isConsume"));
		books.add(book);
	    }
	    return books;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}		
    }
    
}