Programación Web - Dynamic Proxy

Cliente.java

/**
 * Facultad Politécnica - Ingeniería en Informática. 
 * Programación Web - Dynamic Proxy
 *
 * Ejercicio de como utilizar Dynamic Proxy
 *
 * @author mbaez
 */
public class Cliente {

    /**
     * Se encarga de guardar un producto
     *
     * @param p El nuevo producto
     */
    public void guardar(Producto p){
        // do someting
        ProductoDAO dao = (ProductoDAO) TransactionProxy.newInstance(new ProductoDAOImpl());
        dao.persit(p);
        //do someting
    }
    
}

Producto.java

/**
 * Facultad Politécnica - Ingeniería en Informática.
 * Programación Web - Dynamic Proxy
 * 
 * Ejercicio de como utilizar Dynamic Proxy
 * 
 * @author mbaez
 */
public class Producto {
    // atributos
}

ProductoDAO.java

/**
 * Facultad Politécnica - Ingeniería en Informática.
 * Programación Web - Dynamic Proxy
 * 
 * Ejercicio de como utilizar Dynamic Proxy
 * 
 * @author mbaez
 */
public interface ProductoDAO {

    /**
     * Inserta en la base de datos un producto específico.
     *
     * @param p Nuevo producto
     */
    public void persit(Producto p);
}

ProductoDAOImpl.java

/**
 * Facultad Politécnica - Ingeniería en Informática.
 * Programación Web - Dynamic Proxy
 * 
 * Ejercicio de como utilizar Dynamic Proxy
 * 
 * @author mbaez
 */
public class ProductoDAOImpl implements ProductoDAO{
    /**
     * {@inheritDoc}
     */
    @Override
    public void persit(Producto p) {
        // do someting
    }
}

TransactionProxy.java

/**
 * Facultad Politécnica - Ingeniería en Informática. 
 * Programación Web - Dynamic Proxy
 *
 * Ejercicio de como utilizar Dynamic Proxy
 *
 * @author mbaez
 */
public class TransactionProxy implements InvocationHandler {

    /**
     * Referencia al Dao
     */
    private Object obj;

    /**
     * Método encargado de crear una nueva instancia del proxy.
     *
     * @param obj Referencia al DAO
     * @return una instancia del proxy
     */
    public static Object newInstance(Object obj) {
        return java.lang.reflect.Proxy.newProxyInstance(
                obj.getClass().getClassLoader(),
                obj.getClass().getInterfaces(),
                new TransactionProxy(obj));
    }

    /**
     * Constructor privado del proxy
     *
     * @param obj
     */
    private TransactionProxy(Object obj) {
        this.obj = obj;
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        Object result;
        Session session = null;
        Transaction tx = null;
        
        try {
            session = HibernateUtil.getSessionFactory().openSession();
            //inicia la transacción
            tx = session.beginTransaction();
            //se invoca al método del dao
            result = method.invoke(obj, args);
            //se intenta realizar el commit
            tx.commit();

        } catch (RuntimeException e) {
            //si ocurrio un error se hace rollback de la transacción
            tx.rollback();
            throw e;
        } finally {
            //se cierra la sesión
            if (session != null) {
                session.close();
            }
        }
        return result;
    }
}