Linked

admin · paseos de una lado a otro

  
    javax.faces.STATE_SAVING_METHOD
    client
  

public class JBPMWorkflowService implements WorkflowService{
(...)
public net.javahispano.ocas.workflow.Process startProcess(String processName, String usr) {
        JbpmSession jbpmSession = jbpmSessionFactory.openJbpmSession();
        org.jbpm.graph.def.ProcessDefinition definition = jbpmSession
                .getGraphSession()
                .findLatestProcessDefinition(processName);
        ProcessInstance jbpmProcess = new ProcessInstance(definition);
        jbpmSession.getGraphSession().saveProcessInstance(jbpmProcess);
        jbpmSession.close();
        JBPMProcess proceso = new JBPMProcess(jbpmProcess);
        return proceso;
    }
}

public class JBPMProcess implements Process{
(...)
public Map getVariables(){
        JbpmSession sesion = wfService.getJbpmSession();
        ProcessInstance process = sesion.getGraphSession()
                .loadProcessInstance(processInstance.getId());
        Map result = process.getContextInstance().getVariables();
        wfService.closeJbpmSession(sesion);
        return result;
}

public class JBPMProcessTransaction implements ProcessTransaction{
    private JbpmSessionFactory sesionFactory;
    private JbpmSession jbpmSession;
    private Session hibernateSession;

   (..)

    public void open() {

        if(jbpmSession.getCurrentJbpmSession() == null){
            jbpmSession = sesionFactory.openJbpmSession();
        }else{
            jbpmSession = jbpmSession.getCurrentJbpmSession();
        }
        jbpmSession.beginTransaction();
        jbpmSession.getSession().disconnect();

    }
}

public Map getVariables(){
        JbpmSession sesion = JbpmSession.getCurrentJbpmSession();
        sesion.getSession().reconnect();

        Map result = processInstance.getContextInstance().getVariables();
        sesion.getSession().disconnect();
        return result;
}

ProcessTransaction transaction = new JBPMProcessTransaction();
transaction.open();
wfservice.deployProcessDefinition(processDefinition);
net.javahispano.ocas.workflow.Process proceso = wfservice.startProcess("TestModel", "Test");
wfservice.stateEnded(proceso);

assertEquals(proceso.getVariable(JBPMProcessDefinition.AUTHOR), "Test");
assertEquals(proceso.getVariable(JBPMProcessDefinition.DESCRIPTION), "Test description");
transaction.commitAndClose();

public Map getVariables(){
        JbpmSession sesion = wfService.getJbpmSession();
        ProcessInstance process = sesion.getGraphSession().loadProcessInstance(processInstance.getId());
        Map result = process.getContextInstance().getVariables();
        wfService.closeJbpmSession(sesion);
        return result;
}

producto.getVendedores(2).getName();
public class HibernateUtil {
    private static Configuration configuration;
    private static SessionFactory sessionFactory;
    private static final ThreadLocal threadSession = new ThreadLocal();
    private static final ThreadLocal threadTransaction = new ThreadLocal();
    private static final ThreadLocal threadInterceptor = new ThreadLocal();
    (...)

    /**
     * Retrieves the current Session local to the thread.
     *
     * If no Session is open, opens a new Session for the running thread.
     *
     * @return Session
     */
   public static Session getSession() throws InfrastructureException {
        Session s = (Session) threadSession.get();
        try {
            if (s == null) {
                if (getInterceptor() != null) {
                    s = getSessionFactory().openSession(getInterceptor());
                } else {
                    s = getSessionFactory().openSession();

                }
                threadSession.set(s);
            }
        } catch (HibernateException ex) {
            throw new InfrastructureException(ex);
        }
        return s;
    }

    /**
     * Closes the Session local to the thread.
     */
    public static void closeSession()throws InfrastructureException {
        try {
            Session s = (Session) threadSession.get();
            threadSession.set(null);
            if (s != null && s.isOpen()) {
                s.close();
            }
        } catch (HibernateException ex) {
            throw new InfrastructureException(ex);
        }
    }

(...)
/**
     * Register a Hibernate interceptor with the current thread.
     *
     * Every Session opened is opened with this interceptor after
     * registration. Has no effect if the current Session of the
     * thread is already open, effective on next close()/getSession().
     */
    public static void registerInterceptor(Interceptor interceptor) {

        threadInterceptor.set(interceptor);
    }

