Top Fields Constructors Methods
org.jooq.impl

pack-priv abstract Class AbstractDMLQuery<R extends org.jooq.Record>

extends AbstractRowCountQuery
implements DMLQuery<R extends Record>
Class Inheritance
All Implemented Interfaces
org.jooq.DMLQuery, org.jooq.RowCountQuery, org.jooq.Publisher, java.util.concurrent.Flow.Publisher, org.reactivestreams.Publisher, org.jooq.Query, org.jooq.AttachableQueryPart, org.jooq.QueryPart, java.io.Serializable, org.jooq.Attachable, org.jooq.Statement
Known Direct Subclasses
org.jooq.impl.DeleteQueryImpl, org.jooq.impl.AbstractStoreQuery
Static Imports
java.lang.Boolean.FALSE, org.jooq.SQLDialect.CUBRID, .SQLDialect.DERBY, .SQLDialect.FIREBIRD, .SQLDialect.H2, .SQLDialect.HSQLDB, .SQLDialect.IGNITE, .SQLDialect.MARIADB, .SQLDialect.MYSQL, .SQLDialect.SQLITE, org.jooq.conf.SettingsTools.renderLocale, org.jooq.impl.CommonTableExpressionList.markTopLevelCteAndAccept, .DSL.name, .DSL.select, .DSL.unquotedName, .Keywords.K_BEGIN, .Keywords.K_BULK_COLLECT_INTO, .Keywords.K_DECLARE, .Keywords.K_END, .Keywords.K_FOR, .Keywords.K_FORALL, .Keywords.K_FROM, .Keywords.K_IN, .Keywords.K_INTO, .Keywords.K_OPEN, .Keywords.K_OUTPUT, .Keywords.K_RETURNING, .Keywords.K_ROWCOUNT, .Keywords.K_SELECT, .Keywords.K_SQL, .Keywords.K_TABLE, .Names.N_DELETED, .Names.N_INSERTED, .Tools.EMPTY_FIELD, .Tools.EMPTY_STRING, .Tools.anyMatch, .Tools.autoAlias, .Tools.flattenCollection, .Tools.increment, .Tools.map, .Tools.reference, .Tools.removeGenerator, .Tools.unalias, .Tools.BooleanDataKey.DATA_UNALIAS_ALIASED_EXPRESSIONS, .Tools.SimpleDataKey.DATA_DML_TARGET_TABLE, .Tools.SimpleDataKey.DATA_DML_USING_TABLES, .Tools.SimpleDataKey.DATA_RENDERING_DATA_CHANGE_DELTA_TABLE, .Tools.SimpleDataKey.DATA_TOP_LEVEL_CTE, org.jooq.tools.StringUtils.defaultIfNull, org.jooq.util.sqlite.SQLiteDSL.rowid
Author
Lukas Eder

Field Summary

Modifier and TypeField and Description
private static final JooqLogger
log

Hides org.jooq.impl.AbstractQuery.log.

private static final Set<SQLDialect>
NATIVE_SUPPORT_DATA_CHANGE_DELTA_TABLE

private static final Set<SQLDialect>
NO_NATIVE_SUPPORT_DELETE_RETURNING

private static final Set<SQLDialect>
NO_NATIVE_SUPPORT_INSERT_RETURNING

private static final Set<SQLDialect>
NO_NATIVE_SUPPORT_UPDATE_RETURNING

private static final Set<SQLDialect>
NO_SUPPORT_FETCHING_KEYS

private static final Set<SQLDialect>
NO_SUPPORT_INSERT_ALIASED_TABLE

private static final Set<SQLDialect>
NO_SUPPORT_RETURNING_ASTERISK

pack-priv Result<R>
returned

pack-priv Result<Record>
returnedResult

pack-priv final SelectFieldList<SelectFieldOrAsterisk>
returning

pack-priv final List<Field<?>>
returningResolvedAsterisks

pack-priv final Table<R>
table

pack-priv final WithImpl
with

Constructor Summary

AccessConstructor and Description
pack-priv
AbstractDMLQuery(Configuration configuration, WithImpl with, Table<R> table)

Method Summary

Modifier and TypeMethod and Description
public final void
accept(Context<?> ctx)

Implements org.jooq.QueryPartInternal.accept.

