public class ProductDao {// 查询所有商品// BeanListHandler查询所有商品public List<Product> getAll() throws SQLException {QueryRunner qr = new QueryRunner(MyDBUtils.getDataSource());String sql = "select * from product";List<Product> arr = qr.query(sql, new BeanListHandler<Product>(Product.class));return arr;}// 添加商品public void add(Product product) throws SQLException {QueryRunner qr = new QueryRunner(MyDBUtils.getDataSource());String sql = "insert into product(pid,pname,market_price,shop_price,pdate,pdesc,is_hot,cid) values(?,?,?,?,?,?,?,?)";Object[] obj = { product.getPid(), product.getPname(), product.getMarket_price(), product.getShop_price(),product.getPdate(), product.getPdesc(), product.getIs_hot(), product.getCid() };// 执行sql
        qr.update(sql, obj);}// 根据pid查询商品--就一条记录--用BeanHandlerpublic Product getProductById(String pid) throws SQLException {QueryRunner qr = new QueryRunner(MyDBUtils.getDataSource());String sql = "select * from product where pid = ?";Product product = qr.query(sql, new BeanHandler<Product>(Product.class), pid);return product;}//根据pid修改商品public void edit(Product product) throws SQLException{QueryRunner qr = new QueryRunner(MyDBUtils.getDataSource());String sql ="update product set pname = ?,market_price = ?,shop_price =?,pdesc =?,is_hot=?,cid=? where pid =?";Object[] obj = { product.getPname(), product.getMarket_price(), product.getShop_price(), product.getPdesc(), product.getIs_hot(), product.getCid(),product.getPid()};qr.update(sql,obj);}//根据pid删除商品public void delete(String pid) throws SQLException{QueryRunner qr = new QueryRunner(MyDBUtils.getDataSource());String sql = "delete from product where pid =?";qr.update(sql,pid);}}

package com.oracle.service;import java.sql.SQLException;
import java.util.List;import com.oracle.dao.ProductDao;
import com.oracle.domain.Product;public class ProductService {private ProductDao productDao = new ProductDao();//查询所有商品public List<Product> getAll(){List<Product> arr = null;try {arr=productDao.getAll();} catch (SQLException e) {// TODO Auto-generated catch block
            e.printStackTrace();}return arr;}//添加商品public void add(Product product){try {productDao.add(product);} catch (SQLException e) {// TODO Auto-generated catch block
                e.printStackTrace();}            }//根据pid查询商品public Product getProductById(String pid){Product product = null;try {product =productDao.getProductById(pid);} catch (SQLException e) {// TODO Auto-generated catch block
                e.printStackTrace();}return product;}//根据pid修改商品public void edit(Product product){try {productDao.edit(product);} catch (SQLException e) {// TODO Auto-generated catch block
                e.printStackTrace();}}//根据pid删除商品public void delete(String pid){try {productDao.delete(pid);} catch (SQLException e) {// TODO Auto-generated catch block
                e.printStackTrace();}}
}

package com.oracle.web;import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Map;
import java.util.UUID;import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;import org.apache.commons.beanutils.BeanUtils;import com.oracle.domain.Product;
import com.oracle.service.ProductService;
//增加
public class AddProductServlet extends HttpServlet {private ProductService productService =new ProductService();public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {//解决乱码request.setCharacterEncoding("UTF-8");//获取所有参数的mapMap<String,String[]> map = request.getParameterMap();//创建product对象Product product = new Product();//用BeanUtils进行封装try {BeanUtils.populate(product, map);} catch (IllegalAccessException e) {// TODO Auto-generated catch block
            e.printStackTrace();} catch (InvocationTargetException e) {// TODO Auto-generated catch block
            e.printStackTrace();}//设置pid//uuid是个类，--返回36位的不重复的字母加数字--转成字符串
        product.setPid(UUID.randomUUID().toString());//设置pdateDate date = new Date();SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String d = sdf.format(date);product.setPdate(d);//调用Service方法
        productService.add(product);response.sendRedirect(request.getContextPath()+"/AdminProductListServlet");}public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request, response);}
}

package com.oracle.web;import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;import com.oracle.service.ProductService;
//删除
public class DeleteProductServlet extends HttpServlet {
private ProductService productService=new ProductService();public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {//获取pidString pid =request.getParameter("pid");//调用service方法
        productService.delete(pid);//重定向response.sendRedirect(request.getContextPath() + "/AdminProductListServlet");}public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request, response);}
}

package com.oracle.web;import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.util.Map;import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;import org.apache.commons.beanutils.BeanUtils;import com.oracle.domain.Product;
import com.oracle.service.ProductService;
//修改
public class AdiminEditProductServlet extends HttpServlet {private ProductService productService = new ProductService();public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {//解决乱码request.setCharacterEncoding("UTf-8");//获取所有参数MAPMap<String,String[]> map = request.getParameterMap();//创建product对象Product product = new Product();//用BeanUtils进行封装try {BeanUtils.populate(product, map);} catch (IllegalAccessException e) {// TODO Auto-generated catch block
            e.printStackTrace();} catch (InvocationTargetException e) {// TODO Auto-generated catch block
            e.printStackTrace();}//调用service方法
        productService.edit(product);//这时候已经修改完了，不需要调数据了，只是去页面上查看下数据修改完后的样子//重定向response.sendRedirect(request.getContextPath()+"/AdminProductListServlet");}public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request, response);}
}

package com.oracle.web;import java.io.IOException;
import java.util.List;import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;import com.oracle.domain.Product;
import com.oracle.service.ProductService;
//查
public class AdminProductListServlet extends HttpServlet {// 后台的商品列表页面private ProductService productService = new ProductService();public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {// 获取商品列表List<Product> list = productService.getAll();// 向域中存listrequest.setAttribute("ProductList", list);// 请求转发request.getRequestDispatcher("/admin/product/list.jsp").forward(request, response);}public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request, response);}
}