productservice.java

使用jsp+Servlet,采用MVC模式,实现了一典型小型电子商务网站的全过程.包括前台和后台的全部功能.适合于初学者学习使用.

/**
 * 
 */
package com.eshop.service;

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


import com.eshop.util.DBManager;
import com.eshop.vo.Category;
import com.eshop.vo.Product;
import com.eshop.vo.Supplier;

/**
 * 处理产品业务相关
 * @author jonson
 *
 */
public class ProductService {
	String selectProductByCategory="select * from product where category=?";
	String selectProductById="select * from product where productid=?";

	/**
	 * 根据产品类别查询产信息
	*/
	public List getProductByCategory(String category){
		List list=new ArrayList();
		DBManager dbManager=new DBManager();
		Connection conn=dbManager.GetConnection();
		try {
			PreparedStatement ps=conn.prepareStatement(selectProductByCategory);
			ps.setString(1, category);
			ResultSet rs=ps.executeQuery();
			while(rs.next()){
			Product product=new Product();
			product.setProductid(rs.getString("productid"));
			product.setCategory(rs.getString("category"));
			product.setName(rs.getString("name"));
			product.setDescn(rs.getString("descn"));
			list.add(product);			
			}
			conn.close();
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;		
	}
	/**
	 * 根据产品ID查询商品信息
	 * */
	public Product getProductById(String productid){
		Product product=null;
		DBManager dbManager= new DBManager();
		Connection conn=dbManager.GetConnection();
		try
		{
			PreparedStatement pstmt=conn.prepareStatement(selectProductById);
			pstmt.setString(1,productid);
			ResultSet rs=pstmt.executeQuery();
          
			while(rs.next())
			{
				
				product=new Product();
				product.setProductid(rs.getString("productid"));
				product.setCategory(rs.getString("category"));
				product.setName(rs.getString("name"));
				product.setDescn(rs.getString("descn"));
			}
				conn.close();
		}
		catch(SQLException e)
		{
			e.printStackTrace();
		}				
		return product;
	}
	public List getProduct(String productid){
		Product product=null;
		List list=new ArrayList();
		DBManager dbManager= new DBManager();
		Connection conn=dbManager.GetConnection();
		try
		{
			PreparedStatement pstmt=conn.prepareStatement(selectProductById);
			pstmt.setString(1,productid);
			ResultSet rs=pstmt.executeQuery();
          
			while(rs.next())
			{				
				product=new Product();
				product.setProductid(rs.getString("productid"));
				product.setCategory(rs.getString("category"));
				product.setName(rs.getString("name"));
				product.setDescn(rs.getString("descn"));
				list.add(product);
				
			}
				conn.close();
		}
		catch(SQLException e)
		{
			e.printStackTrace();
		}				
		return list;
	}
	/**
	 * 获得所有产品信息列表
	 * @return list
	 */
	public List getAllProduct(){
		List list=new ArrayList();
		DBManager dbManager= new DBManager();
		Connection conn=dbManager.GetConnection();
		try {
			PreparedStatement ps=conn.prepareStatement("select * from product");
			ResultSet rs=ps.executeQuery();
			while (rs.next()){
				Product product=new Product();
				product.setProductid(rs.getString("productid"));
				product.setCategory(rs.getString("category"));
				product.setName(rs.getString("name"));
				product.setDescn(rs.getString("descn"));
				list.add(product);
			}
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}
/**
 * 保存类
 * @param product
 * @return
 */
public boolean saveProduct(Product product){
	boolean success=false;
	DBManager DbManager= new DBManager();
	Connection conn=DbManager.GetConnection();
	try {
//		Statement stm=conn.createStatement();
		PreparedStatement ps=conn.prepareStatement("INSERT INTO product(productid,category,name,descn)values(?,?,?,?)");
		ps.setString(1,product.getProductid());
		ps.setString(2, product.getCategory());
		ps.setString(3, product.getName());
		ps.setString(4, product.getDescn());
		ps.executeUpdate();
		ps.close();
		conn.commit();
		success=true;
	} catch (SQLException e) {
		// TODO Auto-generated catch block
		
		e.printStackTrace();
		try{
			conn.rollback();
		}catch(SQLException ex){
			ex.printStackTrace();				
		}
	}
	return success;		
}

	/**
	 * 修改类
	 * @param product
	 * @return
	 */
	public boolean changeProduct(Product product){
		boolean success=false;
		DBManager dbManager= new DBManager();
		Connection conn=dbManager.GetConnection();
		try {
//			Statement stm=conn.createStatement();
			PreparedStatement ps=conn.prepareStatement
			("update product set productid=?,category=?,name=?,descn=? where productid='"+product.getProductid()+"'");
			ps.setString(1,product.getProductid());
			ps.setString(2, product.getCategory());
			ps.setString(3, product.getName());
			ps.setString(4, product.getDescn());
			ps.executeUpdate();
			ps.close();
			conn.commit();
			success=true;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			
			e.printStackTrace();
			try{
				conn.rollback();
			}catch(SQLException ex){
				ex.printStackTrace();				
			}
		}
		return success;		
	}
	/**
	 * 删除类
	 * @param product
	 * @return
	 */
	public boolean deleteProduct(Product product){
		boolean success=false;
		DBManager dbManager= new DBManager();
		Connection conn=dbManager.GetConnection();
		try {
//			Statement stm=conn.createStatement();
			PreparedStatement ps=conn.prepareStatement
			("delete from product where productid='"+product.getProductid()+"'");
			ps.executeUpdate();
			ps.close();
			conn.commit();
			success=true;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			
			e.printStackTrace();
			try{
				conn.rollback();
			}catch(SQLException ex){
				ex.printStackTrace();				
			}
		}
		return success;
		
	}
	/**
	 * 获得所有产品信息列表
	 * @return list
	 */
	public List getAllSupplier(){
		List list=new ArrayList();
		DBManager dbManager= new DBManager();
		Connection conn=dbManager.GetConnection();
		try {
			PreparedStatement ps=conn.prepareStatement("select * from supplier");
			ResultSet rs=ps.executeQuery();
			while (rs.next()){
				Supplier supplier=new Supplier();
				supplier.setSuppid(rs.getLong("suppid"));
				supplier.setName(rs.getString("name"));				
				list.add(supplier);
			}
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}
}