summaryrefslogtreewikicommitdiff
path: root/src/main/java/dev/tylerm/khs/database/Database.java
diff options
context:
space:
mode:
authorFreya Murphy <freya@freyacat.org>2025-09-06 23:11:25 -0400
committerFreya Murphy <freya@freyacat.org>2025-09-06 23:11:25 -0400
commit67aba9081bb73aeaa822b059e8ca6defc8352a2f (patch)
treecba7c5c8c9a0286b491b0b0784a27730ce58696e /src/main/java/dev/tylerm/khs/database/Database.java
parentadd wiki for cgit (diff)
downloadkenshinshideandseek-67aba9081bb73aeaa822b059e8ca6defc8352a2f.tar.gz
kenshinshideandseek-67aba9081bb73aeaa822b059e8ca6defc8352a2f.tar.bz2
kenshinshideandseek-67aba9081bb73aeaa822b059e8ca6defc8352a2f.zip
rename pacakges dev.tylerm -> cat.freya
Diffstat (limited to 'src/main/java/dev/tylerm/khs/database/Database.java')
-rw-r--r--src/main/java/dev/tylerm/khs/database/Database.java107
1 files changed, 0 insertions, 107 deletions
diff --git a/src/main/java/dev/tylerm/khs/database/Database.java b/src/main/java/dev/tylerm/khs/database/Database.java
deleted file mode 100644
index 42c4798..0000000
--- a/src/main/java/dev/tylerm/khs/database/Database.java
+++ /dev/null
@@ -1,107 +0,0 @@
-package dev.tylerm.khs.database;
-
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.nio.Buffer;
-import java.nio.ByteBuffer;
-import java.sql.Connection;
-import java.sql.SQLException;
-import java.util.UUID;
-
-import com.google.common.io.ByteStreams;
-
-import dev.tylerm.khs.Main;
-import dev.tylerm.khs.configuration.Config;
-import dev.tylerm.khs.database.connections.DatabaseConnection;
-import dev.tylerm.khs.database.connections.MySQLConnection;
-import dev.tylerm.khs.database.connections.SQLiteConnection;
-
-public class Database {
-
- private final GameDataTable playerInfo;
- private final NameDataTable nameInfo;
- private final InventoryTable inventoryInfo;
- private final DatabaseConnection connection;
-
- public Database(){
-
- if(Config.databaseType.equalsIgnoreCase("SQLITE")) {
- Main.getInstance().getLogger().info("SQLITE database chosen");
- connection = new SQLiteConnection();
- } else if(Config.databaseType.equalsIgnoreCase("MYSQL")) {
- Main.getInstance().getLogger().info("MYSQL database chosen");
- connection = new MySQLConnection();
- } else {
- throw new IllegalArgumentException("Invalid database type: " + Config.databaseType);
- }
-
- playerInfo = new GameDataTable(this);
-
- nameInfo = new NameDataTable(this);
-
- inventoryInfo = new InventoryTable(this);
-
- LegacyTable legacyTable = new LegacyTable(this);
- if(legacyTable.exists()){
- if(legacyTable.copyData()){
- if(!legacyTable.drop()){
- Main.getInstance().getLogger().severe("Failed to drop old legacy table: player_info. Some data may be duplicated!");
- }
- }
- }
- }
-
- public GameDataTable getGameData(){
- return playerInfo;
- }
-
- public NameDataTable getNameData() { return nameInfo; }
-
- public InventoryTable getInventoryData() { return inventoryInfo; }
-
- protected Connection connect() {
- Connection conn = null;
- try {
- conn = connection.connect();
- } catch (SQLException e) {
- Main.getInstance().getLogger().severe(e.getMessage());
- e.printStackTrace();
- }
- return conn;
- }
-
- protected byte[] encodeUUID(UUID uuid) {
- try {
- byte[] bytes = new byte[16];
- ByteBuffer.wrap(bytes)
- .putLong(uuid.getMostSignificantBits())
- .putLong(uuid.getLeastSignificantBits());
- InputStream is = new ByteArrayInputStream(bytes);
- byte[] result = new byte[is.available()];
- if (is.read(result) == -1) {
- Main.getInstance().getLogger().severe("IO Error: Failed to read bytes from input stream");
- return new byte[0];
- }
- return result;
- } catch (IOException e) {
- Main.getInstance().getLogger().severe("IO Error: " + e.getMessage());
- return new byte[0];
- }
- }
-
- @SuppressWarnings("UnstableApiUsage")
- protected UUID decodeUUID(byte[] bytes) {
- InputStream is = new ByteArrayInputStream(bytes);
- ByteBuffer buffer = ByteBuffer.allocate(16);
- try {
- buffer.put(ByteStreams.toByteArray(is));
- ((Buffer)buffer).flip();
- return new UUID(buffer.getLong(), buffer.getLong());
- } catch (IOException e) {
- Main.getInstance().getLogger().severe("IO Error: " + e.getMessage());
- }
- return null;
- }
-
-}