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

DATACASS-722 - Relax test plan for LWT tests.

Browse Source 
LWT tests are now simplified and to not attempt to issue another query as Cassandra becomes eventually consistent.
This commit is contained in:
Mark Paluch
2020-01-29 11:31:30 +01:00
parent f29cededbb
commit 461975cf1a
2 changed files with 1 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/AsyncCassandraTemplateIntegrationTests.java
View File

@@ -217,11 +217,6 @@ public class AsyncCassandraTemplateIntegrationTests extends AbstractKeyspaceCrea
assertThat(getUninterruptibly(updated).wasApplied()).isTrue();
assertThat(getUninterruptibly(updated).getEntity()).isSameAs(user);
// Cassandra requires a while to apply that change...
Thread.sleep(200);
assertThat(getUser(user.getId()).getFirstname()).isEqualTo("Walter Hartwell");
}
@Test // DATACASS-343
@@ -298,7 +293,6 @@ public class AsyncCassandraTemplateIntegrationTests extends AbstractKeyspaceCrea
getUninterruptibly(template.insert(user));
assertThat(getUninterruptibly(template.delete(user, lwtOptions)).wasApplied()).isTrue();
assertThat(getUninterruptibly(template.delete(user, lwtOptions)).wasApplied()).isFalse();
}
@Test // DATACASS-606

8
spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/CassandraTemplateIntegrationTests.java
View File

@@ -316,7 +316,7 @@ public class CassandraTemplateIntegrationTests extends AbstractKeyspaceCreatingI
}
@Test // DATACASS-292
public void updateShouldUpdateEntityWithLwt() throws InterruptedException {
public void updateShouldUpdateEntityWithLwt() {
UpdateOptions lwtOptions = UpdateOptions.builder().withIfExists().build();
@@ -329,10 +329,6 @@ public class CassandraTemplateIntegrationTests extends AbstractKeyspaceCreatingI
WriteResult lwt = template.update(user, lwtOptions);
assertThat(lwt.wasApplied()).isTrue();
// Await until Cassandra has persisted the change
Thread.sleep(300);
assertThat(template.selectOneById(user.getId(), User.class).getFirstname()).isEqualTo("Walter Hartwell");
}
@Test // DATACASS-343
@@ -407,7 +403,6 @@ public class CassandraTemplateIntegrationTests extends AbstractKeyspaceCreatingI
template.insert(user);
assertThat(template.delete(user, lwtOptions).wasApplied()).isTrue();
assertThat(template.delete(user, lwtOptions).wasApplied()).isFalse();
}
@Test // DATACASS-606
@@ -420,7 +415,6 @@ public class CassandraTemplateIntegrationTests extends AbstractKeyspaceCreatingI
Query query = Query.query(where("id").is("heisenberg")).queryOptions(lwtOptions);
assertThat(template.delete(query, User.class)).isTrue();
assertThat(template.delete(query, User.class)).isFalse();
}
@Test // DATACASS-182