Package com.couchbase.client.core.classic.query

Class PreparedStatementStrategy

java.lang.Object

com.couchbase.client.core.classic.query.PreparedStatementStrategy

Direct Known Subclasses:

EnhancedPreparedStatementStrategy, LegacyPreparedStatementStrategy

@Internal
public abstract class PreparedStatementStrategy
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,PreparedStatement>	cache

Constructor Summary

Constructors

Constructor	Description
PreparedStatementStrategy(Core core, int cacheSize)

Method Summary

Modifier and Type	Method	Description
void	evict(QueryRequest request)
abstract reactor.core.publisher.Mono<QueryResponse>	execute(QueryRequest request)
reactor.core.publisher.Mono<QueryResponse>	executeAdhoc(QueryRequest request)
protected reactor.core.publisher.Mono<QueryResponse>	executeAlreadyPrepared(QueryRequest request, PreparedStatement prepared)	Executes a query using an existing prepared statement.
protected static void	propagateDispatchedNode(QueryRequest original, QueryRequest dispatched)	Passes back the lastDispatchedTo context from the dispatched request to the original request.
protected RequestTracer	requestTracer()

Methods inherited from class java.lang.Object

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

Field Details

cache

protected final Map<String,PreparedStatement> cache

Constructor Details

PreparedStatementStrategy

public PreparedStatementStrategy(Core core,
 int cacheSize)

Method Details

requestTracer

protected RequestTracer requestTracer()

execute

public abstract reactor.core.publisher.Mono<QueryResponse> execute(QueryRequest request)

executeAlreadyPrepared

protected reactor.core.publisher.Mono<QueryResponse> executeAlreadyPrepared(QueryRequest request,
 PreparedStatement prepared)

Executes a query using an existing prepared statement.

propagateDispatchedNode

protected static void propagateDispatchedNode(QueryRequest original,
 QueryRequest dispatched)

Passes back the lastDispatchedTo context from the dispatched request to the original request. This is needed for single query transactions to construct a TransactionQueryContext

executeAdhoc

public reactor.core.publisher.Mono<QueryResponse> executeAdhoc(QueryRequest request)

evict

public void evict(QueryRequest request)