This QueryPart can accept a Context object in order to render a SQL string or to bind its variables.
pack-priv abstract void
accept0(Context<?> ctx)

protected final int
execute(ExecuteContext ctx, ExecuteListener listener)

Overrides org.jooq.impl.AbstractQuery.execute.

Default implementation for query execution using a prepared statement.
private final PreparedStatement
executeImmediate(PreparedStatement s)

Make sure a PreparedStatement, which may be a BatchedPreparedStatement, is executed immediately, not batched.

private final ResultSet
executeReturningGeneratedKeys(ExecuteContext ctx, ExecuteListener listener)

private final int
executeReturningGeneratedKeysFetchAdditionalRows(ExecuteContext ctx, ExecuteListener listener)

private final ResultSet
executeReturningQuery(ExecuteContext ctx, ExecuteListener listener)

pack-priv void
executeWithoutWhere(String message, ExecuteWithoutWhere executeWithoutWhere)

[#6771] Handle the case where a statement is executed without a WHERE clause.

public final Field<?>[]
getFields(ThrowingSupplier<? extends ResultSetMetaData, SQLException> rs)

Deprecated as a consequence of Field being deprecated.
public final Class<? extends Record>
getRecordType()

public final Result<?>
getResult()

public final R
getReturnedRecord()

public final Result<R>
getReturnedRecords()

pack-priv final boolean
nativeSupportReturning(Scope ctx)

pack-priv final boolean
nativeSupportReturningOrDataChangeDeltaTable(Scope ctx)

protected final void
prepare(ExecuteContext ctx)

Overrides org.jooq.impl.AbstractQuery.prepare.

Default implementation for preparing a statement.
private final void
prepare0(ExecuteContext ctx)

private final Field<?>
returnedIdentity()

Deprecated as a consequence of Field being deprecated.
private final void
selectReturning(Configuration originalConfiguration, Configuration derivedConfiguration, Object... values)

Get the returning record in those dialects that do not support fetching arbitrary fields from JDBC's Statement#getGeneratedKeys() method.

public final void
setReturning()

public final void
setReturning(Identity<R, ?> identity)

public final void
setReturning(SelectFieldOrAsterisk... fields)

public final void
setReturning(Collection<? extends SelectFieldOrAsterisk> fields)

pack-priv final Table<R>
table()

pack-priv final Table<?>
table(Context<?> ctx)

pack-priv final void
toSQLReturning(Context<?> ctx)

private final void
warnOnAPIMisuse()

Inherited from org.jooq.impl.AbstractRowCountQuery:
subscribe

Field Detail

logback to summary
private static final JooqLogger log

Hides org.jooq.impl.AbstractQuery.log.

NATIVE_SUPPORT_DATA_CHANGE_DELTA_TABLEback to summary
private static final Set<SQLDialect> NATIVE_SUPPORT_DATA_CHANGE_DELTA_TABLE
NO_NATIVE_SUPPORT_DELETE_RETURNINGback to summary
private static final Set<SQLDialect> NO_NATIVE_SUPPORT_DELETE_RETURNING
NO_NATIVE_SUPPORT_INSERT_RETURNINGback to summary
private static final Set<SQLDialect> NO_NATIVE_SUPPORT_INSERT_RETURNING
NO_NATIVE_SUPPORT_UPDATE_RETURNINGback to summary
private static final Set<SQLDialect> NO_NATIVE_SUPPORT_UPDATE_RETURNING
NO_SUPPORT_FETCHING_KEYSback to summary
private static final Set<SQLDialect> NO_SUPPORT_FETCHING_KEYS
NO_SUPPORT_INSERT_ALIASED_TABLEback to summary
private static final Set<SQLDialect> NO_SUPPORT_INSERT_ALIASED_TABLE
NO_SUPPORT_RETURNING_ASTERISKback to summary
private static final Set<SQLDialect> NO_SUPPORT_RETURNING_ASTERISK
returnedback to summary
pack-priv Result<R> returned
returnedResultback to summary
pack-priv Result<Record> returnedResult
returningback to summary
pack-priv final SelectFieldList<SelectFieldOrAsterisk> returning
returningResolvedAsterisksback to summary
pack-priv final List<Field<?>> returningResolvedAsterisks
tableback to summary
pack-priv final Table<R> table
withback to summary
pack-priv final WithImpl with

Constructor Detail

AbstractDMLQueryback to summary
pack-priv AbstractDMLQuery(Configuration configuration, WithImpl with, Table<R> table)

Method Detail

acceptback to summary
public final void accept(Context<?> ctx)

Implements org.jooq.QueryPartInternal.accept.

Doc from org.jooq.QueryPartInternal.accept.

This QueryPart can accept a Context object in order to render a SQL string or to bind its variables.

Annotations
@Override
accept0back to summary
pack-priv abstract void accept0(Context<?> ctx)
executeback to summary
protected final int execute(ExecuteContext ctx, ExecuteListener listener) throws SQLException

Overrides org.jooq.impl.AbstractQuery.execute.

Doc from org.jooq.impl.AbstractQuery.execute.

Default implementation for query execution using a prepared statement. Subclasses may override this method.

Annotations
@SuppressWarnings:rawtypes, unchecked
@Override
executeImmediateback to summary
private final PreparedStatement executeImmediate(PreparedStatement s) throws SQLException

Make sure a PreparedStatement, which may be a BatchedPreparedStatement, is executed immediately, not batched.

executeReturningGeneratedKeysback to summary
private final ResultSet executeReturningGeneratedKeys(ExecuteContext ctx, ExecuteListener listener) throws SQLException
executeReturningGeneratedKeysFetchAdditionalRowsback to summary
private final int executeReturningGeneratedKeysFetchAdditionalRows(ExecuteContext ctx, ExecuteListener listener) throws SQLException
executeReturningQueryback to summary
private final ResultSet executeReturningQuery(ExecuteContext ctx, ExecuteListener listener) throws SQLException
executeWithoutWhereback to summary
pack-priv void executeWithoutWhere(String message, ExecuteWithoutWhere executeWithoutWhere)

[#6771] Handle the case where a statement is executed without a WHERE clause.

getFieldsback to summary
public final Field<?>[] getFields(ThrowingSupplier<? extends ResultSetMetaData, SQLException> rs) throws SQLException

Deprecated

as a consequence of Field being deprecated. See corresponding docs for further information.

getRecordTypeback to summary
public final Class<? extends Record> getRecordType()
getResultback to summary
public final Result<?> getResult()
getReturnedRecordback to summary
public final R getReturnedRecord()
getReturnedRecordsback to summary
public final Result<R> getReturnedRecords()
Annotations
@SuppressWarnings:unchecked
nativeSupportReturningback to summary
pack-priv final boolean nativeSupportReturning(Scope ctx)
nativeSupportReturningOrDataChangeDeltaTableback to summary
pack-priv final boolean nativeSupportReturningOrDataChangeDeltaTable(Scope ctx)
prepareback to summary
protected final void prepare(ExecuteContext ctx) throws SQLException

Overrides org.jooq.impl.AbstractQuery.prepare.

Doc from org.jooq.impl.AbstractQuery.prepare.

Default implementation for preparing a statement. Subclasses may override this method.

Annotations
@Override
prepare0back to summary
private final void prepare0(ExecuteContext ctx) throws SQLException
returnedIdentityback to summary
private final Field<?> returnedIdentity()

Deprecated

as a consequence of Field being deprecated. See corresponding docs for further information.

selectReturningback to summary
private final void selectReturning(Configuration originalConfiguration, Configuration derivedConfiguration, Object... values)

Get the returning record in those dialects that do not support fetching arbitrary fields from JDBC's Statement#getGeneratedKeys() method.

Annotations
@SuppressWarnings:unchecked, rawtypes
setReturningback to summary
public final void setReturning()
setReturningback to summary
public final void setReturning(Identity<R, ?> identity)
setReturningback to summary
public final void setReturning(SelectFieldOrAsterisk... fields)
setReturningback to summary
public final void setReturning(Collection<? extends SelectFieldOrAsterisk> fields)
tableback to summary
pack-priv final Table<R> table()
tableback to summary
pack-priv final Table<?> table(Context<?> ctx)
toSQLReturningback to summary
pack-priv final void toSQLReturning(Context<?> ctx)
warnOnAPIMisuseback to summary
private final void warnOnAPIMisuse()