vendordco.java

海鲜超市管理 登录 修改 增加 等功能jsp+servlet

/*
 * 创建日期 2006-12-18
 * TODO 
 */
package module.vendor.dco;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.List;

import tools.PageControl;
import conn.ConnSky;
import module.vendor.dto.VendorDto;



public class VendorDco {
	
	public static int sumNote;
	
	public void selectVendor(List list, String curpage){
		PageControl pc = new PageControl();
		Connection conn = null;
		ResultSet rs = null;
		PreparedStatement pstmt = null;
		VendorDto vDto = null;
		String sql = "select vendor_id, vendor_name, vendor_address, vendor_phone," +
						" vendor_fax,vendor_contact_person from table_vendor" ;
		System.out.println(sql);
		try {
			conn = ConnSky.getConn();
			pstmt = conn.prepareStatement(sql,
					ResultSet.TYPE_SCROLL_INSENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
			rs = pstmt.executeQuery();
			rs.absolute(-1);
			sumNote = rs.getRow();
			pc.init(Integer.parseInt(curpage), sumNote);
			
			if (sumNote > 0) {
				if (pc.getStart() == 0) {
					rs.absolute(1);
				} else {
					rs.absolute(pc.getStart());
				}
			}
			do {
				vDto = new VendorDto();
				vDto.setVendorId(rs.getString("vendor_id"));
				vDto.setName(rs.getString("vendor_name"));
				vDto.setAddress(rs.getString("vendor_address"));
				vDto.setPhone(rs.getString("vendor_phone"));
				vDto.setFax(rs.getString("vendor_fax"));
				vDto.setContactP(rs.getString("vendor_contact_person"));
				
				list.add(vDto);
				if (!rs.next()) {
					break;
				}

			} while (rs.getRow() < pc.getEnd() + 1);
			
		} catch (Exception e) {
			e.printStackTrace();
		}		
		
		
	}
	
	public void addVendor(VendorDto dto){
		Connection conn = null;
		PreparedStatement pstmt = null;
		int flag = 0;
		String sql = "insert into table_vendor values (vendor_seq.nextval,?,?,?,?,?)";
		
		try{
			conn = ConnSky.getConn();
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1,dto.getName());
			pstmt.setString(2,dto.getAddress());
			pstmt.setString(3,dto.getPhone());
			pstmt.setString(4,dto.getFax());
			pstmt.setString(5,dto.getContactP());
			flag = pstmt.executeUpdate();
			conn.commit();
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try{
				pstmt.close();
				conn.close();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
		
		
	}

	public void updateVendor(VendorDto dto){
		
		Connection conn = null;
		PreparedStatement pstmt = null;
		int flag = 0;
		String sql = "update table_vendor set vendor_name = ?, vendor_address = ?," +
						" vendor_phone = ?, vendor_fax = ?, vendor_contact_person = ? " +
							"where vendor_id = ?  ";
		
		try{
			conn = ConnSky.getConn();
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1,dto.getName());
			pstmt.setString(2,dto.getAddress());
			pstmt.setString(3,dto.getPhone());
			pstmt.setString(4,dto.getFax());
			pstmt.setString(5,dto.getContactP());
			pstmt.setString(6,dto.getVendorId());
			
			flag = pstmt.executeUpdate();
			conn.commit();
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try{
				pstmt.close();
				conn.close();
			}catch(Exception e){
				e.printStackTrace();
			}
		}
	
	}	


}