vendordao.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.DeptPO;
import po.VendorPO;

import vo.incomeVO;

public class VendorDAO {
	
	Connection conn = null;
	Statement state = null;
	ResultSet rs = null;
	
	//遍历Table_Vendor表
	public ArrayList ListVendor()
	{
		ArrayList array = new ArrayList();
		//IncomeDAO dao = new IncomeDAO();
		VendorPO vendorpo = null;
		
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select * from table_vendor" );
			
			while(rs.next())
			{
				vendorpo = new VendorPO();
				vendorpo.setVendor_id(rs.getInt("vendor_id"));
				vendorpo.setVendor_name(rs.getString("vendor_name"));
				vendorpo.setVendor_address(rs.getString("vendor_address"));
				vendorpo.setVendor_phone(rs.getString("vendor_phone"));
				vendorpo.setVendor_fax(rs.getString("vendor_fax"));
				vendorpo.setVendor_contact_person(rs.getString("vendor_contact_person"));
				
			    array.add(vendorpo);
			}

		} 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;
	}
	
    //自动累加ID
	public int addID()
	{
		int id = 0;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select max(vendor_id) Mid from table_vendor  ");
			
			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;
	}
	
	//按照vendor_id查找记录
	public VendorPO FindVendorByID(int vendorid)
	{
		VendorPO vendorpo = null;
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			rs = state.executeQuery("select * from table_vendor where vendor_id = " + vendorid);
			
			if(rs.next())
			{
				vendorpo = new VendorPO();
				vendorpo.setVendor_id(rs.getInt("vendor_id"));
				vendorpo.setVendor_name(rs.getString("vendor_name"));
				vendorpo.setVendor_address(rs.getString("vendor_address"));
				vendorpo.setVendor_phone(rs.getString("vendor_phone"));
				vendorpo.setVendor_fax(rs.getString("vendor_fax"));
				vendorpo.setVendor_contact_person(rs.getString("vendor_contact_person"));
			}
				
		} 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 vendorpo;
	}
	
	//修改Table_Vendor表
	public void ModifyVendor(VendorPO po)
	{
		
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			state.executeUpdate("update Table_vendor set vendor_name = '"+po.getVendor_name()+"',vendor_address = '"+po.getVendor_address()+"',vendor_phone = '"+po.getVendor_phone()+"',vendor_fax = '"+po.getVendor_fax()+"',vendor_contact_person = '"+po.getVendor_contact_person()+"' where vendor_id = " + po.getVendor_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();
			}
		}
	}
	
	//向Table_Vendor表插入一条新纪录
	public void AddVendor(VendorPO po)
	{
		
		try {
			conn = Tools.getConnection();
			state = conn.createStatement();
			state.executeUpdate("insert into table_vendor values("+po.getVendor_id()+",'"+po.getVendor_name()+"','"+po.getVendor_address()+"','"+po.getVendor_phone()+"','"+po.getVendor_fax()+"','"+po.getVendor_contact_person()+"')");
			
		} 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();
			}
		}
	}
	

}