diff --git a/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/AsyncCqlOperationsExtensions.kt b/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/AsyncCqlOperationsExtensions.kt index 2d56636f0..b71d4eb06 100644 --- a/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/AsyncCqlOperationsExtensions.kt +++ b/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/AsyncCqlOperationsExtensions.kt @@ -59,7 +59,7 @@ fun AsyncCqlOperations.queryForObject( entityClass: KClass, vararg args: Any ): CompletableFuture = - queryForObject(cql, entityClass.java, args) + queryForObject(cql, entityClass.java, *args) /** * Extension for [AsyncCqlOperations.queryForObject] leveraging reified type parameters. @@ -68,7 +68,7 @@ inline fun AsyncCqlOperations.queryForObject( cql: String, vararg args: Any ): CompletableFuture = - queryForObject(cql, T::class.java, args) + queryForObject(cql, T::class.java, *args) /** * Extension for [AsyncCqlOperations.queryForObject] leveraging reified type parameters. @@ -78,7 +78,7 @@ fun AsyncCqlOperations.queryForObject( vararg args: Any, function: (Row, Int) -> T ): CompletableFuture = - queryForObject(cql, RowMapper { row, i -> function(row, i) }, *args) + queryForObject(cql, { row, i -> function(row, i) }, *args) /** * Extension for [AsyncCqlOperations.queryForObject] providing a [KClass] based variant. @@ -114,7 +114,7 @@ inline fun AsyncCqlOperations.queryForList( cql: String, vararg args: Any ): CompletableFuture> = - queryForList(cql, T::class.java, args) + queryForList(cql, T::class.java, *args) /** * Extension for [AsyncCqlOperations.queryForList] providing a [KClass] based variant. diff --git a/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/CqlOperationsExtensions.kt b/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/CqlOperationsExtensions.kt index a37495164..045d10889 100644 --- a/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/CqlOperationsExtensions.kt +++ b/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/CqlOperationsExtensions.kt @@ -46,19 +46,19 @@ inline fun CqlOperations.queryForObject(cql: String): T? = */ @Deprecated("Since 2.2, use the reified variant", replaceWith = ReplaceWith("queryForObject(cql, args)")) fun CqlOperations.queryForObject(cql: String, entityClass: KClass, vararg args: Any): T? = - queryForObject(cql, entityClass.java, args) + queryForObject(cql, entityClass.java, *args) /** * Extension for [CqlOperations.queryForObject] leveraging reified type parameters. */ inline fun CqlOperations.queryForObject(cql: String, vararg args: Any): T? = - queryForObject(cql, T::class.java, args) + queryForObject(cql, T::class.java, *args) /** * Extension for [CqlOperations.queryForObject] leveraging reified type parameters. */ fun CqlOperations.queryForObject(cql: String, vararg args: Any, function: (Row, Int) -> T): T? = - queryForObject(cql, function, args) + queryForObject(cql, function, *args) /** * Extension for [CqlOperations.queryForObject] providing a [KClass] based variant. @@ -85,7 +85,7 @@ inline fun CqlOperations.queryForList(cql: String): List = */ @Suppress("EXTENSION_SHADOWED_BY_MEMBER") inline fun CqlOperations.queryForList(cql: String, vararg args: Any): List = - queryForList(cql, T::class.java, args) + queryForList(cql, T::class.java, *args) /** * Extension for [CqlOperations.queryForList] providing a [KClass] based variant. diff --git a/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/ReactiveCqlOperationsExtensions.kt b/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/ReactiveCqlOperationsExtensions.kt index e7bba47d2..9cb276a00 100644 --- a/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/ReactiveCqlOperationsExtensions.kt +++ b/spring-data-cassandra/src/main/kotlin/org/springframework/data/cassandra/core/cql/ReactiveCqlOperationsExtensions.kt @@ -48,19 +48,19 @@ inline fun ReactiveCqlOperations.queryForObject(cql: String): */ @Deprecated("Since 2.2, use the reified variant", replaceWith = ReplaceWith("queryForObject(cql, args)")) fun ReactiveCqlOperations.queryForObject(cql: String, entityClass: KClass, vararg args: Any): Mono = - queryForObject(cql, entityClass.java, args) + queryForObject(cql, entityClass.java, *args) /** * Extension for [ReactiveCqlOperations.queryForObject] leveraging reified type parameters. */ inline fun ReactiveCqlOperations.queryForObject(cql: String, vararg args: Any): Mono = - queryForObject(cql, T::class.java, args) + queryForObject(cql, T::class.java, *args) /** * Extension for [ReactiveCqlOperations.queryForObject] leveraging reified type parameters. */ fun ReactiveCqlOperations.queryForObject(cql: String, vararg args: Any, function: (Row, Int) -> T): Mono = - queryForObject(cql, function, args) + queryForObject(cql, function, *args) /** * Extension for [ReactiveCqlOperations.queryForObject] providing a [KClass] based variant. @@ -87,7 +87,7 @@ inline fun ReactiveCqlOperations.queryForFlux(cql: String): Fl */ @Suppress("EXTENSION_SHADOWED_BY_MEMBER") inline fun ReactiveCqlOperations.queryForFlux(cql: String, vararg args: Any): Flux = - queryForFlux(cql, T::class.java, args) + queryForFlux(cql, T::class.java, *args) /** * Extension for [ReactiveCqlOperations.queryForFlux] providing a [KClass] based variant. diff --git a/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/CqlOperationsExtensionsUnitTests.kt b/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/CqlOperationsExtensionsUnitTests.kt index d923b0b1f..9032effab 100644 --- a/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/CqlOperationsExtensionsUnitTests.kt +++ b/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/CqlOperationsExtensionsUnitTests.kt @@ -49,14 +49,14 @@ class CqlOperationsExtensionsUnitTests { fun `queryForObject(String, KClass, array) extension should call its Java counterpart`() { operations.queryForObject("", Person::class, "foo", "bar") - verify { operations.queryForObject("", Person::class.java, arrayOf("foo", "bar")) } + verify { operations.queryForObject("", Person::class.java, "foo", "bar") } } @Test // DATACASS-484 fun `queryForObject(String, array) extension should call its Java counterpart`() { operations.queryForObject("", "foo", "bar") - verify { operations.queryForObject("", Person::class.java, arrayOf("foo", "bar")) } + verify { operations.queryForObject("", Person::class.java, "foo", "bar") } } @Test // DATACASS-484 @@ -67,7 +67,7 @@ class CqlOperationsExtensionsUnitTests { operations.queryForObject( eq(""), any>(), - eq(arrayOf(3)) + eq(3) ) } } @@ -101,7 +101,7 @@ class CqlOperationsExtensionsUnitTests { fun `queryForList(String, array) extension should call its Java counterpart`() { operations.queryForList("", "foo", "bar") - verify { operations.queryForList("", Person::class.java, arrayOf("foo", "bar")) } + verify { operations.queryForList("", Person::class.java, "foo", "bar") } } @Test // DATACASS-484 diff --git a/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/LegacyAsyncCqlOperationsExtensionsUnitTests.kt b/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/LegacyAsyncCqlOperationsExtensionsUnitTests.kt index 56fd14dcf..6745fc68f 100644 --- a/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/LegacyAsyncCqlOperationsExtensionsUnitTests.kt +++ b/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/LegacyAsyncCqlOperationsExtensionsUnitTests.kt @@ -50,14 +50,14 @@ class LegacyAsyncCqlOperationsExtensionsUnitTests { fun `queryForObject(String, KClass, array) extension should call its Java counterpart`() { operations.queryForObject("", Person::class, "foo", "bar") - verify { operations.queryForObject("", Person::class.java, arrayOf("foo", "bar")) } + verify { operations.queryForObject("", Person::class.java, "foo", "bar") } } @Test // DATACASS-484 fun `queryForObject(String, array) extension should call its Java counterpart`() { operations.queryForObject("", "foo", "bar") - verify { operations.queryForObject("", Person::class.java, arrayOf("foo", "bar")) } + verify { operations.queryForObject("", Person::class.java, "foo", "bar") } } @Test // DATACASS-484 @@ -96,7 +96,7 @@ class LegacyAsyncCqlOperationsExtensionsUnitTests { fun `queryForList(String, array) extension should call its Java counterpart`() { operations.queryForList("", "foo", "bar") - verify { operations.queryForList("", Person::class.java, arrayOf("foo", "bar")) } + verify { operations.queryForList("", Person::class.java, "foo", "bar") } } @Test // DATACASS-484 diff --git a/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/ReactiveCqlOperationsExtensionsUnitTests.kt b/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/ReactiveCqlOperationsExtensionsUnitTests.kt index 37c73b753..3803b7353 100644 --- a/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/ReactiveCqlOperationsExtensionsUnitTests.kt +++ b/spring-data-cassandra/src/test/kotlin/org/springframework/data/cassandra/core/cql/ReactiveCqlOperationsExtensionsUnitTests.kt @@ -49,14 +49,14 @@ class ReactiveCqlOperationsExtensionsUnitTests { fun `queryForObject(String, KClass, array) extension should call its Java counterpart`() { operations.queryForObject("", Person::class, "foo", "bar") - verify { operations.queryForObject("", Person::class.java, arrayOf("foo", "bar")) } + verify { operations.queryForObject("", Person::class.java, "foo", "bar") } } @Test // DATACASS-484 fun `queryForObject(String, array) extension should call its Java counterpart`() { operations.queryForObject("", "foo", "bar") - verify { operations.queryForObject("", Person::class.java, arrayOf("foo", "bar")) } + verify { operations.queryForObject("", Person::class.java, "foo", "bar") } } @Test // DATACASS-484 @@ -67,7 +67,7 @@ class ReactiveCqlOperationsExtensionsUnitTests { operations.queryForObject( eq(""), any>(), - eq(arrayOf(3)) + eq(3) ) } } @@ -101,7 +101,7 @@ class ReactiveCqlOperationsExtensionsUnitTests { fun `queryForFlux(String, array) extension should call its Java counterpart`() { operations.queryForFlux("", "foo", "bar") - verify { operations.queryForFlux("", Person::class.java, arrayOf("foo", "bar")) } + verify { operations.queryForFlux("", Person::class.java, "foo", "bar") } } @Test // DATACASS-484