diff --git a/src/test/java/io/vertx/ext/asyncsql/PostgreSQLTest.java b/src/test/java/io/vertx/ext/asyncsql/PostgreSQLTest.java index 4ff0b1a9..f676146e 100644 --- a/src/test/java/io/vertx/ext/asyncsql/PostgreSQLTest.java +++ b/src/test/java/io/vertx/ext/asyncsql/PostgreSQLTest.java @@ -21,6 +21,9 @@ import io.vertx.ext.sql.ResultSet; import io.vertx.ext.unit.Async; import io.vertx.ext.unit.TestContext; + +import java.time.Instant; + import org.junit.Before; import org.junit.Test; @@ -128,4 +131,27 @@ public void testUpdatingNumericField(TestContext context) { }); } + @Test + public void testInstant(TestContext context) { + Async async = context.async(); + client.getConnection(ar -> { + ensureSuccess(context, ar); + conn = ar.result(); + conn.execute("DROP TABLE IF EXISTS test_table", ar1 -> { + ensureSuccess(context, ar1); + conn.execute("CREATE TABLE test_table (instant TIMESTAMP)", ar2 -> { + ensureSuccess(context, ar2); + Instant now = Instant.now(); + conn.queryWithParams("INSERT INTO test_table (instant) VALUES (?)", new JsonArray().add(now), ar3 -> { + ensureSuccess(context, ar3); + conn.query("SELECT instant FROM test_table", ar4 -> { + ensureSuccess(context, ar4); + context.assertEquals(ar4.result().getResults().get(0).getInstant(0), now); + async.complete(); + }); + }); + }); + }); + }); + } }