Modifier and Type	Class and Description
pack-priv static enum	BatchCRUD.Action The action to be performed by this operation.
private static class	BatchCRUD.QueryCollector Collect queries The query collector intercepts query execution after rendering.
private static class	BatchCRUD.QueryCollectorSignal A query execution interception signal.

Modifier and Type	Field and Description
private final BatchCRUD.Action	action
private static final JooqLogger	log
private final TableRecord<?>[]	records

Access	Constructor and Description
pack-priv	BatchCRUD(Configuration configuration, BatchCRUD.Action action, TableRecord<?>[] records)

Method Summary

Modifier and Type	Method and Description
private final Configuration	deriveConfiguration(BatchCRUD.QueryCollector collector)
public final int[]	execute() Implements org.jooq.Batch.execute. Execute the batch operation.
private final void	executeAction(int i)
private final int[]	executePrepared()
private final int[]	executeStatic()
public final int	size() Implements org.jooq.Batch.size. Get the number of executed queries in this batch operation
public void	subscribe(Subscriber<? super Integer> the `Subscriber` that will consume signals from this `Publisher` s) Implements org.reactivestreams.Publisher.subscribe. Request `Publisher` to start streaming data.
private final void	updateChangedFlag()

Inherited from org.jooq.impl.AbstractBatch:: executeAsync executeAsync

Field Detail

action	back to summary
private final BatchCRUD.Action action

log	back to summary
private static final JooqLogger log

records	back to summary
private final TableRecord<?>[] records

BatchCRUD	back to summary
pack-priv BatchCRUD(Configuration configuration, BatchCRUD.Action action, TableRecord<?>[] records)

Method Detail

deriveConfiguration	back to summary
private final Configuration deriveConfiguration(BatchCRUD.QueryCollector collector)

execute	back to summary
public final int[] execute() throws DataAccessException Implements org.jooq.Batch.execute. Doc from org.jooq.Batch.execute. Execute the batch operation. Annotations @Override Exceptions DataAccessException: if something went wrong executing the query

execute

back to summary

public final int[] execute() throws DataAccessException

Implements org.jooq.Batch.execute.

Doc from org.jooq.Batch.execute.

Execute the batch operation.

Annotations

@Override

Exceptions

DataAccessException:: if something went wrong executing the query

executeAction	back to summary
private final void executeAction(int i)

executePrepared	back to summary
private final int[] executePrepared()

executeStatic	back to summary
private final int[] executeStatic()

size	back to summary
public final int size() Implements org.jooq.Batch.size. Doc from org.jooq.Batch.size. Get the number of executed queries in this batch operation Annotations @Override

size

back to summary

public final int size()

Implements org.jooq.Batch.size.

Doc from org.jooq.Batch.size.

Get the number of executed queries in this batch operation

Annotations

@Override

subscribe back to summary

subscribe	back to summary
public void subscribe(Subscriber<? super Integer> s) Implements org.reactivestreams.Publisher.subscribe. Doc from org.reactivestreams.Publisher.subscribe. Request `Publisher` to start streaming data. This is a "factory method" and can be called multiple times, each time starting a new `Subscription`. Each `Subscription` will work for only a single `Subscriber`. A `Subscriber` should only subscribe once to a single `Publisher`. If the `Publisher` rejects the subscription attempt or otherwise fails it will signal the error via `Subscriber#onError(Throwable)`. Parameters s:Subscriber<? super Integer> the `Subscriber` that will consume signals from this `Publisher` Annotations @Override

public void subscribe(Subscriber<? super Integer> s)

Implements org.reactivestreams.Publisher.subscribe.

Doc from org.reactivestreams.Publisher.subscribe.

Request Publisher to start streaming data.

This is a "factory method" and can be called multiple times, each time starting a new Subscription.

Each Subscription will work for only a single Subscriber.

A Subscriber should only subscribe once to a single Publisher.

If the Publisher rejects the subscription attempt or otherwise fails it will signal the error via Subscriber#onError(Throwable).

Parameters

s:Subscriber<? super Integer>: the Subscriber that will consume signals from this Publisher

Annotations

@Override

updateChangedFlag	back to summary
private final void updateChangedFlag()

org.jooq.impl back to summary

pack-priv final Enum BatchCRUD.Action

Class Inheritance

extends Enum<BatchCRUD.Action>

java.lang.Object
java.lang.Enum
org.jooq.impl.BatchCRUD.Action

The action to be performed by this operation.

Field Summary

Modifier and Type	Field and Description
public static final BatchCRUD.Action	DELETE Corresponds to `UpdatableRecord#delete()`.
public static final BatchCRUD.Action	INSERT Corresponds to `UpdatableRecord#insert()`.
public static final BatchCRUD.Action	MERGE Corresponds to `UpdatableRecord#merge()`.
public static final BatchCRUD.Action	STORE Corresponds to `UpdatableRecord#store()`.
public static final BatchCRUD.Action	UPDATE Corresponds to `UpdatableRecord#update()`.

Constructor Summary

Access	Constructor and Description
private	Action()

