ordermanage_dao.java

这是一个Struts网上商城(图书)的管理系统源代码.

package com.bookshop.dao;

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 com.bookshop.db.DBConnection;
import com.bookshop.dto.bookinfo_dto;
import com.bookshop.dto.order_dto;

public class orderManage_dao {
//	用户定单查询
	public ArrayList order_sel()
	{
		Connection conn=DBConnection.getConnection();
		Statement st=null;
		ResultSet rs=null;
		ArrayList list=new ArrayList();
		String sql="";
		try{
			sql="select * from tb_order";
			st=conn.createStatement();
			rs=st.executeQuery(sql);
			while(rs.next()){
				order_dto dto=new order_dto();
				dto.setOrderid(rs.getString("orderid"));
				dto.setBnumber(rs.getString("bnumber"));
				dto.setTruename(rs.getString("truename"));
				dto.setPay(rs.getString("pay"));
				dto.setCarry(rs.getString("carry"));
				dto.setRebate(rs.getString("rebate"));
				dto.setOrderdate(rs.getString("orderdate"));
				dto.setEnforce(Integer.parseInt(rs.getString("enforce")));
				list.add(dto);
			}
			
		}catch(SQLException e){e.printStackTrace();}
		
		finally{
			try{
				rs.close();
				st.close();
				conn.close();
			}catch(SQLException ex){ex.printStackTrace();}
		}
		return list;
	}
	
	
	//执行定单
	public int order_execute(String orderid){
		Connection conn=DBConnection.getConnection();
		Statement st=null;
		ResultSet rs=null;
		String sql="";
		int n=0;
		try{
			sql="update tb_order set enforce=1 where orderid="+orderid;
			st=conn.createStatement();
			n=st.executeUpdate(sql);
			System.out.print(sql);
			
		}catch(SQLException ex){ex.printStackTrace();}
		
		finally{
			try{
				
				st.close();
				conn.close();
			}catch(SQLException ex){ex.printStackTrace();}
		}
		
		
		return n;
		
		
	}
	
//	求分页最大页	
	public int maxpage(int pagesize)
	 {
	      
	      Connection conn=DBConnection.getConnection();
	      ResultSet r = null;
	      PreparedStatement pstm = null;
	      int rowcount=0;   //总记录数
	      int maxpage=0;
	     
	      
	      String countSql="select count(*) as t  from tb_order";
	     try {
	    	
	         pstm = conn.prepareStatement(countSql);
	         r = pstm.executeQuery();
	         while (r.next()) {
	             rowcount = r.getInt("t");
	           
		         if(rowcount%pagesize!=0)
		         {
		           maxpage=rowcount/pagesize+1;
		         }
		         else
		         {
		        	 maxpage=rowcount/pagesize;
		         }
	         }
	     }catch (SQLException ex) {
	            ex.printStackTrace();
	        } finally {          
	        	 try {
	        		 r.close();
	        		 pstm.close();
	                 conn.close();
	             } catch (SQLException ex1) { }                              
	        }
	      return maxpage;
	 }
	    
//求当前页码
	public ArrayList sel_order(int pagesize, int curpage) {
		 ArrayList list = new ArrayList();
	     Connection conn = DBConnection.getConnection();
	    
	     ResultSet rs = null;
	     PreparedStatement pstmt=null;
	     String selectSQL = "select * from tb_order";	     
	     int tip =pagesize * (curpage - 1);  //定位到指定的记录
	     
	     try {
	       pstmt = conn.prepareStatement(selectSQL, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
	     rs = pstmt.executeQuery();
	     System.out.print(tip);
	       if (tip <= 0) {
	           rs.beforeFirst();
	       } else {
	           if (!rs.absolute(tip)) {
	               rs.beforeFirst();
	           }
	       }
	       for (int i = 1; rs.next() && i <= pagesize; i++) {
				order_dto dto=new order_dto();
				dto.setOrderid(rs.getString("orderid"));
				dto.setBnumber(rs.getString("bnumber"));
				dto.setTruename(rs.getString("truename"));
				dto.setPay(rs.getString("pay"));
				dto.setCarry(rs.getString("carry"));
				dto.setRebate(rs.getString("rebate"));
				dto.setOrderdate(rs.getString("orderdate"));
				dto.setEnforce(Integer.parseInt(rs.getString("enforce")));
				list.add(dto);
			
	      }

	   
	        } catch (SQLException ex) {
	            ex.printStackTrace();
	        } finally {          
	        	 try {
	        		 rs.close();
	        		 pstmt.close();
	                 conn.close();
	             } catch (SQLException ex1) { }                              
	        }
	        return list;
			}

}