influxdata/influxdb-java

package org.influxdb.querybuilder;

import org.influxdb.querybuilder.clauses.Clause;
import org.influxdb.querybuilder.clauses.FromClause;
import org.influxdb.querybuilder.clauses.RawTextClause;

public class SelectQueryImpl extends BuiltQuery implements SelectWithSubquery {

  private final SelectCoreImpl<WhereQueryImpl> selectCore;

  SelectQueryImpl(
      final String database, final boolean requiresPost, final SelectionCoreImpl selectionCore) {
    super(database, requiresPost);
    WhereCoreImpl<?> whereCore = new WhereCoreImpl<>(this);
    WhereQueryImpl<SelectQueryImpl> whereQuery = new WhereQueryImpl<>(this, whereCore);
    this.selectCore = selectionCore.from(whereQuery);
  }

  SelectQueryImpl(
      final String database,
      final FromClause fromClause,
      final boolean requiresPost,
      final SelectionCoreImpl selectionCore) {
    super(database, requiresPost);
    WhereCoreImpl<?> whereCore = new WhereCoreImpl<>(this);
    WhereQueryImpl<SelectQueryImpl> whereQuery = new WhereQueryImpl<>(this, whereCore);
    this.selectCore = selectionCore.from(fromClause, whereQuery);
  }

  @Override
  public StringBuilder buildQueryString() {
    return selectCore.buildQueryString(new StringBuilder());
  }

  @Override
  public StringBuilder buildQueryString(final StringBuilder stringBuilder) {
    return selectCore.buildQueryString(stringBuilder);
  }

  @Override
  public void setSubQuery(final QueryStringBuilder query) {
    selectCore.setSubQuery(query);
  }

  @Override
  public WhereQueryImpl<SelectQueryImpl> where() {
    return selectCore.where();
  }

  @Override
  public WhereQueryImpl<SelectQueryImpl> where(final Clause clause) {
    return selectCore.where().and(clause);
  }

  @Override
  public WhereQueryImpl where(final String text) {
    return selectCore.where().and(new RawTextClause(text));
  }

  @Override
  public SelectQueryImpl orderBy(final Ordering ordering) {
    selectCore.orderBy(ordering);
    return this;
  }

  @Override
  public SelectQueryImpl groupBy(final Object... columns) {
    selectCore.groupBy(columns);
    return this;
  }

  @Override
  public SelectQueryImpl fill(final Number value) {
    selectCore.fill(value);
    return this;
  }

  @Override
  public SelectQueryImpl fill(final String value) {
    selectCore.fill(value);
    return this;
  }

  @Override
  public SelectQueryImpl limit(final int limit) {
    selectCore.limit(limit);
    return this;
  }

  @Override
  public SelectQueryImpl limit(final int limit, final long offSet) {
    selectCore.limit(limit, offSet);
    return this;
  }

  @Override
  public SelectQueryImpl sLimit(final int sLimit) {
    selectCore.sLimit(sLimit);
    return this;
  }

  @Override
  public SelectQueryImpl sLimit(final int sLimit, final long sOffSet) {
    selectCore.sLimit(sLimit, sOffSet);
    return this;
  }

  @Override
  public SelectQueryImpl tz(final String timezone) {
    selectCore.tz(timezone);
    return this;
  }
}