Method Summary

Modifier and Type	Method and Description
public static BatchCRUD.Action	valueOf(String name)
public static BatchCRUD.Action[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

DELETE	back to summary
public static final BatchCRUD.Action DELETE Corresponds to `UpdatableRecord#delete()`.

INSERT	back to summary
public static final BatchCRUD.Action INSERT Corresponds to `UpdatableRecord#insert()`.

MERGE	back to summary
public static final BatchCRUD.Action MERGE Corresponds to `UpdatableRecord#merge()`.

STORE	back to summary
public static final BatchCRUD.Action STORE Corresponds to `UpdatableRecord#store()`.

UPDATE	back to summary
public static final BatchCRUD.Action UPDATE Corresponds to `UpdatableRecord#update()`.

Constructor Detail

Action	back to summary
private Action()

Method Detail

valueOf	back to summary
public static BatchCRUD.Action valueOf(String name)

values	back to summary
public static BatchCRUD.Action[] values()

org.jooq.impl back to summary

private Class BatchCRUD.QueryCollector

Class Inheritance

extends Object
implements ExecuteListener

java.lang.Object
org.jooq.impl.BatchCRUD.QueryCollector

All Implemented Interfaces

org.jooq.ExecuteListener, java.io.Serializable, java.util.EventListener

Collect queries

The query collector intercepts query execution after rendering. This allows for rendering SQL according to the specific logic contained in TableRecords without actually executing that SQL

Constructor Summary

Access	Constructor and Description
private	QueryCollector()

Method Summary

Modifier and Type	Method and Description
public void	renderEnd(ExecuteContext The context containing information about the execution. ctx) Overrides default org.jooq.ExecuteListener.renderEnd. Called after rendering SQL from a `QueryPart`.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

QueryCollector	back to summary
private QueryCollector()

Method Detail

renderEnd back to summary

renderEnd	back to summary
public void renderEnd(ExecuteContext ctx) Overrides default org.jooq.ExecuteListener.renderEnd. Doc from org.jooq.ExecuteListener.renderEnd. Called after rendering SQL from a `QueryPart`. Available attributes from `ExecuteContext`: `ExecuteContext#connection()`: The connection used for execution `ExecuteContext#configuration()`: The execution configuration `ExecuteContext#query()`: The `Query` object, if a jOOQ query is being executed or `null` otherwise `ExecuteContext#routine()`: The `Routine` object, if a jOOQ routine is being executed or `null` otherwise `ExecuteContext#sql()`: The rendered `SQL` statement that is about to be executed, or `null` if the `SQL` statement is unknown.. Overridable attributes in `ExecuteContext`: `ExecuteContext#sql(String)`: The rendered `SQL` statement that is about to be executed. You can modify this statement freely. Parameters ctx:ExecuteContext The context containing information about the execution. Annotations @Override

public void renderEnd(ExecuteContext ctx)

Overrides default org.jooq.ExecuteListener.renderEnd.

Doc from org.jooq.ExecuteListener.renderEnd.

Called after rendering SQL from a QueryPart.

Available attributes from ExecuteContext:

ExecuteContext#connection(): The connection used for execution
ExecuteContext#configuration(): The execution configuration
ExecuteContext#query(): The Query object, if a jOOQ query is being executed or null otherwise
ExecuteContext#routine(): The Routine object, if a jOOQ routine is being executed or null otherwise
ExecuteContext#sql(): The rendered SQL statement that is about to be executed, or null if the SQL statement is unknown..

Overridable attributes in ExecuteContext:

ExecuteContext#sql(String): The rendered SQL statement that is about to be executed. You can modify this statement freely.

Parameters

ctx:ExecuteContext: The context containing information about the execution.

Annotations

@Override

org.jooq.impl back to summary

private Class BatchCRUD.QueryCollectorSignal

Class Inheritance

extends ControlFlowSignal

java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
org.jooq.exception.ControlFlowSignal
org.jooq.impl.BatchCRUD.QueryCollectorSignal

A query execution interception signal.

This exception is used as a signal for jOOQ's internals to abort query execution, and return generated SQL back to batch execution.

Field Summary

Modifier and Type	Field and Description
private final Query	query
private final String	sql

Constructor Summary

Access	Constructor and Description
pack-priv	QueryCollectorSignal(String sql, Query query)

Method Summary

Modifier and Type	Method and Description
pack-priv Query	getQuery()
pack-priv String	getSQL()

Inherited from org.jooq.exception.ControlFlowSignal:: fillInStackTrace

Field Detail

query	back to summary
private final Query query

sql	back to summary
private final String sql

Constructor Detail

QueryCollectorSignal	back to summary
pack-priv QueryCollectorSignal(String sql, Query query)

Method Detail

getQuery	back to summary
pack-priv Query getQuery()

getSQL	back to summary
pack-priv String getSQL()

pack-priv final Class BatchCRUD

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Enum BatchCRUD.Action

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class BatchCRUD.QueryCollector

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private Class BatchCRUD.QueryCollectorSignal

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail