Database connection. Only PostgreSQL and SQLite.

Author: UnFamousSoul

src/main/java/com/unfamoussoul/test/Test.java

@@ -1,12 +1,14 @@
 package com.unfamoussoul.test;
 
 import com.unfamoussoul.sapi.SAPI;
+import com.unfamoussoul.sapi.api.database.DatabaseConfig;
 import com.unfamoussoul.sapi.api.serialize.Persistent;
 import com.unfamoussoul.sapi.module.SAPIModule;
 import com.unfamoussoul.test.command.RememberCommand;
 import com.unfamoussoul.test.command.RemindCommand;
 import com.unfamoussoul.test.command.TestCommand;
 import com.unfamoussoul.test.config.Config;
+import com.unfamoussoul.test.database.TestDatabaseHandler;
 import com.unfamoussoul.test.listener.EventListener;
 import com.unfamoussoul.test.web.Web;
 
@@ -16,6 +18,7 @@
 public class Test extends SAPIModule {
 
     private Config config;
+    private TestDatabaseHandler databaseHandler;
 
     @Persistent(value = "player_phrases")
     private final Map<UUID, List<String>> playerPhrases = new HashMap<>();
@@ -35,6 +38,9 @@ public void onEnable() {
         addCommand(new RemindCommand(this));
         addListener(new EventListener(this));
         addWebListener(new Web(this), config.webPort);
+        DatabaseConfig databaseConfig = DatabaseConfig.forSqlite(config.databaseJDBC);
+        databaseHandler = new TestDatabaseHandler(databaseConfig);
+        addDatabaseHandler(databaseHandler);
         getLogger().warning("test---");
     }
 
@@ -43,6 +49,10 @@ public void onDisable() {
         getLogger().warning("test+++");
     }
 
+    public TestDatabaseHandler getDatabaseHandler() {
+        return databaseHandler;
+    }
+
     public void addPhrase(UUID playerId, String phrase) {
         playerPhrases.computeIfAbsent(playerId, k -> new ArrayList<>()).add(phrase);
     }

src/main/java/com/unfamoussoul/test/config/Config.java

@@ -16,6 +16,8 @@ public class Config {
     public final int webThreadsIdle;
     public final int webThreadsEvict;
 
+    public final String databaseJDBC;
+
     public Config(@NotNull ConfigHandler configHandler) {
         FileConfiguration cfg = configHandler.getConfig();
 
@@ -28,5 +30,7 @@ public Config(@NotNull ConfigHandler configHandler) {
         webThreadsQueued = cfg.getInt("web.threads.queued");
         webThreadsIdle = cfg.getInt("web.threads.idle");
         webThreadsEvict = cfg.getInt("web.threads.evict");
+
+        databaseJDBC = cfg.getString("database.jdbc");
     }
 }

src/main/java/com/unfamoussoul/test/database/TestDatabaseHandler.java

@@ -0,0 +1,39 @@
+package com.unfamoussoul.test.database;
+
+import com.unfamoussoul.sapi.api.database.DatabaseConfig;
+import com.unfamoussoul.sapi.api.database.DatabaseHandler;
+import com.unfamoussoul.sapi.api.database.Migration;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.List;
+
+public class TestDatabaseHandler extends DatabaseHandler {
+
+    public TestDatabaseHandler(DatabaseConfig config) {
+        super(
+                config,
+                List.of(
+                        new Migration(1, c -> c.createStatement()
+                                .execute("CREATE TABLE logbook (id INTEGER PRIMARY KEY, route TEXT)")),
+                        new Migration(2, c -> c.createStatement()
+                                .execute("ALTER TABLE logbook ADD COLUMN ip TEXT"))
+                )
+        );
+    }
+
+    public void addLog(String route, String ip) {
+        try (Connection conn = connection()) {
+
+            try (PreparedStatement ps = conn.prepareStatement("INSERT INTO logbook (route, ip) VALUES (?, ?)")) {
+                ps.setString(1, route);
+                ps.setString(2, ip);
+                ps.executeUpdate();
+            }
+
+        } catch (SQLException _) {
+            //
+        }
+    }
+}

src/main/java/com/unfamoussoul/test/web/route/RemindersRoute.java

@@ -2,7 +2,6 @@
 
 import com.unfamoussoul.test.Test;
 import io.javalin.http.Context;
-import org.bukkit.Bukkit;
 import org.bukkit.OfflinePlayer;
 import org.jetbrains.annotations.NotNull;
 
@@ -27,6 +26,7 @@ public void getAll(@NotNull Context ctx) {
         payload.put("count", phrases.size());
         payload.put("data", phrases);
 
+        module.getDatabaseHandler().addLog("/reminders", ctx.ip());
         ctx.json(payload);
     }
 
@@ -41,11 +41,12 @@ public void getByNickname(@NotNull Context ctx) {
         payload.put("count", phrases.size());
         payload.put("data", phrases);
 
+        module.getDatabaseHandler().addLog("/reminders/" + nickname, ctx.ip());
         ctx.json(payload);
     }
 
     private @NotNull UUID resolveUuid(String nickname) {
-        OfflinePlayer player = Bukkit.getOfflinePlayer(nickname);
+        OfflinePlayer player = module.getPlugin().getServer().getOfflinePlayer(nickname);
         return player.getUniqueId();
     }
 }

src/main/java/com/unfamoussoul/test/web/route/ServerRoute.java

@@ -29,6 +29,7 @@ public void getOnline(Context ctx) {
         payload.put("max", module.getPlugin().getServer().getMaxPlayers());
         payload.put("names", names);
 
+        module.getDatabaseHandler().addLog("/server/online", ctx.ip());
         ctx.json(payload);
     }
 }

src/main/resources/config.yml

@@ -8,4 +8,7 @@ web:
     max: 10
     queued: 100
     idle: 60
-    evict: 120
+    evict: 120
+
+database:
+  jdbc: "jdbc:sqlite:data.db"

src/main/resources/locale/messages_en_US.json

@@ -6,4 +6,5 @@
   "test.remember.success": "Remembered <0> symbols!"
   "test.remember.success": "Remembered <0> symbols!",
   "test.command.textapi_not_loaded": "TextAPI is not loaded!",
+  "test.database.error": "SQL error: <0>"
 }

src/main/resources/locale/messages_ru_RU.json

@@ -6,4 +6,5 @@
   "test.remember.success": "Запомнил <0> символов!"
   "test.remember.success": "Запомнил <0> символов!",
   "test.command.textapi_not_loaded": "TextAPI не загружен!",
+  "test.database.error": "Ошибка SQL: <0>"
 }