Open Source Repository

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



org/hibernate/sql/OracleJoinFragment.java
//$Id: OracleJoinFragment.java 6750 2005-05-11 15:26:04Z oneovthafew $
package org.hibernate.sql;

import java.util.HashSet;
import java.util.Set;

/**
 * An Oracle-style (theta) join
 *
 @author Jon Lipsky, Gavin King
 */
public class OracleJoinFragment extends JoinFragment {

  private StringBuffer afterFrom = new StringBuffer();
  private StringBuffer afterWhere = new StringBuffer();

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

    addCrossJointableName, alias );

    for int j = 0; j < fkColumns.length; j++ ) {
      setHasThetaJoinstrue );
      afterWhere.append" and " )
          .appendfkColumns[j] );
      if joinType == RIGHT_OUTER_JOIN || joinType == FULL_JOIN afterWhere.append"(+)" );
      afterWhere.append'=' )
          .appendalias )
          .append'.' )
          .appendpkColumns[j] );
      if joinType == LEFT_OUTER_JOIN || joinType == FULL_JOIN afterWhere.append"(+)" );
    }

  }

  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() {
    OracleJoinFragment copy = new OracleJoinFragment();
    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) {
    throw new UnsupportedOperationException();
  }

  public boolean addCondition(String condition) {
    return addConditionafterWhere, condition );
  }

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

  public void addJoin(String tableName, String alias, String[] fkColumns, String[] pkColumns, int joinType, String on) {
    //arbitrary on clause ignored!!
    addJointableName, alias, fkColumns, pkColumns, joinType );
    if joinType == JoinFragment.INNER_JOIN ) {
      addConditionon );
    }
    else if joinType == JoinFragment.LEFT_OUTER_JOIN ) {
      addLeftOuterJoinConditionon );
    }
    else {
      throw new UnsupportedOperationException"join type not supported by OracleJoinFragment (use Oracle9Dialect)" );
    }
  }

  /**
   * This method is a bit of a hack, and assumes
   * that the column on the "right" side of the
   * join appears on the "left" side of the
   * operator, which is extremely wierd if this
   * was a normal join condition, but is natural
   * for a filter.
   */
  private void addLeftOuterJoinCondition(String on) {
    StringBuffer buf = new StringBufferon );
    for int i = 0; i < buf.length(); i++ ) {
      char character = buf.charAt);
      boolean isInsertPoint = OPERATORS.containsnew Charactercharacter ) ) ||
          character == ' ' && buf.length() > i + && "is ".equalsbuf.substringi + 1, i + ) ) );
      if isInsertPoint ) {
        buf.inserti, "(+)" );
        i += 3;
      }
    }
    addConditionbuf.toString() );
  }

  private static final Set OPERATORS = new HashSet();

  static {
    OPERATORS.addnew Character'=' ) );
    OPERATORS.addnew Character'<' ) );
    OPERATORS.addnew Character'>' ) );
  }
}