#573 - Add integration test for interval type

Author: slutmaker

src/test/java/org/springframework/data/r2dbc/core/PostgresIntegrationTests.java

@@ -20,20 +20,14 @@
 
 import io.r2dbc.postgresql.PostgresqlConnectionConfiguration;
 import io.r2dbc.postgresql.PostgresqlConnectionFactory;
-import io.r2dbc.postgresql.codec.Box;
-import io.r2dbc.postgresql.codec.Circle;
-import io.r2dbc.postgresql.codec.EnumCodec;
-import io.r2dbc.postgresql.codec.Line;
-import io.r2dbc.postgresql.codec.Lseg;
-import io.r2dbc.postgresql.codec.Path;
-import io.r2dbc.postgresql.codec.Point;
-import io.r2dbc.postgresql.codec.Polygon;
+import io.r2dbc.postgresql.codec.*;
 import io.r2dbc.postgresql.extension.CodecRegistrar;
 import io.r2dbc.spi.ConnectionFactory;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import reactor.test.StepVerifier;
 
+import java.time.Duration;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
@@ -245,6 +239,27 @@ void shouldReadAndWriteGeoTypes() {
 		assertThat(saved).isEqualTo(loaded);
 	}
 
+	@Test // gh-573
+	void shouldReadAndWriteInterval() {
+		EntityWithInterval entityWithInterval = new EntityWithInterval();
+		entityWithInterval.interval = Interval.of(Duration.ofHours(3));
+
+		template.execute("DROP TABLE IF EXISTS with_interval");
+		template.execute("CREATE TABLE with_interval (" //
+						 + "id serial PRIMARY KEY," //
+						 + "interval INTERVAL" //
+						 + ")");
+
+		R2dbcEntityTemplate template = new R2dbcEntityTemplate(client,
+				new DefaultReactiveDataAccessStrategy(PostgresDialect.INSTANCE));
+
+		EntityWithInterval saved = template.insert(entityWithInterval).block();
+		EntityWithInterval loaded = template.select(Query.empty(), EntityWithInterval.class) //
+				.blockLast();
+
+		assertThat(saved.interval).isEqualTo(loaded.interval);
+	}
+
 	private void insert(EntityWithArrays object) {
 
 		client.insert() //
@@ -300,4 +315,15 @@ static class GeoType {
 		org.springframework.data.geo.Point springDataPoint;
 		org.springframework.data.geo.Polygon springDataPolygon;
 	}
+
+	@Data
+	@Table("with_interval")
+	static class EntityWithInterval {
+
+		@Id Integer id;
+
+		Interval interval;
+
+	}
+
 }