    private static Interceptor getInterceptor() {
        Interceptor interceptor = (Interceptor) threadInterceptor.get();
        return interceptor;
    }

HibernateUtil.beginTransaction()
Query query = HibernateUtil.getSession().getNamedQuery("query1");
result = query.setEntity("usuario", usuario).list();
return result;

public class HibernateFilter implements Filter {


    private static Log log = LogFactory.getLog(HibernateFilter.class);

    public void init(FilterConfig filterConfig) throws ServletException {
        log.info("Servlet filter init, now opening/closing a Session for each request.");
    }


    public void doFilter(ServletRequest request,
                         ServletResponse response,
                         FilterChain chain)
            throws IOException, ServletException {


        // There is actually no explicit "opening" of a Session, the
        // first call to HibernateUtil.beginTransaction() in control
        // logic (e.g. use case controller/event handler) will get

        // a fresh Session.
        try {
            chain.doFilter(request, response);

            // Commit any pending database transaction.

            HibernateUtil.commitTransaction();

        } finally {

            // No matter what happens, close the Session.
            HibernateUtil.closeSession();


        }
    }

try {
    factory.getCurrentSession().beginTransaction();

    // Do some work
    factory.getCurrentSession().load(...);

    factory.getCurrentSession().persist(...);

    factory.getCurrentSession().getTransaction().commit();
}
catch (RuntimeException e) {
    factory.getCurrentSession().getTransaction().rollback();

    throw e; // or display error message
}
 // Do some work
factory.getCurrentSession().load(...);
factory.getCurrentSession().persist(...);


        product.hbm.xml
      

        net.sf.hibernate.dialect.MySQLDialect

      
  …
  

public class ProductDaoImpl implements ProductDao {
    private SessionFactory sessionFactory;
    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }

public Collection loadProductsByCategory(final String category) throws DataAccessException {
    HibernateTemplate ht = new HibernateTemplate(this.sessionFactory);
    return (Collection) ht.execute(new HibernateCallback() {
        public Object doInHibernate(Session session) throws HibernateException {
            Query query = session.createQuery("from test.Product product where product.category=?");
            query.setString(0, category);
            return query.list();
        }
    });
}

public class ProductDaoImpl extends HibernateDaoSupport implements ProductDao {
    public Collection loadProductsByCategory(String category) throws DataAccessException {
        return getHibernateTemplate().find(
            "from test.Product product where product.category=?", category);

    }
}

public class ProductDaoImpl extends HibernateDaoSupport implements ProductDao {
    public Collection loadProductsByCategory(String category)
            throws DataAccessException, MyException {

        Session session = getSession(getSessionFactory(), false);
        try {
            List result = session.find(
                "from test.Product product where product.category=?",

                category, Hibernate.STRING);
            if (result == null) {

                throw new MyException("invalid search result");
            }

            return result;
        }
        catch (HibernateException ex) {
            throw convertHibernateAccessException(ex);
        }

    }
}

public class ProductDaoImpl implements ProductDao {

    private SessionFactory sessionFactory;
    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }
    public Collection loadProductsByCategory(String category) {

        return this.sessionFactory.getCurrentSession()
                .createQuery("from test.Product product where product.category=?")
            .setParameter(0, category)
            .list();

  }
}

Linked

Archive for October, 2005

Una semana distinta

JSF: Excepciones más comunes y errores frecuentes

¿Dónde esta Linking Paths S.L.?

DENIM: deja de usar el boli!

Cuatro paredes y un techo

¿Como debería ser un CMS sencillo?

La solución a los problemas con jbpm: ¿Un nuevo patrón para usar hibernate?

Sesiones y transacciones en hibernate: el “problema” de tirar pa’arriba

¿Está Java Server Faces preparado para la vida real?, ¿ya?

Sesiones en Hibernate Vs Sesiones en Spring

Linked

Linking Camp

Busqueda

Ultimos comentarios

Ultimos artículos