Open Source Repository

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



org/hibernate/sql/QueryJoinFragment.java
//$Id: QueryJoinFragment.java 4889 2004-12-05 17:20:21Z pgmjsd $
package org.hibernate.sql;

import org.hibernate.dialect.Dialect;

/**
 * A join that appears in a translated HQL query
 *
 @author Gavin King
 */
public class QueryJoinFragment extends JoinFragment {

  private StringBuffer afterFrom = new StringBuffer();
  private StringBuffer afterWhere = new StringBuffer();
  private Dialect dialect;
  private boolean useThetaStyleInnerJoins;

  public QueryJoinFragment(Dialect dialect, boolean useThetaStyleInnerJoins) {
    this.dialect = dialect;
    this.useThetaStyleInnerJoins = useThetaStyleInnerJoins;
  }

  public void addJoin(String tableName, String alias, String[] fkColumns, String[] pkColumns, int joinType) {
    addJointableName, alias, alias, fkColumns, pkColumns, joinType, null );
  }

  public void addJoin(String tableName, String alias, String[] fkColumns, String[] pkColumns, int joinType, String on) {
    addJointableName, alias, alias, fkColumns, pkColumns, joinType, on );
  }

  private void addJoin(String tableName, String alias, String concreteAlias, String[] fkColumns, String[] pkColumns, int joinType, String on) {
    if !useThetaStyleInnerJoins || joinType != INNER_JOIN ) {
      JoinFragment jf = dialect.createOuterJoinFragment();
      jf.addJointableName, alias, fkColumns, pkColumns, joinType, on );
      addFragmentjf );
    }
    else {
      addCrossJointableName, alias );
      addConditionconcreteAlias, fkColumns, pkColumns );
      addConditionon );
    }
  }

  public String toFromFragmentString() {
    return afterFrom.toString();
  }

  public String toWhereFragmentString() {
    return afterWhere.toString();
  }

  public void addJoins(String fromFragment, String whereFragment) {
    afterFrom.appendfromFragment );
    afterWhere.appendwhereFragment );
  }

  public JoinFragment copy() {
    QueryJoinFragment copy = new QueryJoinFragmentdialect, useThetaStyleInnerJoins );
    copy.afterFrom = new StringBufferafterFrom.toString() );
    copy.afterWhere = new StringBufferafterWhere.toString() );
    return copy;
  }

  public void addCondition(String alias, String[] columns, String condition) {
    for int i = 0; i < columns.length; i++ ) {
      afterWhere.append" and " )
          .appendalias )
          .append'.' )
          .appendcolumns[i] )
          .appendcondition );
    }
  }


  public void addCrossJoin(String tableName, String alias) {
    afterFrom.append", " )
        .appendtableName )
        .append' ' )
        .appendalias );
  }

  public void addCondition(String alias, String[] fkColumns, String[] pkColumns) {
    for int j = 0; j < fkColumns.length; j++ ) {
      afterWhere.append" and " )
          .appendfkColumns[j] )
          .append'=' )
          .appendalias )
          .append'.' )
          .appendpkColumns[j] );
    }
  }

  /**
   * Add the condition string to the join fragment.
   *
   @param condition
   @return true if the condition was added, false if it was already in the fragment.
   */
  public boolean addCondition(String condition) {
    // if the condition is not already there...
    if (
        afterFrom.toString().indexOfcondition.trim() ) &&
        afterWhere.toString().indexOfcondition.trim() ) 0
    ) {
      if !condition.startsWith" and " ) ) {
        afterWhere.append" and " );
      }
      afterWhere.appendcondition );
      return true;
    }
    else {
      return false;
    }
  }

  public void addFromFragmentString(String fromFragmentString) {
    afterFrom.appendfromFragmentString );
  }

  public void clearWherePart() {
    afterWhere.setLength);
  }
}