package org.jooq.impl;
import static org.jooq.impl.Keywords.K_CASE;
import static org.jooq.impl.Keywords.K_ELSE;
import static org.jooq.impl.Keywords.K_END;
import static org.jooq.impl.Keywords.K_SWITCH;
import static org.jooq.impl.Keywords.K_THEN;
import static org.jooq.impl.Keywords.K_TRUE;
import static org.jooq.impl.Keywords.K_WHEN;
import static org.jooq.impl.Names.N_CASE;
import java.util.ArrayList;
import java.util.List;
import org.jooq.CaseConditionStep;
import org.jooq.Condition;
import org.jooq.Context;
import org.jooq.Field;
import org.jooq.Record1;
import org.jooq.Select;
final class CaseConditionStepImpl<T> extends AbstractField<T> implements CaseConditionStep<T> {
private static final long serialVersionUID = -1735676153683257465L;
private final List<Condition> conditions;
private final List<Field<T>> results;
private Field<T> else_;
CaseConditionStepImpl(Condition condition, Field<T> result) {
super(N_CASE, result.getDataType());
this.conditions = new ArrayList<>();
this.results = new ArrayList<>();
when(condition, result);
}
@Override
public final CaseConditionStep<T> when(Condition condition, T result) {
return when(condition, Tools.field(result));
}
@Override
public final CaseConditionStep<T> when(Condition condition, Field<T> result) {
conditions.add(condition);
results.add(result);
return this;
}
@Override
public final CaseConditionStep<T> when(Condition condition, Select<? extends Record1<T>> result) {
return when(condition, DSL.field(result));
}
@Override
public final CaseConditionStep<T> when(Field<Boolean> condition, T result) {
return when(DSL.condition(condition), result);
}
@Override
public final CaseConditionStep<T> when(Field<Boolean> condition, Field<T> result) {
return when(DSL.condition(condition), result);
}
@Override
public final CaseConditionStep<T> when(Field<Boolean> condition, Select<? extends Record1<T>> result) {
return when(DSL.condition(condition), result);
}
@Override
public final Field<T> otherwise(T result) {
return else_(result);
}
@Override
public final Field<T> otherwise(Field<T> result) {
return else_(result);
}
@Override
public final Field<T> otherwise(Select<? extends Record1<T>> result) {
return else_(result);
}
@Override
public final Field<T> else_(T result) {
return else_(Tools.field(result));
}
@Override
public final Field<T> else_(Field<T> result) {
this.else_ = result;
return this;
}
@Override
public final Field<T> else_(Select<? extends Record1<T>> result) {
return else_(DSL.field(result));
}
@Override
public final void accept(Context<?> ctx) {
switch (ctx.family()) {
default:
ctx.visit(new Native());
break;
}
}
private class Native extends AbstractQueryPart {
private static final long serialVersionUID = 7850713333675233736L;
@Override
public final void accept(Context<?> ctx) {
ctx.visit(K_CASE)
.formatIndentStart()
.formatSeparator();
int size = conditions.size();
for (int i = 0; i < size; i++) {
if (i > 0)
ctx.formatSeparator();
ctx.visit(K_WHEN).sql(' ').visit(conditions.get(i)).sql(' ')
.visit(K_THEN).sql(' ').visit(results.get(i));
}
if (else_ != null)
ctx.formatSeparator()
.visit(K_ELSE).sql(' ').visit(else_);
ctx.formatIndentEnd()
.formatSeparator()
.visit(K_END);
}
}
}