package me.jayell.ms;

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

import org.bukkit.Bukkit;

public class MySQL {

    static String IP = "pma.valaphee.de";
    static String PORT = "3306";
    static String USERNAME = "jlemke";
    static String PASSWORD = "7ax03EMZyDDNltAJ";
    static String DATABASE = "jlemke";

    public static Connection con;

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

    public static void connect(){
        if(!isConnected()){
            try {
                con = DriverManager.getConnection("jdbc:mysql://" + IP + ":" + PORT + "/" + DATABASE + "?autoReconnect=true", USERNAME, PASSWORD);
                Bukkit.getConsoleSender().sendMessage(Data.mysqlTrue + "Es konnte erfolgreich mit der Datenbank verbunden werden");
            } catch (SQLException e) {
                e.printStackTrace();
                Bukkit.getConsoleSender().sendMessage(Data.mysqlFalse + "Es konnte nicht mit der Datenbank verbunden werden");
            }
        }
    }

    public static void disconnect(){
        try {
            con.close();
            Bukkit.getConsoleSender().sendMessage(Data.mysqlTrue  + "Die Verbindung zur Datenbank konnte erfolgreich geschlossen werden");
        } catch (SQLException e) {
            Bukkit.getConsoleSender().sendMessage(Data.mysqlFalse + "Die Verbindung zur Datenbank konnte nicht geschlossen werden");
        }
    }

    public static PreparedStatement getStatement(String sql){
        if(isConnected()){
            PreparedStatement ps;
            try {
                ps = con.prepareStatement(sql);
                return ps;
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

    public static void update(String qry){
        try{
            PreparedStatement ps = con.prepareStatement(qry);
            ps.executeUpdate();
        }catch(SQLException e) {
            e.printStackTrace();
        }
    }

    public static ResultSet getResult(String sql){
        if(isConnected()){
            PreparedStatement ps;
            ResultSet rs;
            try {
                ps = getStatement(sql);
                rs = ps.executeQuery();
                return rs;
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

}