javaweb 网上书城（包含数据库）

package zyqx.order.dao; import java.sql.SQLException; import java.sql.Timestamp; import java.util.ArrayList; import java.util.List; import java.util.Map; import org.apache.commons.dbutils.QueryRunner; import org.apache.commons.dbutils.handlers.BeanHandler; import org.apache.commons.dbutils.handlers.BeanListHandler; import org.apache.commons.dbutils.handlers.MapListHandler; import org.apache.commons.dbutils.handlers.ScalarHandler; import zyqx.book.domain.Book; import zyqx.category.domain.Category; import zyqx.order.domain.Order; import zyqx.order.domain.OrderItem; import cn.itcast.commons.CommonUtils; import cn.itcast.jdbc.TxQueryRunner; public class OrderDao { private QueryRunner qr = new TxQueryRunner(); /** * 添加订单 * @param order */ public void addOrder(Order order) { try { String sql = "insert into orders values(?,?,?,?,?,?)"; /* * 处理util的Date转换成sql的Timestamp */ Timestamp timestamp = new Timestamp(order.getOrdertime().getTime()); Object[] params = {order.getOid(), timestamp, order.getTotal(), order.getState(), order.getOwner().getUid(), order.getAddress()}; qr.update(sql, params); } catch(SQLException e) { throw new RuntimeException(e); } } /** * 插入订单条目 * @param orderItemList */ public void addOrderItemList(List<OrderItem> orderItemList) { /** * QueryRunner类的batch(String sql, Object[][] params) * 其中params是多个一维数组！ * 每个一维数组都与sql在一起执行一次，多个一维数组就执行多次 */ try { String sql = "insert into orderitem values(?,?,?,?,?)"; /* * 把orderItemList转换成两维数组 * 把一个OrderItem对象转换成一个一维数组 */ Object[][] params = new Object[orderItemList.size()][]; // 循环遍历orderItemList，使用每个orderItem对象为params中每个一维数组赋值 for(int i = 0; i < orderItemList.size(); i++) { OrderItem item = orderItemList.get(i); params[i] = new Object[]{item.getIid(), item.getCount(), item.getSubtotal(), item.getOrder().getOid(), item.getBook().getBid()}; } qr.batch(sql, params);//执行批处理 } catch(SQLException e) { throw new RuntimeException(e); } } /** * 按uid查询订单 * @param uid * @return */ public List<Order> findByUid(String uid) { /* * 1. 通过uid查询出当前用户的所有List<Order> * 2. 循环遍历每个Order，为其加载他的所有OrderItem */ try { /* * 1. 得到当前用户的所有订单 */ String sql = "select * from orders where uid=?"; List<Order> orderList = qr.query(sql, new BeanListHandler<Order>(Order.class), uid); /* * 2. 循环遍历每个Order，为其加载它自己所有的订单条目 */ for(Order order : orderList) { loadOrderItems(order);//为order对象添加它的所有订单条目 } /* * 3. 返回订单列表 */ return orderList; } catch(SQLException e) { throw new RuntimeException(e); } } /** * 加载指定的订单所有的订单条目 * @param order * @throws SQLException */ private void loadOrderItems(Order order) throws SQLException { /* * 查询两张表：orderitem、book */ String sql = "select * from orderitem i, book b where i.bid=b.bid and oid=?"; /* * 因为一行结果集对应的不再是一个javabean，所以不能再使用BeanListHandler，而是MapListHandler */ List<Map<String,Object>> mapList = qr.query(sql, new MapListHandler(), order.getOid()); /* * mapList是多个map，每个map对应一行结果集 * 一行： * {iid=C7AD5492F27D492189105FB50E55CBB6, count=2, subtotal=60.0, oid=1AE8A70354C947F8B81B80ADA6783155, bid=7, bname=精通Hibernate,price=30.0, author=张卫琴, image=book_img/8991366-1_l.jpg, cid=2} * ... * * 我们需要使用一个Map生成两个对象：OrderItem、Book，然后再建立两者的关系（把Book设置给OrderItem） */ /* * 循环遍历每个Map，使用map生成两个对象，然后建立关系（最终结果一个OrderItem），把OrderItem保存起来 */ List<OrderItem> orderItemList = toOrderItemList(mapList); order.setOrderItemList(orderItemList); } /** * 把mapList中每个Map转换成两个对象，并建立关系 * @param mapList * @return */ private List<OrderItem> toOrderItemList(List<Map<String, Object>> mapList) { List<OrderItem> orderItemList = new ArrayList<OrderItem>(); for(Map<String,Object> map : mapList) { OrderItem item = toOrderItem(map); orderItemList.add(item); } return orderItemList; } /** * 把一个Map转换成一个OrderItem对象 * @param map * @return */ private OrderItem toOrderItem(Map<String, Object> map) { OrderItem orderItem = CommonUtils.toBean(map, OrderItem.class); Book book = CommonUtils.toBean(map, Book.class); orderItem.setBook(book); return orderItem; } /** * 修改订单状态 * @param oid * @param status * @throws SQLException */ public void updateStatus(String oid, int status) throws SQLException { String sql = "update orders set state=? where oid=?"; qr.update(sql, status, oid); } /** * 查询订单状态 * @param oid * @return * @throws SQLException */ public int findStatus(String oid) throws SQLException { String sql = "select state from orders where oid=?"; Number number = (Number)qr.query(sql, new ScalarHandler(), oid); return number.intValue(); } /** * 加载订单 * @param oid * @return */ public Order load(String oid) { try { /* * 1. 得到当前用户的所有订单 */ String sql = "select * from orders where oid=?"; Order order = qr.query(sql, new BeanHandler<Order>(Order.class), oid); /* * 2. 为order加载它的所有条目 */ loadOrderItems(order); /* * 3. 返回订单列表 */ return order; } catch(SQLException e) { throw new RuntimeException(e); } } /** * 通过oid查询订单状态 * @param oid * @return */ public int getStateByOid(String oid) { try { String sql = "select state from orders where oid=?"; return (Integer)qr.query(sql, new ScalarHandler(), oid); } catch(SQLException e) { throw new RuntimeException(e); } } /** * 修改订单状态 * @param oid * @param state * @return */ public void updateState(String oid, int state) { try { String sql = "update orders set state=? where oid=?"; qr.update(sql, state, oid); } catch(SQLException e) { throw new RuntimeException(e); } } public void updateAddress(String oid, String address) { try { String sql = "update orders set address=? where oid=?"; qr.update(sql,address, oid); } catch(SQLException e) { throw new RuntimeException(e); } } /** * 查询所有订单 * @return */ public List<Order> findAll() { try { String sql = "select * from orders"; System.out.println(sql); return qr.query(sql, new BeanListHandler<Order>(Order.class)); } catch(SQLException e) { throw new RuntimeException(e); } } }