package skywars.kenny.db;

import org.bukkit.Bukkit;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.configuration.file.YamlConfiguration;
import skywars.kenny.main.main;

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

public class dbmain {

    static final File file = new File("plugins/SkyWars", "config.yml");
    static final FileConfiguration cfg = YamlConfiguration.loadConfiguration(file);

    public static final String host = cfg.getString("host");
    public static final int port = cfg.getInt("port");
    public static final String username = cfg.getString("username");
    public static final String password = cfg.getString("password");
    public static final String database = cfg.getString("database");
    static Connection con;

    public static void connect() {
        if (!(isConnected())) {
            try {
                startRunnable();
                con = DriverManager.getConnection(
                        "jdbc:mysql://" + host + ":" + port + "/" + database + "?autoReconnect=true", username,
                        password);
                Bukkit.getConsoleSender().sendMessage("[MySQL] ยง2Connected");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void disconnect() {
        if (isConnected()) {
            try {
                con.close();
                con = null;
                Bukkit.getConsoleSender().sendMessage("[MySQL] ยง4Disconnected");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void startRunnable() {
        Bukkit.getScheduler().scheduleSyncRepeatingTask(main.plugin, new Runnable() {

            @Override
            public void run() {
                if (!(isConnected())) {
                    try {
                        con = DriverManager.getConnection(
                                "jdbc:mysql://" + host + ":" + port + "/" + database + "?autoReconnect=true", username,
                                password);
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
            }
        }, 20, 20);
    }

    public static boolean isConnected() {
        return (con != null);
    }

    public static Connection getConnection() {
        return con;
    }

}