diff --git a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/AsyncCqlTemplateUnitTests.java b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/AsyncCqlTemplateUnitTests.java index 85a9a31f5..112ec978e 100644 --- a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/AsyncCqlTemplateUnitTests.java +++ b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/AsyncCqlTemplateUnitTests.java @@ -179,7 +179,7 @@ class AsyncCqlTemplateUnitTests { List rows = getUninterruptibly( asyncCqlTemplate.query("SELECT * from USERS", (row, index) -> row.getString(0))); - assertThat(rows).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(rows).hasSize(3).contains("Walter", "Hank", "Jesse"); verify(session).executeAsync(any(Statement.class)); }); } @@ -192,7 +192,7 @@ class AsyncCqlTemplateUnitTests { List rows = getUninterruptibly( asyncCqlTemplate.query("SELECT * from USERS", (row, index) -> row.getString(0))); - assertThat(rows).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(rows).hasSize(3).contains("Walter", "Hank", "Jesse"); verify(session).executeAsync(any(Statement.class)); }); } @@ -357,7 +357,7 @@ class AsyncCqlTemplateUnitTests { ListenableFuture> future = asyncCqlTemplate.query(SimpleStatement.newInstance("SELECT * from USERS"), (row, index) -> row.getString(0)); - assertThat(getUninterruptibly(future)).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(getUninterruptibly(future)).hasSize(3).contains("Walter", "Hank", "Jesse"); verify(session).executeAsync(any(Statement.class)); }); } @@ -370,7 +370,7 @@ class AsyncCqlTemplateUnitTests { ListenableFuture> future = asyncCqlTemplate.query(SimpleStatement.newInstance("SELECT * from USERS"), (row, index) -> row.getString(0)); - assertThat(getUninterruptibly(future)).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(getUninterruptibly(future)).hasSize(3).contains("Walter", "Hank", "Jesse"); verify(session).executeAsync(any(Statement.class)); }); } @@ -783,7 +783,7 @@ class AsyncCqlTemplateUnitTests { @Nullable CqlIdentifier keyspace, Consumer cqlTemplateConsumer) { - String[] results = { "Walter", "Hank", " Jesse" }; + String[] results = { "Walter", "Hank", "Jesse" }; when(this.session.executeAsync((Statement) any())).thenReturn(new TestResultSetFuture(resultSet)); when(this.resultSet.currentPage()).thenReturn(Arrays.asList(row, row, row)); diff --git a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/CqlTemplateUnitTests.java b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/CqlTemplateUnitTests.java index ee5a06ac7..6fcca43a0 100644 --- a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/CqlTemplateUnitTests.java +++ b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/CqlTemplateUnitTests.java @@ -158,7 +158,7 @@ class CqlTemplateUnitTests { List rows = cqlTemplate.query("SELECT * from USERS", (row, index) -> row.getString(0)); - assertThat(rows).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(rows).hasSize(3).contains("Walter", "Hank", "Jesse"); verify(session).execute(any(Statement.class)); }); } @@ -170,7 +170,7 @@ class CqlTemplateUnitTests { List rows = cqlTemplate.query("SELECT * from USERS", (row, index) -> row.getString(0)); - assertThat(rows).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(rows).hasSize(3).contains("Walter", "Hank", "Jesse"); verify(session).execute(any(Statement.class)); }); } @@ -321,7 +321,7 @@ class CqlTemplateUnitTests { List result = cqlTemplate.query(SimpleStatement.newInstance("SELECT * from USERS"), (row, index) -> row.getString(0)); - assertThat(result).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(result).hasSize(3).contains("Walter", "Hank", "Jesse"); verify(session).execute(any(Statement.class)); }); } @@ -334,7 +334,7 @@ class CqlTemplateUnitTests { List result = cqlTemplate.query(SimpleStatement.newInstance("SELECT * from USERS"), (row, index) -> row.getString(0)); - assertThat(result).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(result).hasSize(3).contains("Walter", "Hank", "Jesse"); verify(session).execute(any(Statement.class)); }); } @@ -347,7 +347,7 @@ class CqlTemplateUnitTests { Stream result = cqlTemplate.queryForStream(SimpleStatement.newInstance("SELECT * from USERS"), (row, index) -> row.getString(0)); - assertThat(result.collect(Collectors.toList())).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(result.collect(Collectors.toList())).hasSize(3).contains("Walter", "Hank", "Jesse"); verify(session).execute(any(Statement.class)); }); } @@ -756,7 +756,7 @@ class CqlTemplateUnitTests { @Nullable ConsistencyLevel serialConsistencyLevel, @Nullable String executionProfile, @Nullable CqlIdentifier keyspace, Consumer cqlTemplateConsumer) { - String[] results = { "Walter", "Hank", " Jesse" }; + String[] results = { "Walter", "Hank", "Jesse" }; List rows = Arrays.asList(row, row, row); when(this.session.execute((Statement) any())).thenReturn(resultSet); diff --git a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/ReactiveCqlTemplateUnitTests.java b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/ReactiveCqlTemplateUnitTests.java index df80ab48f..4535bd753 100644 --- a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/ReactiveCqlTemplateUnitTests.java +++ b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/ReactiveCqlTemplateUnitTests.java @@ -182,7 +182,7 @@ class ReactiveCqlTemplateUnitTests { Flux flux = reactiveCqlTemplate.query("SELECT * from USERS", (row, index) -> row.getString(0)); - flux.as(StepVerifier::create).expectNext("Walter", "Hank", " Jesse").verifyComplete(); + flux.as(StepVerifier::create).expectNext("Walter", "Hank", "Jesse").verifyComplete(); verify(session).execute(any(Statement.class)); }); @@ -195,7 +195,7 @@ class ReactiveCqlTemplateUnitTests { Flux flux = reactiveCqlTemplate.query("SELECT * from USERS", (row, index) -> row.getString(0)); - flux.as(StepVerifier::create).expectNext("Walter", "Hank", " Jesse").verifyComplete(); + flux.as(StepVerifier::create).expectNext("Walter", "Hank", "Jesse").verifyComplete(); verify(session).execute(any(Statement.class)); }); @@ -387,7 +387,7 @@ class ReactiveCqlTemplateUnitTests { Flux flux = reactiveCqlTemplate.query(SimpleStatement.newInstance("SELECT * from USERS"), (row, index) -> row.getString(0)); - flux.as(StepVerifier::create).expectNext("Walter", "Hank", " Jesse").verifyComplete(); + flux.as(StepVerifier::create).expectNext("Walter", "Hank", "Jesse").verifyComplete(); verify(session).execute(any(Statement.class)); }); @@ -403,7 +403,7 @@ class ReactiveCqlTemplateUnitTests { flux.collectList().as(StepVerifier::create).consumeNextWith(rows -> { - assertThat(rows).hasSize(3).contains("Walter", "Hank", " Jesse"); + assertThat(rows).hasSize(3).contains("Walter", "Hank", "Jesse"); }).verifyComplete(); verify(session).execute(any(Statement.class)); @@ -817,7 +817,7 @@ class ReactiveCqlTemplateUnitTests { @Nullable ConsistencyLevel serialConsistencyLevel, @Nullable String executionProfile, @Nullable CqlIdentifier keyspace, Consumer cqlTemplateConsumer) { - String[] results = { "Walter", "Hank", " Jesse" }; + String[] results = { "Walter", "Hank", "Jesse" }; when(this.session.execute((Statement) any())).thenReturn(Mono.just(reactiveResultSet)); when(this.reactiveResultSet.rows()).thenReturn(Flux.just(row, row, row));