vendordao.java

cantain海鲜超市管理系统

package com.j1132.dao.vendor;

import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import com.j1132.bean.IncomeBean;
import com.j1132.bean.VendorBean;
import com.j1132.dao.AbstractDao;

public class VendorDao extends AbstractDao implements IvendorDao {

	public List<VendorBean> selectVendor() {
		
			List<VendorBean> list = new ArrayList<VendorBean>();

			Connection conn = getConnection();

			String sql = "select *  from  vendor";

			Statement stm = null;

			ResultSet rs = null;
			try {

				stm = conn.createStatement();

				rs = stm.executeQuery(sql);

				while (rs.next()) {

					VendorBean vb = new VendorBean();

					long vendor_id = rs.getLong(1);

					

					String vendor_name = rs.getString(2);

					String vendor_address = rs.getString(3);

					String vendor_phone = rs.getString(4);
					
					String vendor_fax = rs.getString(5);
					
					String vendor_person = rs.getString(6);

					vb.setVendor_ID(vendor_id);

					vb.setVendor_name(vendor_name);
					

					vb.setVendor_address(vendor_address);

					vb.setVendor_phone(vendor_phone);

					vb.setVendor_fax(vendor_fax);

					vb.setVendor_person(vendor_person);

					list.add(vb);
				}
			} catch (Exception e) {
				System.out.println("数据库查询有误");
				e.printStackTrace();
			} finally {
				close(rs, stm, conn);
			}
			return list;
		}

	public boolean addVendor(VendorBean vb) {
		boolean b = true;

		long vendor_id = vb.getVendor_ID();

		String vendor_name = vb.getVendor_name();

		String vendor_address = vb.getVendor_address();

		String vendor_phone = vb.getVendor_phone();
		
		String vendor_fax = vb.getVendor_fax();
		
		String vendor_person = vb.getVendor_person();

		Connection conn = getConnection();

		String sql = "insert into vendor v( vendor_id,vendor_name,vendor_address,vendor_phone,vendor_fax,vendor_contact_person) values (?,?,?,?,?,?)";

		PreparedStatement ps = null;
		try {
			ps = conn.prepareStatement(sql);

			ps.setLong(1, vendor_id);

			ps.setString(2, vendor_name );

			ps.setString(3, vendor_address);

			ps.setString(4,vendor_phone);
			
			ps.setString(5,vendor_fax);
			
			ps.setString(6,vendor_person);

			ps.executeUpdate();

		} catch (Exception e) {
			b = false;
			System.out.println("插入数据错误");
			e.printStackTrace();
		} finally {
			close(null, ps, conn);
		}
		return b;

	}

	public VendorBean selectVendorBeanById(long id) {
		
		VendorBean vb  = new VendorBean();
		
		String sql = "select * from vendor v where v.vendor_id=?";
		
		PreparedStatement ps = null;
		
		ResultSet rs = null;
		
		Connection conn = getConnection();
		
		try{
		ps = conn.prepareStatement(sql);
		
		ps.setLong(1, id);
		
		rs=ps.executeQuery();
		
		while(rs.next()){
			
			String vendor_name = rs.getString(2);
			
			String vendor_address = rs.getString(3);
			
			String vendor_phone = rs.getString(4);
			
			String vendor_fax = rs.getString(5);
			
			String vendor_person = rs.getString(6);
			
			vb.setVendor_ID(id);
			
			vb.setVendor_name(vendor_name);
			
			vb.setVendor_address(vendor_address);
			
			vb.setVendor_phone(vendor_phone);
			
			vb.setVendor_fax(vendor_fax);
			
			vb.setVendor_person(vendor_person);
		}
		}catch(Exception e)
		{
			System.out.println("查找供货商出错");
			e.printStackTrace();
		}finally
		{
			close(null, ps, conn);
		}
		
		
		return vb;
	}

	public boolean updateVendor(VendorBean vb) {
		
		boolean b = true;

		Connection conn = getConnection();

		String sql = "UPDATE VENDOR SET VENDOR_NAME=?, VENDOR_ADDRESS =?,VENDOR_PHONE = ?,VENDOR_FAX = ?,VENDOR_CONTACT_PERSON=?WHERE VENDOR_ID  = ?";

		PreparedStatement ps = null;

		long vendor_id = vb.getVendor_ID();

		String vendor_name = vb.getVendor_name();
		
		String vendor_address = vb.getVendor_address();
		
		String vendor_phone = vb.getVendor_phone();
		
		String vendor_fax = vb.getVendor_fax();
		
		String vendor_person = vb.getVendor_person();

		try {

			ps = conn.prepareStatement(sql);

			ps.setString(1, vendor_name);

			ps.setString(2,vendor_address );

			ps.setString(3,vendor_phone);

			ps.setString(4,vendor_fax);
			
			ps.setString(5,vendor_person);
			
			ps.setLong(6, vendor_id);

			ps.executeUpdate();

		} catch (Exception e) {
			b = false;
			System.out.println("更新数据有误");
			e.printStackTrace();
		} finally {
			close(null, ps, conn);
		}
		return b;
	}

}