package de.hannezhd.citybuildsystem.util;

import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.configuration.file.YamlConfiguration;

import java.io.File;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class MYSQLManager {
    private FileConfiguration mysqlConfig;
    private String host;
    private int port;
    private String database;
    private String username;
    private String password;
    private Connection connection;

    public MYSQLManager(File dataFolder) {
        File configFile = new File(dataFolder, "mysql.config");

        if (!configFile.exists()) {
            try {
                configFile.createNewFile();
                mysqlConfig = YamlConfiguration.loadConfiguration(configFile);

                // Setze Standardwerte
                mysqlConfig.set("mysql.host", "localhost");
                mysqlConfig.set("mysql.port", 3306);
                mysqlConfig.set("mysql.database", "meinedatenbank");
                mysqlConfig.set("mysql.username", "root");
                mysqlConfig.set("mysql.password", "passwort");

                mysqlConfig.save(configFile);
            } catch (IOException e) {
                e.printStackTrace();
            }
        } else {
            mysqlConfig = YamlConfiguration.loadConfiguration(configFile);
        }

        loadConfig();
        connect();
    }

    private void loadConfig() {
        host = mysqlConfig.getString("mysql.host");
        port = mysqlConfig.getInt("mysql.port");
        database = mysqlConfig.getString("mysql.database");
        username = mysqlConfig.getString("mysql.username");
        password = mysqlConfig.getString("mysql.password");
    }

    private void connect() {
        try {
            String url = "jdbc:mysql://" + host + ":" + port + "/" + database;
            connection = DriverManager.getConnection(url, username, password);
            System.out.println("Connected to MySQL database.");
        } catch (SQLException e) {
            System.out.println("Failed to connect to MySQL database.");
            e.printStackTrace();
            connection = null;
        }
    }

    public void disconnect() {
        try {
            if (connection != null && !connection.isClosed()) {
                connection.close();
                System.out.println("Disconnected from MySQL database.");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    public void createTables() {
        try {
            Statement statement = connection.createStatement();
            String createTableQuery = "CREATE TABLE IF NOT EXISTS player_accounts ("
                    + "player_name VARCHAR(255) PRIMARY KEY,"
                    + "balance DOUBLE NOT NULL"
                    + ")";
            statement.execute(createTableQuery);
            statement.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public Connection getConnection() {
        return connection;
    }

}