Skip to content

Commit 9950022

Browse files
committed
couchbase: query scan consistency is request plus
1 parent be083d5 commit 9950022

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

build.gradle.kts

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,11 @@ subprojects.of("lib", "spring", "examples", "ktor") {
9090
compilerOptions {
9191
jvmTarget.set(JvmTarget.JVM_17)
9292
allWarningsAsErrors = true
93+
freeCompilerArgs.addAll(
94+
"-Xjsr305=strict",
95+
"-Xcontext-receivers",
96+
"-Xsuppress-version-warnings"
97+
)
9398
}
9499
}
95100
}

lib/stove-testing-e2e-couchbase/src/main/kotlin/com/trendyol/stove/testing/e2e/couchbase/CouchbaseSystem.kt

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package com.trendyol.stove.testing.e2e.couchbase
33
import com.couchbase.client.kotlin.*
44
import com.couchbase.client.kotlin.Collection
55
import com.couchbase.client.kotlin.codec.*
6-
import com.couchbase.client.kotlin.query.execute
6+
import com.couchbase.client.kotlin.query.*
77
import com.fasterxml.jackson.databind.ObjectMapper
88
import com.trendyol.stove.functional.*
99
import com.trendyol.stove.testing.e2e.system.TestSystem
@@ -70,7 +70,8 @@ class CouchbaseSystem internal constructor(
7070
): CouchbaseSystem {
7171
val result = cluster.query(
7272
statement = query,
73-
metrics = false
73+
metrics = false,
74+
consistency = QueryScanConsistency.requestPlus()
7475
).execute().rows.map { it.contentAs<T>() }
7576
val objects = result
7677
.map { objectMapper.writeValueAsString(it) }

0 commit comments

Comments
 (0)