北大青鸟S2 easyBuy 答辩项目

package cn.jbit.esaybuy.daoimpl; import java.sql.*; import java.util.*; import cn.jbit.esaybuy.dao.BaseDao; import cn.jbit.esaybuy.dao.OrderData; import cn.jbit.esaybuy.entity.EasyBuyNews; import cn.jbit.esaybuy.entity.EasyBuyOrder; public class OrderDataImpl extends BaseDao implements OrderData { final int pageSize=5; public EasyBuyOrder selectOrader(int oraderId) { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; String sql = "select * from EASYBUY_ORDER where EO_ID=?"; con = getConnection(); EasyBuyOrder order = new EasyBuyOrder(); try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, oraderId); rs = pstmt.executeQuery(); if (rs.next()) { order.setEoId(rs.getInt(1)); order.setEoUserId(rs.getString(2)); order.setEoUserName(rs.getString(3)); order.setEoUserAddress(rs.getString(4)); order.setEoCreateTime(rs.getDate(5)); order.setEoCost(rs.getDouble(6)); } } catch (SQLException e) { e.printStackTrace(); } finally { closeAll(con, pstmt, rs); } return order; } public int insertOrder(EasyBuyOrder easyOrder) { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; String sql = "insert into easybuy_order values (easybuy_order_seq.nextval,?,?,?,sysdate,?,?,?)"; int result=0; con=super.getConnection(); try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, easyOrder.getEoId()); pstmt.setString(2, easyOrder.getEoUserName()); pstmt.setString(3, easyOrder.getEoUserAddress()); pstmt.setDouble(4, easyOrder.getEoCost()); pstmt.setInt(5, easyOrder.getEoStatus()); pstmt.setInt(6, easyOrder.getEoType()); result=pstmt.executeUpdate(); } catch (Exception e) { e.printStackTrace(); } finally { super.closeAll(con, pstmt, rs); } return result; } public int updateOrder(EasyBuyOrder easyOrder) { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; int result=0; String sql= "update easybuy_order set eo_user_id=?, eo_user_name=?, eo_user_address=?, eo_cost=?, eo_status=?, eo_type=? where eo_id=?"; con=super.getConnection(); try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, easyOrder.getEoId()); pstmt.setString(2, easyOrder.getEoUserName()); pstmt.setString(3, easyOrder.getEoUserAddress()); pstmt.setDouble(4, easyOrder.getEoCost()); pstmt.setInt(5, easyOrder.getEoStatus()); pstmt.setInt(6, easyOrder.getEoType()); pstmt.setInt(7, easyOrder.getEoId()); result=pstmt.executeUpdate(); } catch (Exception e) { e.printStackTrace(); } finally { super.closeAll(con, pstmt, rs); } return result; } public int deleteOrder(int orderId) { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; int result=0; String sql="delete easybuy_order where eo_id=?"; con=super.getConnection(); try { pstmt = con.prepareStatement(sql); pstmt.setInt(1, orderId); result=pstmt.executeUpdate(); } catch (Exception e) { e.printStackTrace(); } finally { super.closeAll(con, pstmt, rs); } return result; } public int maxOrder() { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; int max=0; String sql="select max(eo_id) from easybuy_order"; con=super.getConnection(); try{ pstmt=con.prepareStatement(sql); rs=pstmt.executeQuery(); if(rs.next()){ max=rs.getInt(1); } }catch (Exception e) { e.printStackTrace(); } finally{ super.closeAll(con, pstmt, rs); } return max; } /* * 查询所有留言 * @see cn.jbit.esaybuy.dao.OrderData#selectAllOrder() */ public List<EasyBuyOrder> selectAllOrder(int pageSize,int pageindex) { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; // TODO Auto-generated method stub EasyBuyOrder buyOrder = null; List<EasyBuyOrder> list = new ArrayList<EasyBuyOrder>(); con = super.getConnection(); String sql ="select * from (select rownum as r,t.* from (select * from easybuy_order order by eo_id desc) t where rownum <="+pageSize * pageindex+") where r>"+pageSize * (pageindex - 1); try { pstmt = con.prepareStatement(sql); rs = pstmt.executeQuery(); while(rs.next()){ buyOrder = new EasyBuyOrder(); buyOrder.setEoId(rs.getInt("eo_id")); buyOrder.setEoUserId(rs.getString("eo_user_id")); buyOrder.setEoUserName(rs.getString("eo_user_name")); buyOrder.setEoUserAddress(rs.getString("eo_user_address")); buyOrder.setEoCreateTime(rs.getDate("eo_create_time")); buyOrder.setEoCost(rs.getDouble("eo_cost")); buyOrder.setEoStatus(rs.getInt("eo_status")); buyOrder.setEoType(rs.getInt("eo_type")); list.add(buyOrder); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { super.closeAll(con, pstmt, rs); } return list; } /* * 查询一共有多少条记录 * @see cn.jbit.esaybuy.dao.OrderData#countPages() */ public int countPages() { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; // TODO Auto-generated method stub con = super.getConnection(); int count = 0; String sql = "select count(*) from easybuy_order"; try { pstmt = con.prepareStatement(sql); rs = pstmt.executeQuery(); while(rs.next()){ count = rs.getInt(1); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { super.closeAll(con, pstmt, rs); } return count; } /* * 按条件查询订单 * @see cn.jbit.esaybuy.dao.OrderData#orderCondition(java.lang.String) */ public int totalCondition(String str){ Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; int count=0; con=super.getConnection(); String sql="select count(*) from easybuy_order where " + str; try { pstmt = con.prepareStatement(sql); rs = pstmt.executeQuery(); if(rs.next()){ count=rs.getInt(1); } } catch (Exception e) { e.printStackTrace(); } finally{ super.closeAll(con, pstmt, rs); } return (count % pageSize == 0)? (count / pageSize) :(count / pageSize +1); } public List<EasyBuyOrder> orderCondition(String sql,int pageIndex) { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; con = super.getConnection(); EasyBuyOrder buyOrder = null; List<EasyBuyOrder> list = new ArrayList<EasyBuyOrder>(); String newsql = "select * from (select rownum as r,t.* from(select * from easybuy_order where " + sql+")t where rownum<="+(pageIndex*pageSize)+")where r>"+((pageIndex-1)*pageSize); try { pstmt = con.prepareStatement(newsql); rs = pstmt.executeQuery(); while(rs.next()){ buyOrder = new EasyBuyOrder(); buyOrder.setEoId(rs.getInt("eo_id")); buyOrder.setEoUserId(rs.getString("eo_user_id")); buyOrder.setEoUserName(rs.getString("eo_user_name")); buyOrder.setEoUserAddress(rs.getString("eo_user_address")); buyOrder.setEoCreateTime(rs.getDate("eo_create_time")); buyOrder.setEoCost(rs.getDouble("eo_cost")); buyOrder.setEoStatus(rs.getInt("eo_status")); buyOrder.setEoType(rs.getInt("eo_type")); list.add(buyOrder); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally{ super.closeAll(con, pstmt, rs); } return list; } /* * 改变订单状态 * @see cn.jbit.esaybuy.dao.OrderData#updateStatus(int) */ public int updateStatus(int Status,int id) { Connection con = null; PreparedStatement pstmt = null; ResultSet rs = null; con = super.getConnection(); int result = 0; String sql = "update easybuy_order set eo_status = ? where eo_id = ?"; try { pstmt = con.pre