incomedao.java

含有 销售商、进货商

package dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import po.*;
import dao.*;
import vo.incomeVO;

public class IncomeDAO {
	
	Connection conn = null;
	Statement state = null;
	ResultSet rs = null;
	
    //查询出当天的所有部门的收入情况
	public ArrayList TodayPartyIncome()
	{
		ArrayList array = new ArrayList();
		incomeVO vo = null;
		
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select  * from table_income income,table_dept dept where income.dept_id = dept.dept_id " );
			
			while(rs.next())
			{
				vo = new incomeVO();
				vo.setDept(rs.getString("dept_name"));
				vo.setBusiness_date(rs.getDate("business_date"));
				vo.setList_mod_timestemp(rs.getDate("list_mod_timestemp"));
				vo.setDaily_income(rs.getInt("daily_income"));
				vo.setDept_id(rs.getInt("dept_id"));
				vo.setIncome_id(rs.getInt("income_id"));
				
				array.add(vo);
			}

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
			try {
				rs.close();
				state.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return array;
	}
	
	
	
    //通过income_id查询出table_income表中相应记录
	public incomeVO FindIncomeByID(int incomeid)
	{
		incomeVO income = null;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select * from table_income where income_id = " + incomeid);
			
			if(rs.next())
			{
				income =  new incomeVO();
				income.setDept_id(rs.getInt("dept_id"));
				income.setIncome_id(rs.getInt("income_id"));
				income.setDaily_income(rs.getInt("daily_income"));
				income.setBusiness_date(rs.getDate("business_date"));
				income.setList_mod_timestemp(rs.getDate("list_mod_timestemp"));
			}
				
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
			try {
				rs.close();
				state.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return income;
	}
	
	
	
	//将当天信息添加到系统中
	public boolean AddMoney(incomeVO vo)
	{
		boolean isdk = false;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			if(state.executeUpdate("insert into table_income values("+vo.getIncome_id()+","+vo.getDept_id()+","+vo.getDaily_income()+",sysdate,sysdate)")>0)
			{
				isdk = true;
			}
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
			try {
				state.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return isdk;
	}
	
	//自动累加income_id
	public int addID()
	{
		int id = 0;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select max(income_id) Mid from table_income  ");
			
			if(rs.next())
			{
				id = rs.getInt("Mid");
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
			try {
				rs.close();
				state.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return ++id;
	}

	
    //修改Table_income表
	public void ModifyIncome(incomeVO vo)
	{
		
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			state.executeUpdate("update Table_income set dept_id = "+vo.getDept_id()+",daily_income = "+vo.getDaily_income()+" where income_id =" + vo.getIncome_id());
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
			try {
				state.close();
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	
	
	

	
}