aboutsummaryrefslogtreecommitdiff
path: root/central/src/main/java/moe/yuuta/dn42peering/node/NodeServiceImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'central/src/main/java/moe/yuuta/dn42peering/node/NodeServiceImpl.java')
-rw-r--r--central/src/main/java/moe/yuuta/dn42peering/node/NodeServiceImpl.java8
1 files changed, 5 insertions, 3 deletions
diff --git a/central/src/main/java/moe/yuuta/dn42peering/node/NodeServiceImpl.java b/central/src/main/java/moe/yuuta/dn42peering/node/NodeServiceImpl.java
index cdcabf3..a2535d4 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/node/NodeServiceImpl.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/node/NodeServiceImpl.java
@@ -4,8 +4,10 @@ import io.vertx.core.AsyncResult;
import io.vertx.core.Future;
import io.vertx.core.Handler;
import io.vertx.core.Vertx;
-import io.vertx.mysqlclient.MySQLPool;
+import io.vertx.sqlclient.Pool;
+import io.vertx.sqlclient.RowSet;
import io.vertx.sqlclient.templates.SqlTemplate;
+import moe.yuuta.dn42peering.database.DatabaseUtils;
import javax.annotation.Nonnull;
import java.util.ArrayList;
@@ -13,10 +15,10 @@ import java.util.Collections;
import java.util.List;
class NodeServiceImpl implements INodeService {
- private final MySQLPool pool;
+ private final Pool pool;
private final Vertx vertx;
- NodeServiceImpl(@Nonnull Vertx vertx, @Nonnull MySQLPool mySQLPool) {
+ NodeServiceImpl(@Nonnull Vertx vertx, @Nonnull Pool mySQLPool) {
this.vertx = vertx;
this.pool = mySQLPool;
}