Package com.couchbase.client.core.api.query

Class CoreQueryOptionsTransactions

java.lang.Object

com.couchbase.client.core.api.query.CoreQueryOptionsTransactions

All Implemented Interfaces:

CoreQueryOptions

@Internal
public class CoreQueryOptionsTransactions
extends Object
implements CoreQueryOptions

Transactions does some rather complex things with CoreQueryOptions. It needs to set its own options in addition to those set by the user (or a higher layer). And sometimes wants to merge those options with the higher options, and sometimes override the higher options entirely. Hence this rather complex ParameterPassthrough system.

If CoreQueryOptions could be easily cloned-with-changes, ala Scala case class's copy() method, that would be preferable.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	CoreQueryOptionsTransactions.ParameterPassthrough
static enum	CoreQueryOptionsTransactions.QueryOptionsParameter

Constructor Summary

Constructors

Constructor	Description
CoreQueryOptionsTransactions()
CoreQueryOptionsTransactions(CoreQueryOptions original)

Method Summary

Modifier and Type	Method	Description
boolean	adhoc()
CoreSingleQueryTransactionOptions	asTransactionOptions()
String	clientContextId()
CoreCommonOptions	commonOptions()
CoreMutationState	consistentWith()
boolean	flexIndex()
Integer	maxParallelism()
boolean	metrics()
CoreQueryOptionsTransactions	metrics(boolean metrics)
com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode	namedParameters()
Integer	pipelineBatch()
Integer	pipelineCap()
com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ArrayNode	positionalParameters()
Boolean	preserveExpiry()
CoreQueryProfile	profile()
CoreQueryOptionsTransactions	put(String key, com.couchbase.client.core.deps.com.fasterxml.jackson.databind.JsonNode value)
com.couchbase.client.core.deps.com.fasterxml.jackson.databind.JsonNode	raw()
CoreQueryOptionsTransactions	raw(String key, com.couchbase.client.core.deps.com.fasterxml.jackson.databind.JsonNode value)
boolean	readonly()
Integer	scanCap()
CoreQueryScanConsistency	scanConsistency()
Duration	scanWait()
CoreQueryOptionsTransactions	set(CoreQueryOptionsTransactions.QueryOptionsParameter param, CoreQueryOptionsTransactions.ParameterPassthrough passthrough)
Boolean	useReplica()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.couchbase.client.core.api.query.CoreQueryOptions

asTransaction

Constructor Details

CoreQueryOptionsTransactions

public CoreQueryOptionsTransactions()

CoreQueryOptionsTransactions

public CoreQueryOptionsTransactions(@Nullable
 CoreQueryOptions original)

Method Details

raw

public CoreQueryOptionsTransactions raw(String key,
 com.couchbase.client.core.deps.com.fasterxml.jackson.databind.JsonNode value)

metrics

public CoreQueryOptionsTransactions metrics(boolean metrics)

set

public CoreQueryOptionsTransactions set(CoreQueryOptionsTransactions.QueryOptionsParameter param,
 CoreQueryOptionsTransactions.ParameterPassthrough passthrough)

put

public CoreQueryOptionsTransactions put(String key,
 com.couchbase.client.core.deps.com.fasterxml.jackson.databind.JsonNode value)

adhoc

public boolean adhoc()

Specified by:

adhoc in interface CoreQueryOptions

clientContextId

public String clientContextId()

Specified by:

clientContextId in interface CoreQueryOptions

consistentWith

public CoreMutationState consistentWith()

Specified by:

consistentWith in interface CoreQueryOptions

maxParallelism

public Integer maxParallelism()

Specified by:

maxParallelism in interface CoreQueryOptions

metrics

public boolean metrics()

Specified by:

metrics in interface CoreQueryOptions

namedParameters

public com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode namedParameters()

Specified by:

namedParameters in interface CoreQueryOptions

pipelineBatch

public Integer pipelineBatch()

Specified by:

pipelineBatch in interface CoreQueryOptions

pipelineCap

public Integer pipelineCap()

Specified by:

pipelineCap in interface CoreQueryOptions

positionalParameters

public com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ArrayNode positionalParameters()

Specified by:

positionalParameters in interface CoreQueryOptions

profile

public CoreQueryProfile profile()

Specified by:

profile in interface CoreQueryOptions

raw

public com.couchbase.client.core.deps.com.fasterxml.jackson.databind.JsonNode raw()

Specified by:

raw in interface CoreQueryOptions

readonly

public boolean readonly()

Specified by:

readonly in interface CoreQueryOptions

scanWait

public Duration scanWait()

Specified by:

scanWait in interface CoreQueryOptions

scanCap

public Integer scanCap()

Specified by:

scanCap in interface CoreQueryOptions

scanConsistency

public CoreQueryScanConsistency scanConsistency()

Specified by:

scanConsistency in interface CoreQueryOptions

flexIndex

public boolean flexIndex()

Specified by:

flexIndex in interface CoreQueryOptions

preserveExpiry

public Boolean preserveExpiry()

Specified by:

preserveExpiry in interface CoreQueryOptions

useReplica

public Boolean useReplica()

Specified by:

useReplica in interface CoreQueryOptions

asTransactionOptions

public CoreSingleQueryTransactionOptions asTransactionOptions()

Specified by:

asTransactionOptions in interface CoreQueryOptions

commonOptions

public CoreCommonOptions commonOptions()

Specified by:

commonOptions in interface CoreQueryOptions