influxdata/influxdb-java

package org.influxdb.querybuilder;

import java.util.Arrays;
import org.influxdb.querybuilder.clauses.OperationClause;
import org.influxdb.querybuilder.clauses.SimpleClause;
import org.influxdb.querybuilder.clauses.RawFromClause;
import org.influxdb.querybuilder.clauses.SimpleFromClause;
import org.influxdb.querybuilder.clauses.MultipleFromClause;
import org.influxdb.querybuilder.clauses.FromClause;

public class SelectionSubQueryImpl<T extends WithSubquery> extends SubQuery<T>
    implements Selection, WithSubquery {

  private final SelectionCoreImpl selectionCore;

  SelectionSubQueryImpl(final T selectQuery) {
    setParent(selectQuery);
    this.selectionCore = new SelectionCoreImpl();
  }

  @Override
  public SelectionSubQueryImpl<T> distinct() {
    selectionCore.distinct();
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> as(final String aliasName) {
    selectionCore.as(aliasName);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> all() {
    selectionCore.all();
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> countAll() {
    selectionCore.countAll();
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> column(final String name) {
    selectionCore.column(name);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> regex(final String clause) {
    selectionCore.regex(clause);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> function(final String name, final Object... parameters) {
    selectionCore.function(name, parameters);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> raw(final String text) {
    selectionCore.raw(text);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> count(final Object column) {
    selectionCore.count(column);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> max(final Object column) {
    selectionCore.max(column);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> min(final Object column) {
    selectionCore.min(column);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> sum(final Object column) {
    selectionCore.sum(column);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> mean(final Object column) {
    selectionCore.mean(column);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> op(final OperationClause operationClause) {
    selectionCore.op(operationClause);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> op(final Object arg1, final String op, final Object arg2) {
    selectionCore.op(arg1, op, arg2);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> cop(final SimpleClause simpleClause) {
    selectionCore.cop(simpleClause);
    return this;
  }

  @Override
  public SelectionSubQueryImpl<T> cop(final String column, final String op, final Object arg2) {
    selectionCore.cop(column, op, arg2);
    return this;
  }

  public SelectSubQueryImpl<T> fromRaw(final String text) {
    return from(new RawFromClause(text));
  }

  public SelectSubQueryImpl<T> from(final String[] tables) {
    if (tables == null) {
      throw new IllegalArgumentException("Tables names should be specified");
    }

    return from(new MultipleFromClause(Arrays.asList(tables)));
  }

  public SelectSubQueryImpl<T> from(final String table) {
    return from(new SimpleFromClause(table));
  }

  private SelectSubQueryImpl<T> from(final FromClause fromClause) {
    selectionCore.clearSelection();
    SelectSubQueryImpl<T> subSelect =
        new SelectSubQueryImpl<>(fromClause, selectionCore.columns, selectionCore.isDistinct);
    subSelect.setParent(getParent());
    return subSelect;
  }

  public SelectionSubQueryImpl<SelectSubQueryImpl<T>> fromSubQuery() {
    selectionCore.clearSelection();
    SelectSubQueryImpl<T> selectSubQuery =
        new SelectSubQueryImpl<>(selectionCore.columns, selectionCore.isDistinct);
    selectSubQuery.setParent(this.getParent());
    SelectionSubQueryImpl<SelectSubQueryImpl<T>> selectionSubQuery
      = new SelectionSubQueryImpl<>(selectSubQuery);
    return selectionSubQuery;
  }

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

  @Override
  public StringBuilder buildQueryString() {
    return null;
  }

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