Minecraft/EpicSpawners
1
0
Fork 0
mirror of https://github.com/craftaro/EpicSpawners.git synced 2025-01-07 03:07:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix MySQL support

Browse Source
This commit is contained in:
ceze88 2024-04-24 15:08:44 +02:00
parent 8937aab91a
commit 0365caf5d1
2 changed files with 26 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
EpicSpawners-Plugin/src/main/java/com/craftaro/epicspawners/database/migrations/_2_AddTiers.java
View File

@ -14,7 +14,9 @@ public class _2_AddTiers extends DataMigration {
@Override
public void migrate(Connection connection, String tablePrefix) throws SQLException {
try (Statement statement = connection.createStatement()) {
statement.execute("ALTER TABLE " + tablePrefix + "spawner_stacks ADD COLUMN IF NOT EXISTS tier VARCHAR(100) DEFAULT 'Tier_1' NOT NULL");
statement.execute("ALTER TABLE " + tablePrefix + "spawner_stacks ADD COLUMN tier VARCHAR(100) DEFAULT 'Tier_1' NOT NULL");
} catch (Exception ignored) {
//Column already exists
}
}
}

24
EpicSpawners-Plugin/src/main/java/com/craftaro/epicspawners/database/migrations/_3_AddUniqueIndex.java
View File

@ -18,16 +18,38 @@ public class _3_AddUniqueIndex extends DataMigration {
//Delete duplicate entries from previous versions
try (Statement statement = connection.createStatement()) {
//Delete duplicate data before adding unique index
//MariaDB and H2
statement.execute("DELETE FROM " + tablePrefix + "entity_kills WHERE count < (SELECT MAX(count) FROM " + tablePrefix + "entity_kills AS t2 WHERE t2.player = " + tablePrefix + "entity_kills.player AND t2.entity_type = " + tablePrefix + "entity_kills.entity_type)");
} catch (Exception e) {
//MySQL
try (PreparedStatement statement = connection.prepareStatement("CREATE TEMPORARY TABLE temp_table AS SELECT player, entity_type, MAX(count) as max_count FROM " + tablePrefix + "entity_kills GROUP BY player, entity_type")) {
statement.execute();
} catch (Exception ignored) {
//Table already exists
}
try (PreparedStatement statement = connection.prepareStatement("DELETE e FROM " + tablePrefix + "entity_kills e INNER JOIN temp_table t ON e.player = t.player AND e.entity_type = t.entity_type WHERE e.count < t.max_count")) {
statement.execute();
} catch (Exception ignored) {
//Table already exists
}
try (PreparedStatement statement = connection.prepareStatement("DROP TEMPORARY TABLE temp_table")) {
statement.execute();
} catch (Exception ignored) {
//Table already exists
}
}
try (Statement statement = connection.createStatement()) {
//MySQL and MariaDB
statement.execute("ALTER TABLE " + tablePrefix + "entity_kills ADD UNIQUE INDEX IF NOT EXISTS player_uuid_entity_type (player, entity_type)");
statement.execute("ALTER TABLE " + tablePrefix + "entity_kills ADD UNIQUE INDEX player_uuid_entity_type (player, entity_type)");
} catch (Exception ignored) {
//H2
try (Statement statement = connection.createStatement()) {
statement.execute("ALTER TABLE " + tablePrefix + "entity_kills ADD CONSTRAINT IF NOT EXISTS player_uuid_entity_type UNIQUE (player, entity_type)");
} catch (Exception ignored2) {
//Index already exists in the MySQL or MariaDB
}
}
}