package com.kodari.economy.database; import com.kodari.economy.KodariEconomy; import com.kodari.economy.model.*; import com.kodari.economy.util.ItemSerializer; import com.zaxxer.hikari.HikariConfig; import com.zaxxer.hikari.HikariDataSource; import org.bukkit.inventory.ItemStack; import java.io.File; import java.sql.*; import java.util.*; import java.util.logging.Level; public class DatabaseManager { private final KodariEconomy plugin; private HikariDataSource dataSource; private final boolean isMySQL; public DatabaseManager(KodariEconomy plugin) { this.plugin = plugin; this.isMySQL = plugin.getConfigManager().getDatabaseType().equalsIgnoreCase("mysql"); } public void initialize() { HikariConfig config = new HikariConfig(); if (isMySQL) { String host = plugin.getConfigManager().getDatabaseHost(); int port = plugin.getConfigManager().getDatabasePort(); String db = plugin.getConfigManager().getDatabaseName(); config.setJdbcUrl("jdbc:mysql://" + host + ":" + port + "/" + db + "?useSSL=false&autoReconnect=true&characterEncoding=utf8"); config.setUsername(plugin.getConfigManager().getDatabaseUser()); config.setPassword(plugin.getConfigManager().getDatabasePassword()); config.setMaximumPoolSize(10); config.setMinimumIdle(2); } else { plugin.getDataFolder().mkdirs(); File dbFile = new File(plugin.getDataFolder(), "economy.db"); config.setJdbcUrl("jdbc:sqlite:" + dbFile.getAbsolutePath()); config.setDriverClassName("org.sqlite.JDBC"); config.setMaximumPoolSize(2); config.addDataSourceProperty("journal_mode", "WAL"); config.addDataSourceProperty("synchronous", "NORMAL"); } config.setPoolName("KodariEconomy-Pool"); config.setConnectionTimeout(30000); config.setIdleTimeout(600000); config.setMaxLifetime(1800000); dataSource = new HikariDataSource(config); createTables(); } public void close() { if (dataSource != null && !dataSource.isClosed()) { dataSource.close(); } } private Connection getConnection() throws SQLException { return dataSource.getConnection(); } private void createTables() { try (Connection conn = getConnection(); Statement stmt = conn.createStatement()) { stmt.executeUpdate( "CREATE TABLE IF NOT EXISTS player_data (" + "uuid VARCHAR(36) NOT NULL PRIMARY KEY," + "name VARCHAR(16) NOT NULL," + "balance DOUBLE NOT NULL DEFAULT 0," + "daily_earned DOUBLE NOT NULL DEFAULT 0," + "daily_spent DOUBLE NOT NULL DEFAULT 0," + "last_daily BIGINT NOT NULL DEFAULT 0," + "daily_streak INT NOT NULL DEFAULT 0," + "last_login BIGINT NOT NULL DEFAULT 0," + "daily_reset_time BIGINT NOT NULL DEFAULT 0)" ); stmt.executeUpdate( "CREATE TABLE IF NOT EXISTS auction_listings (" + "id VARCHAR(36) NOT NULL PRIMARY KEY," + "seller_uuid VARCHAR(36) NOT NULL," + "seller_name VARCHAR(16) NOT NULL," + "item_data TEXT NOT NULL," + "price DOUBLE NOT NULL," + "created_at BIGINT NOT NULL," + "expires_at BIGINT NOT NULL," + "views INT NOT NULL DEFAULT 0," + "expired INTEGER NOT NULL DEFAULT 0," + "sold INTEGER NOT NULL DEFAULT 0)" ); stmt.executeUpdate( "CREATE TABLE IF NOT EXISTS market_orders (" + "id VARCHAR(36) NOT NULL PRIMARY KEY," + "player_uuid VARCHAR(36) NOT NULL," + "player_name VARCHAR(16) NOT NULL," + "order_type VARCHAR(4) NOT NULL," + "item_key VARCHAR(64) NOT NULL," + "item_data TEXT," + "quantity INT NOT NULL," + "filled_quantity INT NOT NULL DEFAULT 0," + "price_each DOUBLE NOT NULL," + "locked_coins DOUBLE NOT NULL DEFAULT 0," + "created_at BIGINT NOT NULL," + "cancelled INTEGER NOT NULL DEFAULT 0)" ); stmt.executeUpdate( "CREATE TABLE IF NOT EXISTS transactions (" + "id VARCHAR(36) NOT NULL PRIMARY KEY," + "player_uuid VARCHAR(36) NOT NULL," + "player_name VARCHAR(16) NOT NULL," + "type VARCHAR(32) NOT NULL," + "amount DOUBLE NOT NULL," + "balance_after DOUBLE NOT NULL," + "description TEXT NOT NULL," + "timestamp BIGINT NOT NULL)" ); stmt.executeUpdate( "CREATE TABLE IF NOT EXISTS shop_items (" + "id VARCHAR(36) NOT NULL PRIMARY KEY," + "owner_uuid VARCHAR(36) NOT NULL," + "owner_name VARCHAR(16) NOT NULL," + "item_data TEXT NOT NULL," + "price DOUBLE NOT NULL," + "stock INT NOT NULL," + "listed_at BIGINT NOT NULL)" ); stmt.executeUpdate( "CREATE TABLE IF NOT EXISTS warehouse_items (" + "id VARCHAR(36) NOT NULL PRIMARY KEY," + "player_uuid VARCHAR(36) NOT NULL," + "item_data TEXT NOT NULL," + "quantity INT NOT NULL," + "deposited_at BIGINT NOT NULL)" ); stmt.executeUpdate( "CREATE TABLE IF NOT EXISTS notifications (" + "id VARCHAR(36) NOT NULL PRIMARY KEY," + "player_uuid VARCHAR(36) NOT NULL," + "message TEXT NOT NULL," + "timestamp BIGINT NOT NULL)" ); // Indexes for performance executeIgnoreError(stmt, "CREATE INDEX IF NOT EXISTS idx_auction_seller ON auction_listings(seller_uuid)"); executeIgnoreError(stmt, "CREATE INDEX IF NOT EXISTS idx_market_player ON market_orders(player_uuid)"); executeIgnoreError(stmt, "CREATE INDEX IF NOT EXISTS idx_market_item ON market_orders(item_key)"); executeIgnoreError(stmt, "CREATE INDEX IF NOT EXISTS idx_tx_player ON transactions(player_uuid)"); executeIgnoreError(stmt, "CREATE INDEX IF NOT EXISTS idx_shop_owner ON shop_items(owner_uuid)"); executeIgnoreError(stmt, "CREATE INDEX IF NOT EXISTS idx_warehouse_player ON warehouse_items(player_uuid)"); executeIgnoreError(stmt, "CREATE INDEX IF NOT EXISTS idx_notif_player ON notifications(player_uuid)"); } catch (SQLException e) { plugin.getLogger().log(Level.SEVERE, "Failed to create database tables", e); } } private void executeIgnoreError(Statement stmt, String sql) { try { stmt.executeUpdate(sql); } catch (SQLException ignored) {} } // ===== Player Data ===== public PlayerData getPlayerData(UUID uuid) { String sql = "SELECT * FROM player_data WHERE uuid = ?"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, uuid.toString()); ResultSet rs = ps.executeQuery(); if (rs.next()) { return mapPlayerData(rs); } } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to get player data", e); } return null; } public void savePlayerData(PlayerData data) { String sql = isMySQL ? "INSERT INTO player_data (uuid,name,balance,daily_earned,daily_spent,last_daily,daily_streak,last_login,daily_reset_time) " + "VALUES (?,?,?,?,?,?,?,?,?) ON DUPLICATE KEY UPDATE name=VALUES(name),balance=VALUES(balance)," + "daily_earned=VALUES(daily_earned),daily_spent=VALUES(daily_spent),last_daily=VALUES(last_daily)," + "daily_streak=VALUES(daily_streak),last_login=VALUES(last_login),daily_reset_time=VALUES(daily_reset_time)" : "INSERT OR REPLACE INTO player_data (uuid,name,balance,daily_earned,daily_spent,last_daily,daily_streak,last_login,daily_reset_time) " + "VALUES (?,?,?,?,?,?,?,?,?)"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, data.getUuid().toString()); ps.setString(2, data.getName()); ps.setDouble(3, data.getBalance()); ps.setDouble(4, data.getDailyEarned()); ps.setDouble(5, data.getDailySpent()); ps.setLong(6, data.getLastDaily()); ps.setInt(7, data.getDailyStreak()); ps.setLong(8, data.getLastLogin()); ps.setLong(9, data.getDailyResetTime()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to save player data", e); } } public List> getTopBalances(int limit) { List> result = new ArrayList<>(); String sql = "SELECT name, balance FROM player_data ORDER BY balance DESC LIMIT ?"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setInt(1, limit); ResultSet rs = ps.executeQuery(); while (rs.next()) { result.add(new AbstractMap.SimpleEntry<>(rs.getString("name"), rs.getDouble("balance"))); } } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to get top balances", e); } return result; } private PlayerData mapPlayerData(ResultSet rs) throws SQLException { return new PlayerData( UUID.fromString(rs.getString("uuid")), rs.getString("name"), rs.getDouble("balance"), rs.getDouble("daily_earned"), rs.getDouble("daily_spent"), rs.getLong("last_daily"), rs.getInt("daily_streak"), rs.getLong("last_login"), rs.getLong("daily_reset_time") ); } // ===== Auction Listings ===== public List getActiveAuctionListings() { return getAuctionListings("WHERE expired=0 AND sold=0 AND expires_at > ?", System.currentTimeMillis()); } public List getExpiredListingsForPlayer(UUID playerUuid) { List all = getAuctionListings( "WHERE seller_uuid=? AND expired=1 AND sold=0", playerUuid.toString()); // Also listings whose time expired but weren't flagged yet long now = System.currentTimeMillis(); List timePassed = getAuctionListings( "WHERE seller_uuid=? AND expired=0 AND sold=0 AND expires_at <= ?", playerUuid.toString(), now); all.addAll(timePassed); return all; } public List getAllNonExpiredListings() { return getAuctionListings("WHERE expired=0 AND sold=0", (Object[]) null); } private List getAuctionListings(String where, Object... params) { List list = new ArrayList<>(); String sql = "SELECT * FROM auction_listings " + where; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { if (params != null) { for (int i = 0; i < params.length; i++) { if (params[i] instanceof Long) ps.setLong(i + 1, (Long) params[i]); else if (params[i] instanceof String) ps.setString(i + 1, (String) params[i]); } } ResultSet rs = ps.executeQuery(); while (rs.next()) { AuctionListing listing = mapAuctionListing(rs); if (listing != null) list.add(listing); } } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to load auction listings", e); } return list; } public void saveAuctionListing(AuctionListing listing) { String sql = isMySQL ? "INSERT INTO auction_listings (id,seller_uuid,seller_name,item_data,price,created_at,expires_at,views,expired,sold) " + "VALUES (?,?,?,?,?,?,?,?,?,?) ON DUPLICATE KEY UPDATE views=VALUES(views),expired=VALUES(expired),sold=VALUES(sold)" : "INSERT OR REPLACE INTO auction_listings (id,seller_uuid,seller_name,item_data,price,created_at,expires_at,views,expired,sold) " + "VALUES (?,?,?,?,?,?,?,?,?,?)"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, listing.getId().toString()); ps.setString(2, listing.getSellerUuid().toString()); ps.setString(3, listing.getSellerName()); ps.setString(4, ItemSerializer.serialize(listing.getItem())); ps.setDouble(5, listing.getPrice()); ps.setLong(6, listing.getCreatedAt()); ps.setLong(7, listing.getExpiresAt()); ps.setInt(8, listing.getViews()); ps.setInt(9, listing.isExpired() ? 1 : 0); ps.setInt(10, listing.isSold() ? 1 : 0); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to save auction listing", e); } } public void updateAuctionListing(AuctionListing listing) { String sql = "UPDATE auction_listings SET views=?,expired=?,sold=? WHERE id=?"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setInt(1, listing.getViews()); ps.setInt(2, listing.isExpired() ? 1 : 0); ps.setInt(3, listing.isSold() ? 1 : 0); ps.setString(4, listing.getId().toString()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to update auction listing", e); } } private AuctionListing mapAuctionListing(ResultSet rs) throws SQLException { ItemStack item = ItemSerializer.deserialize(rs.getString("item_data")); if (item == null) return null; return new AuctionListing( UUID.fromString(rs.getString("id")), UUID.fromString(rs.getString("seller_uuid")), rs.getString("seller_name"), item, rs.getDouble("price"), rs.getLong("created_at"), rs.getLong("expires_at"), rs.getInt("views"), rs.getInt("expired") == 1, rs.getInt("sold") == 1 ); } // ===== Market Orders ===== public List getActiveMarketOrders() { return getMarketOrders("WHERE cancelled=0 AND filled_quantity < quantity"); } public List getPlayerMarketOrders(UUID playerUuid) { return getMarketOrders("WHERE player_uuid=?", playerUuid.toString()); } private List getMarketOrders(String where, String... params) { List list = new ArrayList<>(); String sql = "SELECT * FROM market_orders " + where; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { for (int i = 0; i < params.length; i++) ps.setString(i + 1, params[i]); ResultSet rs = ps.executeQuery(); while (rs.next()) { list.add(mapMarketOrder(rs)); } } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to load market orders", e); } return list; } public void saveMarketOrder(MarketOrder order) { String sql = isMySQL ? "INSERT INTO market_orders (id,player_uuid,player_name,order_type,item_key,item_data,quantity,filled_quantity,price_each,locked_coins,created_at,cancelled) " + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?) ON DUPLICATE KEY UPDATE filled_quantity=VALUES(filled_quantity)," + "locked_coins=VALUES(locked_coins),cancelled=VALUES(cancelled)" : "INSERT OR REPLACE INTO market_orders (id,player_uuid,player_name,order_type,item_key,item_data,quantity,filled_quantity,price_each,locked_coins,created_at,cancelled) " + "VALUES (?,?,?,?,?,?,?,?,?,?,?,?)"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, order.getId().toString()); ps.setString(2, order.getPlayerUuid().toString()); ps.setString(3, order.getPlayerName()); ps.setString(4, order.getType().name()); ps.setString(5, order.getItemKey()); String itemData = order.getItemTemplate() != null ? ItemSerializer.serialize(order.getItemTemplate()) : null; ps.setString(6, itemData); ps.setInt(7, order.getQuantity()); ps.setInt(8, order.getFilledQuantity()); ps.setDouble(9, order.getPriceEach()); ps.setDouble(10, order.getLockedCoins()); ps.setLong(11, order.getCreatedAt()); ps.setInt(12, order.isCancelled() ? 1 : 0); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to save market order", e); } } public void updateMarketOrder(MarketOrder order) { String sql = "UPDATE market_orders SET filled_quantity=?,locked_coins=?,cancelled=? WHERE id=?"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setInt(1, order.getFilledQuantity()); ps.setDouble(2, order.getLockedCoins()); ps.setInt(3, order.isCancelled() ? 1 : 0); ps.setString(4, order.getId().toString()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to update market order", e); } } private MarketOrder mapMarketOrder(ResultSet rs) throws SQLException { String itemData = rs.getString("item_data"); ItemStack item = itemData != null ? ItemSerializer.deserialize(itemData) : null; return new MarketOrder( UUID.fromString(rs.getString("id")), UUID.fromString(rs.getString("player_uuid")), rs.getString("player_name"), OrderType.valueOf(rs.getString("order_type")), rs.getString("item_key"), item, rs.getInt("quantity"), rs.getInt("filled_quantity"), rs.getDouble("price_each"), rs.getDouble("locked_coins"), rs.getLong("created_at"), rs.getInt("cancelled") == 1 ); } // ===== Transactions ===== public void addTransaction(Transaction tx) { String sql = "INSERT INTO transactions (id,player_uuid,player_name,type,amount,balance_after,description,timestamp) VALUES (?,?,?,?,?,?,?,?)"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, tx.getId().toString()); ps.setString(2, tx.getPlayerUuid().toString()); ps.setString(3, tx.getPlayerName()); ps.setString(4, tx.getType().name()); ps.setDouble(5, tx.getAmount()); ps.setDouble(6, tx.getBalanceAfter()); ps.setString(7, tx.getDescription()); ps.setLong(8, tx.getTimestamp()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to add transaction", e); } } public List getPlayerTransactions(UUID playerUuid, int limit) { List list = new ArrayList<>(); String sql = "SELECT * FROM transactions WHERE player_uuid=? ORDER BY timestamp DESC LIMIT ?"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, playerUuid.toString()); ps.setInt(2, limit); ResultSet rs = ps.executeQuery(); while (rs.next()) { list.add(new Transaction( UUID.fromString(rs.getString("id")), UUID.fromString(rs.getString("player_uuid")), rs.getString("player_name"), TransactionType.valueOf(rs.getString("type")), rs.getDouble("amount"), rs.getDouble("balance_after"), rs.getString("description"), rs.getLong("timestamp") )); } } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to get transactions", e); } return list; } // ===== Shop Items ===== public List getPlayerShopItems(UUID ownerUuid) { return getShopItems("WHERE owner_uuid=?", ownerUuid.toString()); } public List getAllShopItems() { return getShopItems("WHERE stock > 0", (String[]) null); } private List getShopItems(String where, String... params) { List list = new ArrayList<>(); String sql = "SELECT * FROM shop_items " + where + " ORDER BY listed_at DESC"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { if (params != null) { for (int i = 0; i < params.length; i++) ps.setString(i + 1, params[i]); } ResultSet rs = ps.executeQuery(); while (rs.next()) { ItemStack item = ItemSerializer.deserialize(rs.getString("item_data")); if (item == null) continue; list.add(new ShopItem( UUID.fromString(rs.getString("id")), UUID.fromString(rs.getString("owner_uuid")), rs.getString("owner_name"), item, rs.getDouble("price"), rs.getInt("stock"), rs.getLong("listed_at") )); } } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to load shop items", e); } return list; } public void saveShopItem(ShopItem shopItem) { String sql = isMySQL ? "INSERT INTO shop_items (id,owner_uuid,owner_name,item_data,price,stock,listed_at) VALUES (?,?,?,?,?,?,?) " + "ON DUPLICATE KEY UPDATE stock=VALUES(stock),price=VALUES(price)" : "INSERT OR REPLACE INTO shop_items (id,owner_uuid,owner_name,item_data,price,stock,listed_at) VALUES (?,?,?,?,?,?,?)"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, shopItem.getId().toString()); ps.setString(2, shopItem.getOwnerUuid().toString()); ps.setString(3, shopItem.getOwnerName()); ps.setString(4, ItemSerializer.serialize(shopItem.getItem())); ps.setDouble(5, shopItem.getPrice()); ps.setInt(6, shopItem.getStock()); ps.setLong(7, shopItem.getListedAt()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to save shop item", e); } } public void removeShopItem(UUID id) { executeUpdate("DELETE FROM shop_items WHERE id=?", id.toString()); } // ===== Warehouse ===== public List getWarehouseItems(UUID playerUuid) { List list = new ArrayList<>(); String sql = "SELECT * FROM warehouse_items WHERE player_uuid=? ORDER BY deposited_at DESC"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, playerUuid.toString()); ResultSet rs = ps.executeQuery(); while (rs.next()) { ItemStack item = ItemSerializer.deserialize(rs.getString("item_data")); if (item == null) continue; list.add(new WarehouseItem( UUID.fromString(rs.getString("id")), UUID.fromString(rs.getString("player_uuid")), item, rs.getInt("quantity"), rs.getLong("deposited_at") )); } } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to get warehouse items", e); } return list; } public void saveWarehouseItem(WarehouseItem item) { String sql = isMySQL ? "INSERT INTO warehouse_items (id,player_uuid,item_data,quantity,deposited_at) VALUES (?,?,?,?,?) " + "ON DUPLICATE KEY UPDATE quantity=VALUES(quantity)" : "INSERT OR REPLACE INTO warehouse_items (id,player_uuid,item_data,quantity,deposited_at) VALUES (?,?,?,?,?)"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, item.getId().toString()); ps.setString(2, item.getPlayerUuid().toString()); ps.setString(3, ItemSerializer.serialize(item.getItem())); ps.setInt(4, item.getQuantity()); ps.setLong(5, item.getDepositedAt()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to save warehouse item", e); } } public void removeWarehouseItem(UUID id) { executeUpdate("DELETE FROM warehouse_items WHERE id=?", id.toString()); } // ===== Notifications ===== public void addNotification(Notification notification) { String sql = "INSERT INTO notifications (id,player_uuid,message,timestamp) VALUES (?,?,?,?)"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, notification.getId().toString()); ps.setString(2, notification.getPlayerUuid().toString()); ps.setString(3, notification.getMessage()); ps.setLong(4, notification.getTimestamp()); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to add notification", e); } } public List getUnreadNotifications(UUID playerUuid) { List list = new ArrayList<>(); String sql = "SELECT * FROM notifications WHERE player_uuid=? ORDER BY timestamp ASC"; try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, playerUuid.toString()); ResultSet rs = ps.executeQuery(); while (rs.next()) { list.add(new Notification( UUID.fromString(rs.getString("id")), UUID.fromString(rs.getString("player_uuid")), rs.getString("message"), rs.getLong("timestamp") )); } } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "Failed to get notifications", e); } return list; } public void clearNotifications(UUID playerUuid) { executeUpdate("DELETE FROM notifications WHERE player_uuid=?", playerUuid.toString()); } private void executeUpdate(String sql, String... params) { try (Connection conn = getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { for (int i = 0; i < params.length; i++) ps.setString(i + 1, params[i]); ps.executeUpdate(); } catch (SQLException e) { plugin.getLogger().log(Level.WARNING, "DB update failed: " + sql, e); } } }