From 90299707ff708a227c2fb33e19cba34eaef5d00f Mon Sep 17 00:00:00 2001 From: Sander Hautvast Date: Tue, 7 Jul 2020 10:49:57 +0200 Subject: [PATCH] cleanup --- src/main/java/nl/sander/BewegingRepo.java | 28 ++++------------------- 1 file changed, 4 insertions(+), 24 deletions(-) diff --git a/src/main/java/nl/sander/BewegingRepo.java b/src/main/java/nl/sander/BewegingRepo.java index 3f1ab8a..d7333be 100644 --- a/src/main/java/nl/sander/BewegingRepo.java +++ b/src/main/java/nl/sander/BewegingRepo.java @@ -6,10 +6,7 @@ import io.vertx.mutiny.pgclient.PgPool; import io.vertx.mutiny.sqlclient.Row; import io.vertx.mutiny.sqlclient.RowSet; import io.vertx.mutiny.sqlclient.Tuple; -import io.vertx.pgclient.PgConnectOptions; -import io.vertx.sqlclient.PoolOptions; -import javax.annotation.PostConstruct; import javax.enterprise.context.ApplicationScoped; import javax.inject.Inject; import javax.transaction.Transactional; @@ -21,21 +18,6 @@ public class BewegingRepo { @Inject PgPool client; -// @PostConstruct -// public void init() { -// PgConnectOptions connectOptions = new PgConnectOptions() -// .setPort(5432) -// .setHost("localhost") -// .setDatabase("postgres") -// .setUser("postgres") -// .setPassword("sander"); -// -// PoolOptions poolOptions = new PoolOptions() -// .setMaxSize(2); -// -// client = PgPool.pool(connectOptions, poolOptions); -// } - public Uni getBeweging(String id) { String sql = "select * from beweging where id = $1"; @@ -55,15 +37,13 @@ public class BewegingRepo { } - private Function mapRow() { - return row -> new Beweging(row.getLong("id"), row.getLocalDate("vldatum"), row.getString("bewegingcode")); - } - - - @Transactional public void persist(Beweging beweging) { client.preparedQuery("insert into beweging(vldatum, bewegingcode) values ($1,$2)") .execute(Tuple.of(beweging.getVlDatum(), beweging.getBewegingcode())).await().indefinitely(); } + + private Function mapRow() { + return row -> new Beweging(row.getLong("id"), row.getLocalDate("vldatum"), row.getString("bewegingcode")); + } }