Open Source Repository

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


org/hibernate/hql/ast/exec/BasicExecutor.java
// $Id: BasicExecutor.java 15240 2008-10-01 19:32:11Z [email protected] $
package org.hibernate.hql.ast.exec;

import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Iterator;
import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.engine.QueryParameters;
import org.hibernate.engine.RowSelection;
import org.hibernate.engine.SessionImplementor;
import org.hibernate.exception.JDBCExceptionHelper;
import org.hibernate.hql.ast.HqlSqlWalker;
import org.hibernate.hql.ast.QuerySyntaxException;
import org.hibernate.hql.ast.SqlGenerator;
import org.hibernate.param.ParameterSpecification;
import org.hibernate.persister.entity.Queryable;

import antlr.RecognitionException;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
 * Implementation of BasicExecutor.
 *
 @author Steve Ebersole
 */
public class BasicExecutor extends AbstractStatementExecutor {
  private static final Log log = LogFactory.getLogBasicExecutor.class );

  private final Queryable persister;
  private final String sql;
  private final List parameterSpecifications;

  public BasicExecutor(HqlSqlWalker walker, Queryable persister) {
    superwalker, log );
    this.persister = persister;
    try {
      SqlGenerator gen = new SqlGeneratorgetFactory() );
      gen.statementwalker.getAST() );
      sql = gen.getSQL();
      gen.getParseErrorHandler().throwQueryException();
      parameterSpecifications = gen.getCollectedParameters();
    }
    catch RecognitionException e ) {
      throw QuerySyntaxException.convert);
    }
  }

  public String[] getSqlStatements() {
    return new String[] { sql };
  }

  public int execute(QueryParameters parameters, SessionImplementor sessionthrows HibernateException {

    coordinateSharedCacheCleanupsession );

    PreparedStatement st = null;
    RowSelection selection = parameters.getRowSelection();

    try {
      try {
        st = session.getBatcher().prepareStatementsql );
        Iterator parameterSpecifications = this.parameterSpecifications.iterator();
        int pos = 1;
        while parameterSpecifications.hasNext() ) {
          final ParameterSpecification paramSpec = ParameterSpecification parameterSpecifications.next();
          pos += paramSpec.bindst, parameters, session, pos );
        }
        if selection != null ) {
          if selection.getTimeout() != null ) {
            st.setQueryTimeoutselection.getTimeout().intValue() );
          }
        }

        return st.executeUpdate();
      }
      finally {
        if st != null ) {
          session.getBatcher().closeStatementst );
        }
      }
    }
    catchSQLException sqle ) {
      throw JDBCExceptionHelper.convert(
          getFactory().getSQLExceptionConverter(),
              sqle,
              "could not execute update query",
              sql
        );
    }
  }

  protected Queryable[] getAffectedQueryables() {
    return new Queryable[] { persister };
  }
}