Upgrade Couchbase Java SDK to 3.12.1

Signed-off-by: Emilien Bevierre <emilien.bevierre@couchbase.com>

Author: emilienbev

pom.xml

@@ -18,7 +18,7 @@
     </parent>
 
     <properties>
-        <couchbase>3.11.3</couchbase>
+        <couchbase>3.12.1</couchbase>
         <springdata.commons>4.2.0-SNAPSHOT</springdata.commons>
         <java-module-name>spring.data.couchbase</java-module-name>
         <hibernate.validator>7.0.1.Final</hibernate.validator>

src/main/java/org/springframework/data/couchbase/core/ReactiveFindByIdOperationSupport.java

@@ -131,7 +131,7 @@ public Mono<T> one(final Object id) {
 					}
 				} else {
 					rejectInvalidTransactionalOptions();
-					return ctxOpt.get().getCore().get(makeCollectionIdentifier(rc.async()), id.toString())
+					return ctxOpt.get().getCore().getReactive(makeCollectionIdentifier(rc.async()), id.toString())
 							.flatMap(result -> support.decodeEntity(id, result.contentAsBytes(),
 									result.cas(), null, domainType, pArgs.getScope(), pArgs.getCollection(), null,
 									null));

src/main/java/org/springframework/data/couchbase/core/ReactiveFindByQueryOperationSupport.java

@@ -209,7 +209,7 @@ public Flux<T> all() {
 					JsonSerializer jSer = clientFactory.getCluster().environment().jsonSerializer();
 					CoreQueryOptions opts = options != null ? options.builder().build() : null;
 					return s.get().getCore()
-							.queryBlocking(statement,
+							.queryReactive(statement,
 									pArgs.getScope() == null ? null
 											: CoreQueryContext.of(rs.bucketName(), pArgs.getScope()),
 									opts, false)
@@ -278,7 +278,7 @@ public Mono<Long> count() {
 					JsonSerializer jSer = clientFactory.getCluster().environment().jsonSerializer();
 					CoreQueryOptions opts = options != null ? options.builder().build() : null;
 					return s.get().getCore()
-							.queryBlocking(statement,
+							.queryReactive(statement,
 									pArgs.getScope() == null ? null
 											: CoreQueryContext.of(rs.bucketName(), pArgs.getScope()),
 									opts, false)

src/main/java/org/springframework/data/couchbase/core/ReactiveRemoveByIdOperationSupport.java

@@ -117,15 +117,15 @@ public Mono<RemoveResult> one(final Object id) {
 						throw new IllegalArgumentException("cas must be supplied for tx remove");
 					}
 					CoreTransactionAttemptContext ctx = s.get().getCore();
-					Mono<CoreTransactionGetResult> gr = ctx.get(makeCollectionIdentifier(rc.async()), id.toString());
+					Mono<CoreTransactionGetResult> gr = ctx.getReactive(makeCollectionIdentifier(rc.async()), id.toString());
 
 					return gr.flatMap(getResult -> {
 						if (getResult.cas() != cas) {
 							return Mono.error(TransactionalSupport.retryTransactionOnCasMismatch(ctx, getResult.cas(), cas));
 						}
 						CoreTransactionAttemptContext internal = ctx;
 						RequestSpan span = CbTracing.newSpan(internal.core().context(), TRANSACTION_OP_REMOVE, internal.span());
-						return ctx.remove(getResult, new SpanWrapper(span)).map(r -> new RemoveResult(id.toString(), 0, null));
+						return ctx.removeReactive(getResult, new SpanWrapper(span)).map(r -> new RemoveResult(id.toString(), 0, null));
 					});
 
 				}

src/main/java/org/springframework/data/couchbase/core/ReactiveRemoveByQueryOperationSupport.java

@@ -101,7 +101,7 @@ public Flux<RemoveResult> all() {
 							.buildTransactionQueryOptions(buildQueryOptions(pArgs.getOptions()));
 					CoreQueryContext queryContext = OptionsBuilder.queryContext(pArgs.getScope(), pArgs.getCollection(), rs.bucketName());
 					return transactionContext.get().getCore()
-							.queryBlocking(statement, queryContext, opts.builder().build(), false)
+							.queryReactive(statement, queryContext, opts.builder().build(), false)
 							.flatMapIterable(result -> result.collectRows()).map(row -> {
 								JsonObject json = JsonObject.fromJson(row.data());
 								return new RemoveResult(json.getString(TemplateUtils.SELECT_ID), json.getLong(TemplateUtils.SELECT_CAS),

src/main/java/org/springframework/data/couchbase/core/ReactiveReplaceByIdOperationSupport.java

@@ -125,7 +125,7 @@ public Mono<T> one(T object) {
 									CoreTransactionAttemptContext ctx = ctxOpt.get().getCore();
 									ctx.logger().info(ctx.attemptId(), "refetching %s for Spring replace",
 											DebugUtil.docId(collId, converted.getId().toString()));
-									Mono<CoreTransactionGetResult> gr = ctx.get(collId, converted.getId().toString());
+									Mono<CoreTransactionGetResult> gr = ctx.getReactive(collId, converted.getId().toString());
 
 									return gr.flatMap(getResult -> {
 										if (getResult.cas() != cas) {