Spring/spring-data-cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACASS-809 - Polishing.

Browse Source 
Remove leading space in test strings to simplify assertions.
This commit is contained in:
Mark Paluch
2020-10-01 10:50:07 +02:00
parent d6a32814ca
commit 9728df0c3c
3 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/AsyncCqlTemplateUnitTests.java
View File

@@ -179,7 +179,7 @@ class AsyncCqlTemplateUnitTests {
List<String> 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<String> 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<List<String>> 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<List<String>> 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<AsyncCqlTemplate> 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));

12
spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/CqlTemplateUnitTests.java
View File

@@ -158,7 +158,7 @@ class CqlTemplateUnitTests {
List<String> 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<String> 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<String> 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<String> 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<String> 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<CqlTemplate> cqlTemplateConsumer) {
String[] results = { "Walter", "Hank", " Jesse" };
String[] results = { "Walter", "Hank", "Jesse" };
List<Row> rows = Arrays.asList(row, row, row);
when(this.session.execute((Statement) any())).thenReturn(resultSet);

10
spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/cql/ReactiveCqlTemplateUnitTests.java
View File

@@ -182,7 +182,7 @@ class ReactiveCqlTemplateUnitTests {
Flux<String> 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<String> 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<String> 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<ReactiveCqlTemplate> 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));