jsp + servlet + mysql 电子商城

package com.zzz.dao.impl; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.List; import java.util.Map; import org.junit.Test; import com.zzz.bean.Customer; import com.zzz.bean.OrderForm; import com.zzz.bean.OrderLine; import com.zzz.bean.Product; import com.zzz.dao.IOrderFormDao; import com.zzz.exception.DataAccessException; import com.zzz.exception.ServiceException; import com.zzz.service.impl.OrderFormService; import com.zzz.service.impl.ProductService; import com.zzz.util.ConnectionFactory; public class OrderFormDao implements IOrderFormDao { @Override public void saveOrderForm(OrderForm order) throws DataAccessException { // TODO Auto-generated method stub Connection con = ConnectionFactory.getConn(); PreparedStatement pst = null; String sql = "insert into orderform values(null,?,?,?)"; try { pst = con.prepareStatement(sql); pst.setFloat(1, order.getCost()); pst.setString(2, order.getOrderdate()); pst.setInt(3, order.getCustomer().getId()); pst.executeUpdate(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ ConnectionFactory.close(pst, con); } } @Override public void deleteOrder(Integer orderid) throws DataAccessException { // TODO Auto-generated method stub Connection con = ConnectionFactory.getConn(); Statement stm = null; String sql = "delete from orderform where id = " + orderid; try { stm = con.createStatement(); stm.executeUpdate(sql); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ ConnectionFactory.close(stm, con); } } @Override public OrderForm findOrderByOrderid(Integer orderid) throws DataAccessException { // TODO Auto-generated method stub Connection con = ConnectionFactory.getConn(); ResultSet rst = null; Statement stm = null; OrderForm order = new OrderForm(); String sql = "select * from orderform where id = " + orderid; try { stm = con.createStatement(); rst = stm.executeQuery(sql); while(rst.next()){ order.setCost(rst.getFloat("cost")); Customer customer = new CustomerDao().findUserByUserid(rst.getInt("customerid")); order.setCustomer(customer); order.setId(rst.getInt("id")); order.setOrderdate(rst.getString("orderdate")); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ ConnectionFactory.close(rst, stm, con); } return order; } @Override public List<OrderForm> findOrderByUserid(Integer userid) throws DataAccessException { // TODO Auto-generated method stub List<OrderForm> list = new ArrayList<OrderForm>(); Connection con = ConnectionFactory.getConn(); Statement stm = null; ResultSet rst = null; String sql = "select * from orderform where customerid = " + userid; try { stm = con.createStatement(); rst = stm.executeQuery(sql); while(rst.next()){ OrderForm order = new OrderForm(); order.setCost(rst.getFloat("cost")); Customer customer = new CustomerDao().findUserByUserid(userid); order.setCustomer(customer); order.setId(rst.getInt("id")); order.setOrderdate(rst.getString("orderdate")); list.add(order); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } @Override public Map<?, ?> findAllPayway() throws DataAccessException { // TODO Auto-generated method stub return null; } @Override public List<?> findOrderByPageNumber(Integer page, Integer userid) throws DataAccessException { // TODO Auto-generated method stub return null; } //保存所有订单明细 public void saveAllOrderLine(List<OrderLine> orderlines) throws DataAccessException{ for (OrderLine orderLine : orderlines) { saveOrderLine(orderLine); } } //保存订单明细 public void saveOrderLine(OrderLine orderline) throws DataAccessException{ Connection con = ConnectionFactory.getConn(); PreparedStatement pst = null; String sql = "insert into orderline values(null,?,?,?)"; try { pst = con.prepareStatement(sql); pst.setInt(1, orderline.getNum()); pst.setInt(2, orderline.getOrderform().getId()); pst.setInt(3,orderline.getProduct().getId()); pst.executeUpdate(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //删除所有订单明细通过订单号 public void delOrderLinesByOrderid(Integer orderid) throws DataAccessException{ Connection con = ConnectionFactory.getConn(); Statement stm = null; String sql = "delete from orderline where orderformid = " + orderid; try { stm = con.prepareStatement(sql); stm.executeUpdate(sql); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //根据订单生成时间获取订单 public OrderForm getOrderFormByTime(String time) throws DataAccessException{ OrderForm orderform = new OrderForm(); Connection con = ConnectionFactory.getConn(); Statement stm = null; ResultSet rst = null; String sql = "select * from orderform where orderdate = \'" + time +"\'"; try { stm = con.createStatement(); rst = stm.executeQuery(sql); while(rst.next()){ orderform.setCost(rst.getFloat("cost")); Customer customer = new CustomerDao().findUserByUserid(rst.getInt("customerid")); orderform.setCustomer(customer); orderform.setId(rst.getInt("id")); orderform.setOrderdate(rst.getString("orderdate")); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return orderform; } //通过订单id获取或有订单项 public List<OrderLine> getOrderLinesByOrderid(Integer orderid) throws ServiceException{ List<OrderLine> orderlines = new ArrayList<OrderLine>(); Connection con = ConnectionFactory.getConn(); ResultSet rst = null; Statement stm = null; String sql = "select * from orderline where orderformid = " + orderid; try { stm = con.createStatement(); rst = stm.executeQuery(sql); while(rst.next()){ OrderLine orderline = new OrderLine(); orderline.setId(rst.getInt("id")); orderline.setNum(rst.getInt("num")); OrderForm orderform = new OrderFormService().listOrderByOrderid(rst.getInt("orderformid")); orderline.setOrderform(orderform); Product product = new ProductService().getProductByProductid(rst.getInt("productid")); orderline.setProduct(product); orderlines.add(orderline); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ ConnectionFactory.close(rst, stm, con); } return orderlines; } }