foodaccess.java

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

/*
 * FoodAccess.java
 *
 * Created on 2007年6月18日, 上午3:48
 *
 * 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 FoodAccess {
     private IDBResource dbRes;
    /** Creates a new instance of FoodAccess */
    public FoodAccess(IDBResource dbRes) 
    {
        this.dbRes=dbRes;
    }
    
     public int insert(FoodInfo foodinfo)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "INSERT INTO FoodInfo(FoodId, FoodName, StoreInfo,FoodType,Unit,UnitPrice) " +
		    " VALUES(?, ?, ?,?,?,?)";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, foodinfo.getFoodId());
	    ps.setString(2, foodinfo.getFoodName());
            ps.setString(3, foodinfo.getStoreInfo());
	    ps.setString(4, foodinfo.getFoodType());
            ps.setString(5, foodinfo.getUnit());
            ps.setString(6, foodinfo.getUnitPrice());
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}		
    }
     
     public int update(FoodInfo foodinfo)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "UPDATE FoodInfo SET UnitPrice = ?, StoreInfo = ? WHERE FoodId = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, foodinfo.getUnitPrice());
	    ps.setString(2, foodinfo.getStoreInfo());
	    ps.setString(3, foodinfo.getFoodId());
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}    
    }
     
    public int delete(FoodInfo foodinfo)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "DELETE FROM FoodInfo WHERE FoodId = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);	   
	    ps.setString(1, foodinfo.getFoodId());
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}		
    }
    
    public FoodInfo getFoodById(String foodid)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM FoodInfo WHERE FoodId = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, foodid);
	    ResultSet rs = ps.executeQuery();
	    if(rs.next())
	    {
		FoodInfo food = new FoodInfo();
		food.setFoodId(rs.getString("FoodId"));
		food.setFoodName(rs.getString("FoodName"));
                food.setStoreInfo(rs.getString("StoreInfo"));
                food.setFoodType(rs.getString("FoodType"));	
                food.setUnit(rs.getString("Unit"));
                food.setUnitPrice(rs.getString("UnitPrice"));

		return food;
	    }	    
	    return null;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}		
    }
    
    public ArrayList<FoodInfo> getFoodByType(String foodtype)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM FoodInfo WHERE FoodType = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, foodtype);
	    ResultSet rs = ps.executeQuery();
	    ArrayList<FoodInfo> foods = new ArrayList<FoodInfo>();
	    while(rs.next())
	    {
		FoodInfo food = new FoodInfo();
		food.setFoodId(rs.getString("FoodId"));
		food.setFoodName(rs.getString("FoodName"));
                food.setStoreInfo(rs.getString("StoreInfo"));
                food.setFoodType(rs.getString("FoodType"));	
                food.setUnit(rs.getString("Unit"));
                food.setUnitPrice(rs.getString("UnitPrice"));

		foods.add(food);
	    }	    
	    return foods;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}		
    }
    
}