diff options
Diffstat (limited to 'central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java')
-rw-r--r-- | central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java index 2fce4f1..81bd946 100644 --- a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java +++ b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java @@ -162,4 +162,21 @@ class ASNServiceImpl implements IASNService { .onComplete(handler); return this; } + + @Nonnull + @Override + public IASNService list(@Nonnull Handler<AsyncResult<List<ASN>>> handler) { + SqlTemplate + .forQuery(pool, "SELECT asn, activated " + + "FROM asn") + .mapTo(ASNRowMapper.INSTANCE) + .execute(null) + .compose(asns -> { + final List<ASN> asnList = new ArrayList<>(); + for (ASN asn : asns) asnList.add(asn); + return Future.succeededFuture(asnList); + }) + .onComplete(handler); + return this; + } } |