package com.lifesteal.database; import com.lifesteal.LifestealPlugin; import com.lifesteal.data.*; import com.zaxxer.hikari.HikariConfig; import com.zaxxer.hikari.HikariDataSource; import org.bukkit.Bukkit; import org.bukkit.Location; import java.sql.*; import java.util.ArrayList; import java.util.List; import java.util.UUID; public class DatabaseManager { private final LifestealPlugin plugin; private HikariDataSource dataSource; public DatabaseManager(LifestealPlugin plugin) { this.plugin = plugin; } public void connect() { HikariConfig config = new HikariConfig(); String type = plugin.getConfig().getString("database.type", "SQLITE"); if (type.equalsIgnoreCase("MYSQL")) { String host = plugin.getConfig().getString("database.mysql.host", "localhost"); int port = plugin.getConfig().getInt("database.mysql.port", 3306); String database = plugin.getConfig().getString("database.mysql.database", "lifesteal"); String username = plugin.getConfig().getString("database.mysql.username", "root"); String password = plugin.getConfig().getString("database.mysql.password", ""); config.setJdbcUrl("jdbc:mysql://" + host + ":" + port + "/" + database); config.setUsername(username); config.setPassword(password); config.addDataSourceProperty("useSSL", plugin.getConfig().getBoolean("database.mysql.properties.useSSL", false)); config.addDataSourceProperty("autoReconnect", plugin.getConfig().getBoolean("database.mysql.properties.autoReconnect", true)); } else { config.setJdbcUrl("jdbc:sqlite:" + plugin.getDataFolder() + "/data.db"); config.setDriverClassName("org.sqlite.JDBC"); } config.setMaximumPoolSize(10); config.setMinimumIdle(2); config.setConnectionTimeout(30000); config.setIdleTimeout(600000); config.setMaxLifetime(1800000); dataSource = new HikariDataSource(config); createTables(); } public void disconnect() { if (dataSource != null && !dataSource.isClosed()) { dataSource.close(); } } private void createTables() { try (Connection conn = getConnection()) { conn.createStatement().execute( "CREATE TABLE IF NOT EXISTS player_data (" + "uuid VARCHAR(36) PRIMARY KEY," + "name VARCHAR(16)," + "hearts INT," + "balance DOUBLE," + "last_updated BIGINT," + "kills INT," + "deaths INT)" ); conn.createStatement().execute( "CREATE TABLE IF NOT EXISTS homes (" + "uuid VARCHAR(36)," + "name VARCHAR(32)," + "world VARCHAR(64)," + "x DOUBLE," + "y DOUBLE," + "z DOUBLE," + "yaw FLOAT," + "pitch FLOAT," + "PRIMARY KEY (uuid, name))" ); conn.createStatement().execute( "CREATE TABLE IF NOT EXISTS auction_listings (" + "id INTEGER PRIMARY KEY " + (plugin.getConfig().getString("database.type", "SQLITE").equalsIgnoreCase("MYSQL") ? "AUTO_INCREMENT" : "AUTOINCREMENT") + "," + "seller_uuid VARCHAR(36)," + "seller_name VARCHAR(16)," + "item_data TEXT," + "price DOUBLE," + "created_at BIGINT," + "expires_at BIGINT)" ); conn.createStatement().execute( "CREATE TABLE IF NOT EXISTS clans (" + "name VARCHAR(32) PRIMARY KEY," + "owner VARCHAR(36)," + "members TEXT," + "invites TEXT," + "friendly_fire BOOLEAN," + "created_at BIGINT)" ); conn.createStatement().execute( "CREATE TABLE IF NOT EXISTS warps (" + "name VARCHAR(32) PRIMARY KEY," + "owner VARCHAR(36)," + "owner_name VARCHAR(16)," + "world VARCHAR(64)," + "x DOUBLE," + "y DOUBLE," + "z DOUBLE," + "yaw FLOAT," + "pitch FLOAT," + "is_public BOOLEAN)" ); conn.createStatement().execute( "CREATE TABLE IF NOT EXISTS regions (" + "name VARCHAR(32) PRIMARY KEY," + "owner VARCHAR(36)," + "world VARCHAR(64)," + "min_x INT," + "min_y INT," + "min_z INT," + "max_x INT," + "max_y INT," + "max_z INT," + "members TEXT," + "build BOOLEAN," + "break_block BOOLEAN," + "pvp BOOLEAN)" ); conn.createStatement().execute( "CREATE TABLE IF NOT EXISTS block_logs (" + "id INTEGER PRIMARY KEY " + (plugin.getConfig().getString("database.type", "SQLITE").equalsIgnoreCase("MYSQL") ? "AUTO_INCREMENT" : "AUTOINCREMENT") + "," + "player_uuid VARCHAR(36)," + "player_name VARCHAR(16)," + "action VARCHAR(10)," + "material VARCHAR(64)," + "world VARCHAR(64)," + "x INT," + "y INT," + "z INT," + "timestamp BIGINT)" ); conn.createStatement().execute( "CREATE TABLE IF NOT EXISTS auth (" + "uuid VARCHAR(36) PRIMARY KEY," + "password VARCHAR(64))" ); } catch (SQLException e) { plugin.getLogger().severe("Failed to create tables: " + e.getMessage()); e.printStackTrace(); } } public Connection getConnection() throws SQLException { return dataSource.getConnection(); } public PlayerData getPlayerData(UUID uuid) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("SELECT * FROM player_data WHERE uuid = ?")) { ps.setString(1, uuid.toString()); ResultSet rs = ps.executeQuery(); if (rs.next()) { return new PlayerData( UUID.fromString(rs.getString("uuid")), rs.getString("name"), rs.getInt("hearts"), rs.getDouble("balance"), rs.getLong("last_updated"), rs.getInt("kills"), rs.getInt("deaths") ); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load player data: " + e.getMessage()); } return null; } public void savePlayerData(PlayerData data) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "INSERT OR REPLACE INTO player_data (uuid, name, hearts, balance, last_updated, kills, deaths) " + "VALUES (?, ?, ?, ?, ?, ?, ?) " + "ON DUPLICATE KEY UPDATE name=?, hearts=?, balance=?, last_updated=?, kills=?, deaths=?")) { ps.setString(1, data.getUuid().toString()); ps.setString(2, data.getName()); ps.setInt(3, data.getHearts()); ps.setDouble(4, data.getBalance()); ps.setLong(5, System.currentTimeMillis()); ps.setInt(6, data.getKills()); ps.setInt(7, data.getDeaths()); ps.setString(8, data.getName()); ps.setInt(9, data.getHearts()); ps.setDouble(10, data.getBalance()); ps.setLong(11, System.currentTimeMillis()); ps.setInt(12, data.getKills()); ps.setInt(13, data.getDeaths()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to save player data: " + e.getMessage()); } } public List getHomes(UUID uuid) { List homes = new ArrayList<>(); try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("SELECT * FROM homes WHERE uuid = ?")) { ps.setString(1, uuid.toString()); ResultSet rs = ps.executeQuery(); while (rs.next()) { homes.add(new HomeData( UUID.fromString(rs.getString("uuid")), rs.getString("name"), rs.getString("world"), rs.getDouble("x"), rs.getDouble("y"), rs.getDouble("z"), rs.getFloat("yaw"), rs.getFloat("pitch") )); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load homes: " + e.getMessage()); } return homes; } public void saveHome(HomeData home) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "INSERT OR REPLACE INTO homes (uuid, name, world, x, y, z, yaw, pitch) VALUES (?, ?, ?, ?, ?, ?, ?, ?) " + "ON DUPLICATE KEY UPDATE world=?, x=?, y=?, z=?, yaw=?, pitch=?")) { ps.setString(1, home.getUuid().toString()); ps.setString(2, home.getName()); ps.setString(3, home.getWorld()); ps.setDouble(4, home.getX()); ps.setDouble(5, home.getY()); ps.setDouble(6, home.getZ()); ps.setFloat(7, home.getYaw()); ps.setFloat(8, home.getPitch()); ps.setString(9, home.getWorld()); ps.setDouble(10, home.getX()); ps.setDouble(11, home.getY()); ps.setDouble(12, home.getZ()); ps.setFloat(13, home.getYaw()); ps.setFloat(14, home.getPitch()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to save home: " + e.getMessage()); } } public void deleteHome(UUID uuid, String name) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("DELETE FROM homes WHERE uuid = ? AND name = ?")) { ps.setString(1, uuid.toString()); ps.setString(2, name); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to delete home: " + e.getMessage()); } } public List getAuctionListings() { List listings = new ArrayList<>(); try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("SELECT * FROM auction_listings")) { ResultSet rs = ps.executeQuery(); while (rs.next()) { listings.add(new AuctionListing( rs.getInt("id"), UUID.fromString(rs.getString("seller_uuid")), rs.getString("seller_name"), null, rs.getDouble("price"), rs.getLong("created_at"), rs.getLong("expires_at") )); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load auction listings: " + e.getMessage()); } return listings; } public void saveAuctionListing(AuctionListing listing) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "INSERT INTO auction_listings (seller_uuid, seller_name, item_data, price, created_at, expires_at) VALUES (?, ?, ?, ?, ?, ?)")) { ps.setString(1, listing.getSellerUuid().toString()); ps.setString(2, listing.getSellerName()); ps.setString(3, ""); ps.setDouble(4, listing.getPrice()); ps.setLong(5, listing.getCreatedAt()); ps.setLong(6, listing.getExpiresAt()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to save auction listing: " + e.getMessage()); } } public void deleteAuctionListing(int id) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("DELETE FROM auction_listings WHERE id = ?")) { ps.setInt(1, id); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to delete auction listing: " + e.getMessage()); } } public List getClans() { List clans = new ArrayList<>(); try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("SELECT * FROM clans")) { ResultSet rs = ps.executeQuery(); while (rs.next()) { clans.add(new Clan( rs.getString("name"), UUID.fromString(rs.getString("owner")), parseUUIDList(rs.getString("invites")), parseUUIDList(rs.getString("members")), rs.getBoolean("friendly_fire"), rs.getLong("created_at") )); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load clans: " + e.getMessage()); } return clans; } public void saveClan(Clan clan) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "INSERT OR REPLACE INTO clans (name, owner, members, invites, friendly_fire, created_at) VALUES (?, ?, ?, ?, ?, ?) " + "ON DUPLICATE KEY UPDATE owner=?, members=?, invites=?, friendly_fire=?, created_at=?")) { ps.setString(1, clan.getName()); ps.setString(2, clan.getOwner().toString()); ps.setString(3, serializeUUIDList(clan.getMembers())); ps.setString(4, serializeUUIDList(clan.getInvites())); ps.setBoolean(5, clan.isFriendlyFire()); ps.setLong(6, clan.getCreatedAt()); ps.setString(7, clan.getOwner().toString()); ps.setString(8, serializeUUIDList(clan.getMembers())); ps.setString(9, serializeUUIDList(clan.getInvites())); ps.setBoolean(10, clan.isFriendlyFire()); ps.setLong(11, clan.getCreatedAt()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to save clan: " + e.getMessage()); } } public void deleteClan(String name) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("DELETE FROM clans WHERE name = ?")) { ps.setString(1, name); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to delete clan: " + e.getMessage()); } } public List getWarps() { List warps = new ArrayList<>(); try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("SELECT * FROM warps")) { ResultSet rs = ps.executeQuery(); while (rs.next()) { warps.add(new WarpData( rs.getString("name"), UUID.fromString(rs.getString("owner")), rs.getString("owner_name"), rs.getString("world"), rs.getDouble("x"), rs.getDouble("y"), rs.getDouble("z"), rs.getFloat("yaw"), rs.getFloat("pitch"), rs.getBoolean("is_public") )); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load warps: " + e.getMessage()); } return warps; } public void saveWarp(WarpData warp) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "INSERT OR REPLACE INTO warps (name, owner, owner_name, world, x, y, z, yaw, pitch, is_public) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?) " + "ON DUPLICATE KEY UPDATE owner=?, owner_name=?, world=?, x=?, y=?, z=?, yaw=?, pitch=?, is_public=?")) { ps.setString(1, warp.getName()); ps.setString(2, warp.getOwner().toString()); ps.setString(3, warp.getOwnerName()); ps.setString(4, warp.getWorld()); ps.setDouble(5, warp.getX()); ps.setDouble(6, warp.getY()); ps.setDouble(7, warp.getZ()); ps.setFloat(8, warp.getYaw()); ps.setFloat(9, warp.getPitch()); ps.setBoolean(10, warp.isPublic()); ps.setString(11, warp.getOwner().toString()); ps.setString(12, warp.getOwnerName()); ps.setString(13, warp.getWorld()); ps.setDouble(14, warp.getX()); ps.setDouble(15, warp.getY()); ps.setDouble(16, warp.getZ()); ps.setFloat(17, warp.getYaw()); ps.setFloat(18, warp.getPitch()); ps.setBoolean(19, warp.isPublic()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to save warp: " + e.getMessage()); } } public void deleteWarp(String name) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("DELETE FROM warps WHERE name = ?")) { ps.setString(1, name); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to delete warp: " + e.getMessage()); } } public List getRegions() { List regions = new ArrayList<>(); try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("SELECT * FROM regions")) { ResultSet rs = ps.executeQuery(); while (rs.next()) { regions.add(new Region( rs.getString("name"), UUID.fromString(rs.getString("owner")), rs.getString("world"), rs.getInt("min_x"), rs.getInt("min_y"), rs.getInt("min_z"), rs.getInt("max_x"), rs.getInt("max_y"), rs.getInt("max_z"), parseUUIDList(rs.getString("members")), rs.getBoolean("build"), rs.getBoolean("break_block"), rs.getBoolean("pvp"), true )); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load regions: " + e.getMessage()); } return regions; } public void saveRegion(Region region) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "INSERT OR REPLACE INTO regions (name, owner, world, min_x, min_y, min_z, max_x, max_y, max_z, members, build, break_block, pvp) " + "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) " + "ON DUPLICATE KEY UPDATE owner=?, world=?, min_x=?, min_y=?, min_z=?, max_x=?, max_y=?, max_z=?, members=?, build=?, break_block=?, pvp=?")) { ps.setString(1, region.getName()); ps.setString(2, region.getOwner().toString()); ps.setString(3, region.getWorld()); ps.setInt(4, region.getMinX()); ps.setInt(5, region.getMinY()); ps.setInt(6, region.getMinZ()); ps.setInt(7, region.getMaxX()); ps.setInt(8, region.getMaxY()); ps.setInt(9, region.getMaxZ()); ps.setString(10, serializeUUIDList(region.getMembers())); ps.setBoolean(11, region.isBuild()); ps.setBoolean(12, region.isBreakBlock()); ps.setBoolean(13, region.isPvp()); ps.setString(14, region.getOwner().toString()); ps.setString(15, region.getWorld()); ps.setInt(16, region.getMinX()); ps.setInt(17, region.getMinY()); ps.setInt(18, region.getMinZ()); ps.setInt(19, region.getMaxX()); ps.setInt(20, region.getMaxY()); ps.setInt(21, region.getMaxZ()); ps.setString(22, serializeUUIDList(region.getMembers())); ps.setBoolean(23, region.isBuild()); ps.setBoolean(24, region.isBreakBlock()); ps.setBoolean(25, region.isPvp()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to save region: " + e.getMessage()); } } public void deleteRegion(String name) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("DELETE FROM regions WHERE name = ?")) { ps.setString(1, name); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to delete region: " + e.getMessage()); } } public void saveBlockLog(BlockLog log) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "INSERT INTO block_logs (player_uuid, player_name, action, material, world, x, y, z, timestamp) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)")) { ps.setString(1, log.getPlayerUuid().toString()); ps.setString(2, log.getPlayerName()); ps.setString(3, log.getAction()); ps.setString(4, log.getMaterial()); ps.setString(5, log.getWorld()); ps.setInt(6, log.getX()); ps.setInt(7, log.getY()); ps.setInt(8, log.getZ()); ps.setLong(9, log.getTimestamp()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to save block log: " + e.getMessage()); } } public List getBlockLogs(String playerName, long since) { List logs = new ArrayList<>(); try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "SELECT * FROM block_logs WHERE player_name = ? AND timestamp >= ? ORDER BY timestamp DESC")) { ps.setString(1, playerName); ps.setLong(2, System.currentTimeMillis() - (since * 1000)); ResultSet rs = ps.executeQuery(); while (rs.next()) { logs.add(new BlockLog( rs.getInt("id"), UUID.fromString(rs.getString("player_uuid")), rs.getString("player_name"), rs.getString("action"), rs.getString("material"), rs.getString("world"), rs.getInt("x"), rs.getInt("y"), rs.getInt("z"), rs.getLong("timestamp") )); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load block logs: " + e.getMessage()); } return logs; } public List getBlockLogsAt(String world, int x, int y, int z) { List logs = new ArrayList<>(); try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "SELECT * FROM block_logs WHERE world = ? AND x = ? AND y = ? AND z = ? ORDER BY timestamp DESC LIMIT 10")) { ps.setString(1, world); ps.setInt(2, x); ps.setInt(3, y); ps.setInt(4, z); ResultSet rs = ps.executeQuery(); while (rs.next()) { logs.add(new BlockLog( rs.getInt("id"), UUID.fromString(rs.getString("player_uuid")), rs.getString("player_name"), rs.getString("action"), rs.getString("material"), rs.getString("world"), rs.getInt("x"), rs.getInt("y"), rs.getInt("z"), rs.getLong("timestamp") )); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load block logs at location: " + e.getMessage()); } return logs; } public void savePassword(UUID uuid, String password) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement( "INSERT OR REPLACE INTO auth (uuid, password) VALUES (?, ?) ON DUPLICATE KEY UPDATE password=?")) { ps.setString(1, uuid.toString()); ps.setString(2, password); ps.setString(3, password); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().severe("Failed to save password: " + e.getMessage()); } } public String getPassword(UUID uuid) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement("SELECT password FROM auth WHERE uuid = ?")) { ps.setString(1, uuid.toString()); ResultSet rs = ps.executeQuery(); if (rs.next()) { return rs.getString("password"); } } catch (SQLException e) { plugin.getLogger().severe("Failed to load password: " + e.getMessage()); } return null; } public boolean isRegistered(UUID uuid) { return getPassword(uuid) != null; } private List parseUUIDList(String data) { List list = new ArrayList<>(); if (data == null || data.isEmpty()) return list; for (String part : data.split(",")) { try { list.add(UUID.fromString(part.trim())); } catch (IllegalArgumentException ignored) {} } return list; } private String serializeUUIDList(List list) { if (list == null || list.isEmpty()) return ""; return String.join(",", list.stream().map(UUID::toString).toArray(String[]::new)); } }