Open Source Repository

Home /hibernate/hibernate-3.2.4.ga | Repository Home


org/hibernate/persister/entity/NamedQueryLoader.java
//$Id: NamedQueryLoader.java 10019 2006-06-15 07:50:12Z [email protected] $
package org.hibernate.persister.entity;

import java.io.Serializable;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.hibernate.FlushMode;
import org.hibernate.HibernateException;
import org.hibernate.engine.EntityKey;
import org.hibernate.engine.SessionImplementor;
import org.hibernate.impl.AbstractQueryImpl;
import org.hibernate.loader.entity.UniqueEntityLoader;

/**
 * Not really a <tt>Loader</tt>, just a wrapper around a
 * named query.
 @author Gavin King
 */
public final class NamedQueryLoader implements UniqueEntityLoader {
  private final String queryName;
  private final EntityPersister persister;
  
  private static final Log log = LogFactory.getLog(NamedQueryLoader.class);

  public NamedQueryLoader(String queryName, EntityPersister persister) {
    super();
    this.queryName = queryName;
    this.persister = persister;
  }

  public Object load(Serializable id, Object optionalObject, SessionImplementor session
  throws HibernateException {
    
    if log.isDebugEnabled() ) {
      log.debug(
          "loading entity: " + persister.getEntityName() 
          " using named query: " + queryName 
        );
    }
    
    AbstractQueryImpl query = (AbstractQueryImplsession.getNamedQuery(queryName);
    if query.hasNamedParameters() ) {
      query.setParameter
          query.getNamedParameters()[0]
          id, 
          persister.getIdentifierType() 
        );
    }
    else {
      query.setParameter0, id, persister.getIdentifierType() );
    }
    query.setOptionalId(id);
    query.setOptionalEntityNamepersister.getEntityName() );
    query.setOptionalObject(optionalObject);
    query.setFlushModeFlushMode.MANUAL );
    query.list();
    
    // now look up the object we are really interested in!
    // (this lets us correctly handle proxies and multi-row
    // or multi-column queries)
    return session.getPersistenceContext()
        .getEntitynew EntityKeyid, persister, session.getEntityMode() ) );

  }
}