cpgqbo.java

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

package javabean;

import java.sql.SQLException;
import java.sql.Connection;

import javabean.ConnectionPool;
import javabean.CpgqDAO;

public class CpgqBO {
	
	private ConnectionPool pool;
	
	public CpgqBO() 
	{
		pool=ConnectionPool.getInstance();
	}
	
	public void update(String sql)
	throws CpgqException{
				
		Connection con=null;
		
		try
		{			
			con=pool.getConnection();			
			CpgqDAO cpgqDAO=new CpgqDAO(con);
			cpgqDAO.update(sql);			
			con.commit();
		}
		catch(Exception e) 
		{
			try
			{
				if(con!=null)
				{
					con.rollback();
					throw new CpgqException(e.getMessage());
				}
			}
			catch(SQLException sqle)
			{
				e.printStackTrace();
				throw new RuntimeException("error.unexpected");
			}
		}
		finally
		{
		    try
		    {
			    if(con!=null)  con.close();
		    }
		    catch(SQLException sqle)
		    {
			    sqle.printStackTrace();
			    throw new RuntimeException("error.unexpected");
		    }
	    }		
	}
	
	
	public void removeCpgq(String sql)
	throws CpgqException{
				
		Connection con=null;
		
		try
		{			
			con=pool.getConnection();			
			CpgqDAO cpgqDAO=new CpgqDAO(con);
			cpgqDAO.remove(sql);			
			con.commit();
		}
		catch(Exception e) 
		{
			try
			{
				if(con!=null)
				{
					con.rollback();
					throw new CpgqException(e.getMessage());
				}
			}
			catch(SQLException sqle)
			{
				e.printStackTrace();
				throw new RuntimeException("error.unexpected");
			}
		}
		finally
		{
		    try
		    {
			    if(con!=null)  con.close();
		    }
		    catch(SQLException sqle)
		    {
			    sqle.printStackTrace();
			    throw new RuntimeException("error.unexpected");
		    }
	    }
    }	
}