Commit 5af9f56

tudormarcmp911de

authored and

committed

Allow WriterOptionsBuilder to set ttl to 0.

Value 0 tells the Cassandra driver to disable the ttl. Original pull request: #1270. Closes #1262

1 parent 5866f00 commit 5af9f56Copy full SHA for 5af9f56

File tree

+11

-7

lines changed

spring-data-cassandra/src
- main/java/org/springframework/data/cassandra/core/cql
  - WriteOptions.java
- test/java/org/springframework/data/cassandra/core/cql
  - WriteOptionsUnitTests.java

+11

-7

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -145,6 +145,7 @@ public int hashCode() {`
`145`	`145`	`* @author Mark Paluch`
`146`	`146`	`* @author Lukasz Antoniak`
`147`	`147`	`* @author Thomas Strauß`
	`148`	`+ * @author Tudor Marc`
`148`	`149`	`* @since 1.5`
`149`	`150`	`*/`
`150`	`151`	`public static class WriteOptionsBuilder extends QueryOptionsBuilder {`
`@@ -288,7 +289,7 @@ public WriteOptionsBuilder ttl(int ttl) {`
`288`	`289`	`public WriteOptionsBuilder ttl(Duration ttl) {`
`289`	`290`
`290`	`291`	`Assert.notNull(ttl, "TTL must not be null");`
`291`		`- Assert.isTrue(!ttl.isNegative() && !ttl.isZero(), "TTL must be greater than equal to zero");`
	`292`	`+ Assert.isTrue(!ttl.isNegative(), "TTL must be greater than equal to zero");`
`292`	`293`
`293`	`294`	`this.ttl = ttl;`
`294`	`295`

Lines changed: 9 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -35,6 +35,7 @@`
`35`	`35`	`* @author Mark Paluch`
`36`	`36`	`* @author Sam Lightfoot`
`37`	`37`	`* @author Thomas Strauß`
	`38`	`+ * @author Tudor Marc`
`38`	`39`	`*/`
`39`	`40`	`class WriteOptionsUnitTests {`
`40`	`41`
`@@ -107,16 +108,18 @@ void buildWriteOptionsMutate() {`
`107`	`108`	`assertThat(writeOptions.getRoutingKey()).isEqualTo(ByteBuffer.allocate(1));`
`108`	`109`	`}`
`109`	`110`
`110`		`- @Test // GH-1248`
`111`		`- void buildWriteOptionsWithTtlDurationZero() {`
`112`		`- assertThatIllegalArgumentException().isThrownBy(() -> WriteOptions.builder().ttl(0));`
`113`		`- assertThatIllegalArgumentException().isThrownBy(() -> WriteOptions.builder().ttl(Duration.ZERO));`
`114`		`- }`
`115`		`-`
`116`	`111`	`@Test // GH-1248`
`117`	`112`	`void buildWriteOptionsWithTtlNegativeDuration() {`
`118`	`113`	`assertThatIllegalArgumentException().isThrownBy(() -> WriteOptions.builder().ttl(-1));`
`119`	`114`	`assertThatIllegalArgumentException()`
`120`	`115`	`.isThrownBy(() -> WriteOptions.builder().ttl(Duration.of(-1, ChronoUnit.MICROS)));`
`121`	`116`	`}`
	`117`	`+`
	`118`	`+ @Test // GH-1262`
	`119`	`+ void buildZeroDurationTtlWriterOptions() {`
	`120`	`+`
	`121`	`+ WriteOptions writeOptions = WriteOptions.builder().ttl(0).build();`
	`122`	`+`
	`123`	`+ assertThat(writeOptions.getTtl()).isEqualTo(Duration.ZERO);`
	`124`	`+ }`
`122`	`125`	`}`

Comments

(0)