package de.EidechsenGHG.QuickSurvivalGames.MySQL;

import de.EidechsenGHG.QuickSurvivalGames.Main;
import org.bukkit.Bukkit;

import java.sql.*;

/**
 * Created by cooki on 12.08.2016.
 */
public class MySQL {

    private static String HOST = "localhost";
    private static String DATABASE = "Punkte";
    private static String USERNAME = "root";
    private static String PASSWORD = "fjnif823";
    private static Connection con;

    public static void connect() {
        try {
            con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":3306/" + DATABASE + "?autoReconnect=true", USERNAME, PASSWORD);
            Bukkit.getConsoleSender().sendMessage(Main.prefix + "§aMySQL-Verbindung wurde aufgebaut!");
        } catch (SQLException e) {
            Bukkit.getConsoleSender().sendMessage(Main.prefix + "§cMySQL-Verbindung konnte nicht aufgebaut werden!");
        }
    }

    public static void disconnect() {
        try {
            con.close();
            Bukkit.getConsoleSender().sendMessage(Main.prefix + "§aMySQL Verbindung wurde getrennt!");
        } catch (SQLException e) {
            Bukkit.getConsoleSender().sendMessage(Main.prefix + "§cFehler beim schließen der MySQL Datenbank!");
        }
    }

    public static void update(String qry) {
        try {
            Statement statement = con.createStatement();
            statement.executeUpdate(qry);
            statement.close();
        } catch (SQLException e) {
            connect();
            System.err.println(e);
        }
    }

    public static ResultSet query(String qry) {
        ResultSet resultSet = null;
        try {
            Statement statement = con.createStatement();
            resultSet = statement.executeQuery(qry);
        } catch (SQLException e) {
            connect();
            System.err.println(e);
        }
        return resultSet;
    }

}