Package org.dotwebstack.framework.backend.postgres.query

Class Query

java.lang.Object

org.dotwebstack.framework.backend.postgres.query.Query

public class Query
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	EXISTS_KEY
static String	GROUP_KEY

Constructor Summary

Constructors

Constructor	Description
Query(BatchRequest batchRequest, RequestContext requestContext)
Query(CollectionBatchRequest collectionBatchRequest, RequestContext requestContext)
Query(CollectionRequest collectionRequest, RequestContext requestContext)
Query(ObjectRequest objectRequest, RequestContext requestContext)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<Map<String,Object>>	execute(org.springframework.r2dbc.core.DatabaseClient databaseClient)
reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<Map<String,Object>,Map<String,Object>>>	executeBatch(org.springframework.r2dbc.core.DatabaseClient databaseClient)

Methods inherited from class java.lang.Object

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

Field Detail

GROUP_KEY

public static final String GROUP_KEY

See Also:

Constant Field Values

EXISTS_KEY

public static final String EXISTS_KEY

See Also:

Constant Field Values

Constructor Detail

Query

public Query(CollectionRequest collectionRequest,
             RequestContext requestContext)

Query

public Query(CollectionBatchRequest collectionBatchRequest,
             RequestContext requestContext)

Query

public Query(ObjectRequest objectRequest,
             RequestContext requestContext)

Query

public Query(BatchRequest batchRequest,
             RequestContext requestContext)

Method Detail

execute

public reactor.core.publisher.Flux<Map<String,Object>> execute(org.springframework.r2dbc.core.DatabaseClient databaseClient)

executeBatch

public reactor.core.publisher.Flux<reactor.core.publisher.GroupedFlux<Map<String,Object>,Map<String,Object>>> executeBatch(org.springframework.r2dbc.core.DatabaseClient databaseClient)