Package com.evolveum.midpoint.repo.sqlbase

Class SqlQueryExecutor

java.lang.Object

com.evolveum.midpoint.repo.sqlbase.SqlQueryExecutor

public class SqlQueryExecutor
extends Object

Component just under the service that orchestrates query transformation and execution. Sql query executor itself does hold the query state, it uses SqlQueryContext for that. This object manages configuration information and provides dataSource/connections for queries.

Constructor Summary

Constructors

Constructor	Description
SqlQueryExecutor(SqlRepoContext sqlRepoContext)

Method Summary

Modifier and Type	Method	Description
<S, Q extends FlexibleRelationalPathBase<R>, R> int	count(@NotNull SqlQueryContext<S,Q,R> context, ObjectQuery query, Collection<SelectorOptions<GetOperationOptions>> options)
<S, Q extends FlexibleRelationalPathBase<R>, R> @NotNull SearchResultList<S>	list(@NotNull SqlQueryContext<S,Q,R> context, ObjectQuery query, Collection<SelectorOptions<GetOperationOptions>> options)
<S, Q extends FlexibleRelationalPathBase<R>, R> int	listStreaming(@NotNull SqlQueryContext<S,Q,R> context, ObjectQuery query, Collection<SelectorOptions<GetOperationOptions>> options, @NotNull ObjectHandler<S> handler, @NotNull OperationResult operationResult, int fetchSize)	Streaming iterative search that processes rows one by one without loading all into memory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SqlQueryExecutor

public SqlQueryExecutor(SqlRepoContext sqlRepoContext)

Method Details

count

public <S,
Q extends FlexibleRelationalPathBase<R>,
R>
int count(@NotNull
 @NotNull SqlQueryContext<S,Q,R> context,
 ObjectQuery query,
 Collection<SelectorOptions<GetOperationOptions>> options)
   throws RepositoryException

Throws:

RepositoryException

list

@NotNull
public <S,
Q extends FlexibleRelationalPathBase<R>,
R>
@NotNull SearchResultList<S> list(@NotNull
 @NotNull SqlQueryContext<S,Q,R> context,
 ObjectQuery query,
 Collection<SelectorOptions<GetOperationOptions>> options)
                           throws RepositoryException,
SchemaException

Throws:

RepositoryException

SchemaException

listStreaming

public <S,
Q extends FlexibleRelationalPathBase<R>,
R>
int listStreaming(@NotNull
 @NotNull SqlQueryContext<S,Q,R> context,
 ObjectQuery query,
 Collection<SelectorOptions<GetOperationOptions>> options,
 @NotNull
 @NotNull ObjectHandler<S> handler,
 @NotNull
 @NotNull OperationResult operationResult,
 int fetchSize)
           throws RepositoryException,
SchemaException

Streaming iterative search that processes rows one by one without loading all into memory. Uses JDBC cursor-based streaming with configurable fetch size.

Parameters:

context - query context

query - object query (may be null)

options - get operation options

handler - handler called for each transformed result

operationResult - operation result for handler

fetchSize - JDBC fetch size for streaming

Returns:

number of processed items

Throws:

RepositoryException

SchemaException