incomesumaccess.java

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

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

package minco;

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

import plugin.*;
import helper.*;
/**
 * 实体类 CurrentAssets 的访问类
 * @author Minco
 * @version 1.0
 */ 
public class IncomeSumAccess
{
    private IDBResource dbRes;
    
   /**
    * 构造函数
    * @param dbRes 数据库资源
    */
    public IncomeSumAccess(IDBResource dbRes)
    {
	this.dbRes = dbRes;
    }

   /**
    * 对IncomeSum表进行插入操作
    * @param IncomeSum 要插入的收支情况
    * @return 影响的行数，如果发生错误，则返回-1
    */
    public int insert(IncomeSum incomeSum)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "INSERT INTO IncomeSum(StatTime, RoomTurnover,DiningRoomTurnover, EntertainmentTurnover, RepertoryCost, Tex, ManageCost) " +
		    " VALUES(?, ?, ?, ?, ?, ?, ?)";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setObject(1, incomeSum.getStatTime());
	    ps.setDouble(2, incomeSum.getRoomTurnover());
	    ps.setDouble(3, incomeSum.getDiningRoomTurnover());
	    ps.setDouble(4, incomeSum.getEntertainmentTurnover());
	    ps.setDouble(5, incomeSum.getRepertoryCost());
	    ps.setDouble(6, incomeSum.getTex());
            ps.setDouble(7, incomeSum.getManageCost());
	    
	    int rs = ps.executeUpdate();
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}
    }

   /**
    * 对IncomeSum表进行更新操作
    * @param incomeSum 要更新的收支表信息
    * @return 影响的行数，如果发生错误，则返回-1
    */
    public int update(IncomeSum incomeSum)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "UPDATE IncomeSum SET RoomTurnover = ?, DiningRoomTurnover = ?, " +
		    "EntertainmentTurnover= ?, RepertoryCost = ?, Tex = ?,  ManageCost = ?) " +
		    "WHERE StatTime = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);	    
	    	    
	    ps.setDouble(1, incomeSum.getRoomTurnover());
	    ps.setDouble(2, incomeSum.getDiningRoomTurnover());
	    ps.setDouble(3, incomeSum.getEntertainmentTurnover());
	    ps.setDouble(4, incomeSum.getRepertoryCost());
	    ps.setDouble(5, incomeSum.getTex());
            ps.setDouble(6, incomeSum.getManageCost());
            ps.setObject(7, incomeSum.getStatTime());
	    
	    int rs = ps.executeUpdate();
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}
    }

   /**
    * 对IncomeSum表进行删除操作
    * @param incomeSum 要删除的收支表信息
    * @return 影响的行数，如果发生错误，则返回-1
    */
    public int delete(IncomeSum incomeSum)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "DELETE FROM IncomeSum WHERE StatTime = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    
            ps.setObject(1, incomeSum.getStatTime());
	    
	    int rs = ps.executeUpdate();
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}
    }

   /**
    * 根据Time查询IncomeSum表的信息
    * @param StatTime 日期
    * @return 查询到的收支信息
    */
    public IncomeSum getIncomeSumByTime(java.util.Date statTime)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM IncomeSum WHERE statTime = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setObject(1, statTime);
	    ResultSet rs = ps.executeQuery();
	    ArrayList<IncomeSum> incomeSum = new ArrayList<IncomeSum>();
	    readData(incomeSum, rs);
	    if (incomeSum.size() != 1)
	    {
		return null;
	    }
	    return incomeSum.get(0);
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}
    }

    /**
     * 返回IncomeSum表的所有信息
     * @return 所有收支信息
     */
    public ArrayList<IncomeSum> getAllIncomeSum()
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM IncomeSum";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ResultSet rs = ps.executeQuery();
	    ArrayList<IncomeSum> incomeSum = new ArrayList<IncomeSum>();
	    readData(incomeSum, rs);
	    return incomeSum;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}
    }

   /**
    * 根据条件查询IncomeSum表的信息
    * @param names 条件的名称
    * @param values 条件的值
    * @return 查询到的收支信息
     */
    public ArrayList<IncomeSum> getIncomeSumByCondition(ArrayList<String> names, ArrayList<Object> values)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM IncomeSum " + SQLHelper.createCondition(names);
	    PreparedStatement ps = conn.prepareStatement(sql);
	    for(int i = 0; i < values.size(); i++)
	    {
		ps.setObject(i+1, values.get(i));
	    }
	    ResultSet rs = ps.executeQuery();
	    ArrayList<IncomeSum> incomeSum = new ArrayList<IncomeSum>();
	    readData(incomeSum, rs);
	    return incomeSum;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}
    }
    
    //读取数据
    private void readData(ArrayList<IncomeSum> incomeSum, ResultSet rs) throws SQLException
    {
	while(rs.next())
	{
	    IncomeSum incomeSums = new IncomeSum();
	    incomeSums.setStatTime(rs.getDate("StatTime"));
	    incomeSums.setRoomTurnover(rs.getDouble("RoomTurnover"));
	    incomeSums.setDiningRoomTurnover(rs.getDouble("DiningRoomTurnover"));
	    incomeSums.setEntertainmentTurnover(rs.getDouble("EntertainmentTurnover"));
	    incomeSums.setRepertoryCost(rs.getDouble("RepertoryCost"));
	    incomeSums.setTex(rs.getDouble("Tex"));
            incomeSums.setManageCost(rs.getDouble("ManageCost"));
	    incomeSum.add(incomeSums);
	}
    }
}