Untitled

package archivo.ar;

import org.bukkit.Bukkit;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class DatabaseManager {
    private String host, database, username, password;
    private int port;
    private Connection connection;

    public DatabaseManager(String host, int port, String database, String username, String password) {
        this.host = host;
        this.port = port;
        this.database = database;
        this.username = username;
        this.password = password;
    }

    public void connect() throws SQLException {
        if (connection != null && !connection.isClosed()) {
            return; // Ya conectado
        }

        String url = "jdbc:mysql://" + host + ":" + port + "/" + database;
        connection = DriverManager.getConnection(url, username, password);
        Bukkit.getConsoleSender().sendMessage("Base de datos conectada");
    }

    public void disconnect() {
        if (connection != null) {
            try {
                connection.close();
                Bukkit.getConsoleSender().sendMessage("Conexión a la base de datos cerrada");
            } catch (SQLException e) {
                Bukkit.getConsoleSender().sendMessage("Error al cerrar la conexión: " + e.getMessage());
            }
        }
    }

    public Connection getConnection() {
        return connection;
    }
}