cpgqdao.java

这个程序是花了好几十万请人开发的

package javabean;

import java.util.Vector;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Collection;
import java.util.ArrayList;

import struts.form.Cpgq;

public class CpgqDAO {
	
	private static Connection con;
	
	public CpgqDAO(Connection con)
	{
		this.con=con;
	}

	
	public void update(String sql) throws CreateException{
    	
		PreparedStatement ps=null;
   
		try
		{
			if(con.isClosed())
			{
				throw new IllegalStateException("error.unexpected");    
			}
        	
			ps=con.prepareStatement(sql);        	
			
			if(ps.executeUpdate()!=1)
			{
				throw new CreateException("error.create.attraction");
			}
		}
		catch(SQLException e)
		{
			e.printStackTrace();
			throw new RuntimeException("error.unexpected");
		}
		finally
		{
			try
			{
				if(ps!=null)  ps.close();
			}
			catch(SQLException e)
			{
				e.printStackTrace();
				throw new RuntimeException("error.unexpected");
			}
		}       
	}
	    
	public static Cpgq findByPrimaryKey(int Id)
	throws FinderException{
    	
		PreparedStatement ps=null;
		ResultSet rs=null;
		Cpgq cpgq=null;
		
		String sql="SELECT * from CPGQB WHERE ID=?";
		
		try
		{
			if(con.isClosed())
			{
				throw new IllegalStateException("error.unexpected");    
			}
			
			ps=con.prepareStatement(sql);
			ps.setInt(1,Id);
			rs=ps.executeQuery();
			
			if(rs.next())
			{				
				cpgq=new Cpgq();
				cpgq.setID(rs.getInt(1));		
				cpgq.setUUID(rs.getString(2));	
				cpgq.setNAME(rs.getString(3));	
				cpgq.setSTYPE(rs.getString(4));	
				cpgq.setKIND(rs.getString(5));	
				cpgq.setDESCRIBE(rs.getString(6));
				cpgq.setSPEC(rs.getString(7));
				cpgq.setAREA(rs.getString(8));
				cpgq.setQUANTITY(rs.getInt(9));
				cpgq.setPRICE(rs.getString(10));
				cpgq.setFBDATE(rs.getString(11));
				cpgq.setEDATE(rs.getString(12));
				cpgq.setFLAG(rs.getString(13));	
     			cpgq.setPHOTO(rs.getString(14));
				return cpgq;
			 }
			 else
			 {
				 throw new ObjectNotFoundException("error.removed.attraction");
			 }      
	     }
	     catch(SQLException e)
	     {
	         e.printStackTrace();
	         throw new RuntimeException("error.unexpected");
	     }
	     finally
	     {
		     try
		     {
		         if(ps!=null)  ps.close();
		         if(rs!=null)  rs.close();
		     }
		     catch(SQLException e)
		     {
		         e.printStackTrace();
		         throw new RuntimeException("error.unexpected");
	         }
	     }
    }
    
	public Collection findAll(String sql){
    	
		PreparedStatement ps=null;
		ResultSet rs=null;
		ArrayList list=new ArrayList();
    	   	
		try
		{
			if(con.isClosed())
			{
				throw new IllegalStateException("error.unexpected");
			}
    		
			ps=con.prepareStatement(sql);
			rs=ps.executeQuery();
    		
			while(rs.next())
			{
				Cpgq cpgq=new Cpgq();
				cpgq.setID(rs.getInt(1));		
				cpgq.setUUID(rs.getString(2));	
				cpgq.setNAME(rs.getString(3));	
				cpgq.setSTYPE(rs.getString(4));	
				cpgq.setKIND(rs.getString(5));	
				cpgq.setDESCRIBE(rs.getString(6));
				cpgq.setSPEC(rs.getString(7));
				cpgq.setAREA(rs.getString(8));
				cpgq.setQUANTITY(rs.getInt(9));
				cpgq.setPRICE(rs.getString(10));
				cpgq.setFBDATE(rs.getString(11));
				cpgq.setEDATE(rs.getString(12));
				cpgq.setFLAG(rs.getString(13));
				cpgq.setPHOTO(rs.getString(14));
				cpgq.setCOMPANY(rs.getString(15));
				
				list.add(cpgq);
			}    		
			return list;    		
		}
		catch(SQLException e)
		{
		    e.printStackTrace();
		    throw new RuntimeException("error.unexpected");
		} 
		finally
		{
		    try
		    {
		        if(ps!=null)  ps.close();
		        if(rs!=null)  rs.close();
		    }
		    catch(SQLException e)
		    {
		        e.printStackTrace();
		        throw new RuntimeException("error.unexpected");
		    }
		}	
	}
	
	public Vector find_fenye(int code,int pagesize,String str){
    	
		PreparedStatement ps=null;
		ResultSet rs=null;
		Vector vec=new Vector();

		try
		{
			if(con.isClosed())
			{
				throw new IllegalStateException("error.unexpected");
			}
			int count=pagesize;
				
			rs=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY).executeQuery(str);
			rs.absolute((code-1)*pagesize+1);
			while(count>0)
			{
				Cpgq cpgq=new Cpgq();
				cpgq.setID(rs.getInt(1));		
				cpgq.setUUID(rs.getString(2));	
				cpgq.setNAME(rs.getString(3));	
				cpgq.setSTYPE(rs.getString(4));	
				cpgq.setKIND(rs.getString(5));	
				cpgq.setDESCRIBE(rs.getString(6));
				cpgq.setSPEC(rs.getString(7));
				cpgq.setAREA(rs.getString(8));
				cpgq.setQUANTITY(rs.getInt(9));
				cpgq.setPRICE(rs.getString(10));
				cpgq.setFBDATE(rs.getString(11));
				cpgq.setEDATE(rs.getString(12));
				cpgq.setFLAG(rs.getString(13));
				cpgq.setPHOTO(rs.getString(14));
				cpgq.setCOMPANY(rs.getString(15));
					
				vec.add(cpgq);
				count--;
				if(!rs.next())	break;
			}   		
			return vec;    		
		}
		catch(SQLException e)
		{
			e.printStackTrace();
			throw new RuntimeException("error.unexpected");
		} 
		finally
		{
			try
			{
			    if(ps!=null)  ps.close();
			    if(rs!=null)  rs.close();
			}
			catch(SQLException e)
			{
			    e.printStackTrace();
			    throw new RuntimeException("error.unexpected");
		    }
		}	
	}
	
	public void remove(String sql) throws CreateException{
    	
			PreparedStatement ps=null;
    
			try
			{
				if(con.isClosed())
				{
					throw new IllegalStateException("error.unexpected");    
				}       	
				ps=con.prepareStatement(sql);       	
				if(ps.executeUpdate()!=1)
				{
					throw new NoSuchEntityException("error.removed.attraction");
				}
			}
			catch(SQLException e)
			{
				e.printStackTrace();
				throw new RuntimeException("error.unexpected");
			}
			finally
			{
				try
				{
					if(ps!=null)  ps.close();
				}
				catch(SQLException e)
				{
					e.printStackTrace();
					throw new RuntimeException("error.unexpected");
				}
			}       
	}	
}