aboutsummaryrefslogtreecommitdiff
path: root/central/src/main/java/moe/yuuta/dn42peering/database/DatabaseUtils.java
diff options
context:
space:
mode:
Diffstat (limited to 'central/src/main/java/moe/yuuta/dn42peering/database/DatabaseUtils.java')
-rw-r--r--central/src/main/java/moe/yuuta/dn42peering/database/DatabaseUtils.java27
1 files changed, 27 insertions, 0 deletions
diff --git a/central/src/main/java/moe/yuuta/dn42peering/database/DatabaseUtils.java b/central/src/main/java/moe/yuuta/dn42peering/database/DatabaseUtils.java
new file mode 100644
index 0000000..8219f50
--- /dev/null
+++ b/central/src/main/java/moe/yuuta/dn42peering/database/DatabaseUtils.java
@@ -0,0 +1,27 @@
+package moe.yuuta.dn42peering.database;
+
+import io.vertx.core.Vertx;
+import io.vertx.core.impl.logging.Logger;
+import io.vertx.core.impl.logging.LoggerFactory;
+import io.vertx.core.json.JsonObject;
+import io.vertx.mysqlclient.MySQLConnectOptions;
+import io.vertx.mysqlclient.MySQLPool;
+import io.vertx.sqlclient.Pool;
+import io.vertx.sqlclient.PoolOptions;
+import io.vertx.sqlclient.PropertyKind;
+
+import javax.annotation.Nonnull;
+
+public final class DatabaseUtils {
+ public static PropertyKind<Long> LAST_INSERTED_ID = PropertyKind.create("last-inserted-id", Long.class);
+
+ private static final Logger logger =
+ LoggerFactory.getLogger(DatabaseUtils.class.getSimpleName());
+
+ @Nonnull
+ public static Pool getPool(@Nonnull Vertx vertx) {
+ final JsonObject json = vertx.getOrCreateContext().config().getJsonObject("database");
+ final MySQLConnectOptions opt = new MySQLConnectOptions(json);
+ return MySQLPool.pool(vertx, opt, new PoolOptions().setMaxSize(5));
+ }
+}