package org.hibernate.persister.entity;
import java.io.Serializable;
import org.hibernate.FlushMode;
import org.hibernate.LockOptions;
import org.hibernate.engine.spi.SharedSessionContractImplementor;
import org.hibernate.internal.CoreLogging;
import org.hibernate.internal.CoreMessageLogger;
import org.hibernate.loader.entity.UniqueEntityLoader;
import org.hibernate.query.internal.AbstractProducedQuery;
public final class NamedQueryLoader implements UniqueEntityLoader {
private static final CoreMessageLogger LOG = CoreLogging.messageLogger( NamedQueryLoader.class );
private final String queryName;
private final EntityPersister persister;
private final int position;
public NamedQueryLoader(String queryName, EntityPersister persister) {
super();
this.queryName = queryName;
this.persister = persister;
this.position = persister.getFactory().getSessionFactoryOptions().jdbcStyleParamsZeroBased()
? 0
: 1;
}
@Override
public Object load(Serializable id, Object optionalObject, SharedSessionContractImplementor session, LockOptions lockOptions) {
if ( lockOptions != null ) {
LOG.debug( "Ignoring lock-options passed to named query loader" );
}
return load( id, optionalObject, session );
}
@Override
public Object load(Serializable id, Object optionalObject, SharedSessionContractImplementor session) {
LOG.debugf( "Loading entity: %s using named query: %s", persister.getEntityName(), queryName );
final AbstractProducedQuery query = (AbstractProducedQuery) session.getNamedQuery( queryName );
if ( query.getParameterMetadata().hasNamedParameters() ) {
query.setParameter( query.getNamedParameters()[0], id, persister.getIdentifierType() );
}
else {
query.setParameter( position, id, persister.getIdentifierType() );
}
query.setOptionalId( id );
query.setOptionalEntityName( persister.getEntityName() );
query.setOptionalObject( optionalObject );
query.setFlushMode( FlushMode.MANUAL );
query.list();
return session.getPersistenceContext().getEntity( session.generateEntityKey( id, persister ) );
}
}