Modifier and Type | Method and Description |
---|---|
static CoreQueryContext |
CoreQueryContext.of(String bucket,
String scope)
Returns a query context for the default namespace, with the given bucket and scope names.
|
Modifier and Type | Method and Description |
---|---|
CoreAsyncResponse<CoreQueryResult> |
CoreQueryOps.queryAsync(String statement,
CoreQueryOptions options,
CoreQueryContext queryContext,
NodeIdentifier target,
Function<Throwable,RuntimeException> errorConverter) |
default CoreQueryResult |
CoreQueryOps.queryBlocking(String statement,
CoreQueryOptions options,
CoreQueryContext queryContext,
NodeIdentifier target,
Function<Throwable,RuntimeException> errorConverter)
Performs a query.
|
Mono<CoreReactiveQueryResult> |
CoreQueryOps.queryReactive(String statement,
CoreQueryOptions options,
CoreQueryContext queryContext,
NodeIdentifier target,
Function<Throwable,RuntimeException> errorConverter) |
Modifier and Type | Method and Description |
---|---|
CoreAsyncResponse<CoreQueryResult> |
ClassicCoreQueryOps.queryAsync(String statement,
CoreQueryOptions options,
CoreQueryContext queryContext,
NodeIdentifier target,
Function<Throwable,RuntimeException> errorConverter) |
Mono<CoreReactiveQueryResult> |
ClassicCoreQueryOps.queryReactive(String statement,
CoreQueryOptions options,
CoreQueryContext queryContext,
NodeIdentifier target,
Function<Throwable,RuntimeException> errorConverter) |
Modifier and Type | Method and Description |
---|---|
CoreAsyncResponse<CoreQueryResult> |
ProtostellarCoreQueryOps.queryAsync(String statement,
CoreQueryOptions options,
CoreQueryContext queryContext,
NodeIdentifier target,
Function<Throwable,RuntimeException> errorConverter) |
CoreQueryResult |
ProtostellarCoreQueryOps.queryBlocking(String statement,
CoreQueryOptions options,
CoreQueryContext queryContext,
NodeIdentifier target,
Function<Throwable,RuntimeException> errorConverter) |
Mono<CoreReactiveQueryResult> |
ProtostellarCoreQueryOps.queryReactive(String statement,
CoreQueryOptions options,
CoreQueryContext queryContext,
NodeIdentifier target,
Function<Throwable,RuntimeException> errorConverter) |
Modifier and Type | Method and Description |
---|---|
Mono<CoreReactiveQueryResult> |
CoreTransactionsReactive.query(String statement,
CoreQueryContext queryContext,
CoreQueryOptions queryOptions,
Optional<RequestSpan> parentSpan,
Function<Throwable,RuntimeException> errorConverter)
Performs a single query transaction, with a scope context and custom configuration.
|
Mono<CoreQueryResult> |
CoreTransactionAttemptContext.queryBlocking(String statement,
CoreQueryContext qc,
CoreQueryOptions options,
boolean tximplicit)
Used by AttemptContext, buffers all query rows in-memory.
|
Mono<CoreQueryResult> |
CoreTransactionsReactive.queryBlocking(String statement,
CoreQueryContext qc,
CoreQueryOptions queryOptions,
Optional<RequestSpan> parentSpan) |
Mono<ClassicCoreReactiveQueryResult> |
CoreTransactionAttemptContext.queryWrapperLocked(int sidx,
CoreQueryContext qc,
String statement,
CoreQueryOptions options,
String hookPoint,
boolean isBeginWork,
boolean existingErrorCheck,
com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ObjectNode txdata,
com.couchbase.client.core.deps.com.fasterxml.jackson.databind.node.ArrayNode params,
SpanWrapper span,
boolean tximplicit,
AtomicReference<ReactiveLock.Waiter> lockToken,
boolean updateInternalState)
This will return a TransactionOperationFailedException if that's what query returns, else will return the error after
passing through convertQueryError.
|
Copyright © 2024 Couchbase, Inc.. All rights reserved.