github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[jOOQ/jOOQ#9482] Add [pro] tag that went missing

Browse Source
This commit is contained in:
Knut Wannheden 2019-11-01 08:47:23 +01:00
parent 350c19ce6e
commit 5560943bfc
1 changed files with 140 additions and 139 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

279
jOOQ/src/main/java/org/jooq/impl/FlashbackTable.java
View File

@ -37,166 +37,167 @@
*/
package org.jooq.impl;
import static org.jooq.impl.DSL.val;
import static org.jooq.impl.Keywords.K_AND;
import static org.jooq.impl.Keywords.K_AS_OF;
import static org.jooq.impl.Keywords.K_MAXVALUE;
import static org.jooq.impl.Keywords.K_MINVALUE;
import static org.jooq.impl.Keywords.K_SCN;
import static org.jooq.impl.Keywords.K_TIMESTAMP;
import static org.jooq.impl.Keywords.K_VERSIONS_BETWEEN;
import static org.jooq.impl.Names.N_FLASHBACK;
import org.jooq.Context;
import org.jooq.Field;
import org.jooq.Keyword;
import org.jooq.Name;
// ...
import org.jooq.QueryPart;
import org.jooq.Record;
import org.jooq.Table;
// ...
/**
* A flashback query clause implementation.
*
* @author Lukas Eder
*/
@Pro
final class FlashbackTable<R extends Record, T>
extends AbstractTable<R>
implements VersionsBetweenAndStep<R, T> {
/**
* Generated UID
*/
private static final long serialVersionUID = -7918219502110473521L;
private final Table<R> table;
private final FlashbackType type;
private final Field<?> asOf;
private final QueryPart minvalue;
private QueryPart maxvalue;
FlashbackTable(Table<R> table, Field<?> asOf, QueryPart minvalue, FlashbackType type) {
super(table.getOptions(), N_FLASHBACK);
this.table = table;
this.asOf = asOf;
this.minvalue = minvalue != null ? minvalue : K_MINVALUE;
this.type = type;
}
private FlashbackTable(Table<R> table, FlashbackTable<R, T> o) {
this(table, o.asOf, o.minvalue, o.type);
this.maxvalue = o.maxvalue;
}
// ------------------------------------------------------------------------
// XXX: Flashback API
// ------------------------------------------------------------------------
@Override
public final Table<R> and(T value) {
return and(val(value));
}
@Override
public final Table<R> and(Field<? extends T> field) {
maxvalue = field;
return this;
}
@Override
public final Table<R> andMaxvalue() {
maxvalue = K_MAXVALUE;
return this;
}
// ------------------------------------------------------------------------
// XXX: Table API
// ------------------------------------------------------------------------
@Override
public final Class<? extends R> getRecordType() {
return table.getRecordType();
}
@Override
public final void accept(Context<?> ctx) {
// [#6303] jOOQ allows for the syntactically incorrect construction of aliased flashback table expressions
Table<R> aliased = Tools.aliased(table);
if (aliased != null) {
Alias<?> alias = Tools.alias(table);
ctx.visit(new Alias<>(
new FlashbackTable<>(aliased, this),
this, alias.alias, alias.fieldAliases, alias.wrapInParentheses
));
}
else {
ctx.visit(table);
if (asOf != null) {
ctx.sql(' ')
.visit(K_AS_OF)
.sql(' ')
.visit(type.keyword())
.sql(' ')
.visit(asOf);
}
else {
ctx.sql(' ')
.visit(K_VERSIONS_BETWEEN)
.sql(' ')
.visit(type.keyword())
.sql(' ')
.visit(minvalue)
.sql(' ')
.visit(K_AND)
.sql(' ')
.visit(maxvalue);
}
}
}
@Override
public final boolean declaresTables() {
return true;
}
@Override
public final Table<R> as(Name alias) {
return new TableAlias<>(this, alias, true);
}
@Override
public final Table<R> as(Name alias, Name... fieldAliases) {
return new TableAlias<>(this, alias, fieldAliases, true);
}
@Override
final Fields<R> fields0() {
return new Fields<>(table.fields());
}
/**
* The flashback query clause type
*/
@Pro
enum FlashbackType {
SCN, TIMESTAMP;
Keyword keyword() {
if (this == SCN)
return K_SCN;
else if (this == TIMESTAMP)
return K_TIMESTAMP;
else
throw new IllegalStateException("Unsupported FlashbackType: " + this);
}
}
}
/* [/pro] */