package skyCubeStats150803;

import java.sql.*;
import java.util.UUID;

import org.bukkit.entity.Player;

public class DatabaseConnect {

    int kills;
    int tode;
    boolean exists;
    final String hostname = "176.31.206.88";
    final String dbname = "stats";
    final String user = "root";
    final String password = "4LpkBtsn44vaYUgY";
    Connection conn = null;

    public DatabaseConnect() { //Konstruktor mit Datenbankverbindung


        try {
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            }

        catch (Exception e) {

                System.out.println("SkyCubeStats: Verbindung zur Datenbank fehlgeschlagen");
                e.printStackTrace();

            }

        try {

        String url = "jdbc:mysql://"+hostname+":3306/"+dbname;
        conn = DriverManager.getConnection(url, user, password);

        }

        catch (SQLException sqle) {

            sqle.printStackTrace();
            System.out.println("SQLException: " + sqle.getMessage());
            System.out.println("SQLState: " + sqle.getSQLState());
            System.out.println("VendorError: " + sqle.getErrorCode());

        }

    } //Konstruktor Ende

    //Statistiken ändern wenn Spieler von Spieler gekillt

    public void addKillAndDeath(Player death, Player killer) {

        UUID deathuuid = UUIDFetcher.getUUID(death.getName());
        UUID killeruuid = UUIDFetcher.getUUID(killer.getName());
        int amountkiller = 1;
        int amountdeath = 1;

        //Datenbankzugriff
        try{
            //Testen ob death in Datenbank
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT count(*) FROM PlayerStatsSkyPvp WHERE Name = '"+deathuuid+"'");

            while (rs.next()) {

                amountdeath = rs.getInt("count(*)");

                }
            //Testen ob killer in Datenbank
            ResultSet rs2 = stmt.executeQuery("SELECT count(*) FROM PlayerStatsSkyPvp WHERE Name = '"+killeruuid+"'");

            while (rs2.next()) {

                 amountkiller = rs2.getInt("count(*)");

                }

            //If Abfragen ob Killer & Death schon in db und entsprechende Änderungen an db

            if(amountdeath > 0) {

                stmt.executeUpdate("UPDATE PlayerStatsSkyPvp SET Tode = Tode + 1 WHERE NAME = '"+deathuuid+"'");

            } else {

                stmt.executeUpdate("INSERT INTO PlayerStatsSkyPvp (Name, Kills, Tode) VALUES ('"+deathuuid+"','0','1');");

            }

            if(amountkiller > 0) {

                stmt.executeUpdate("UPDATE PlayerStatsSkyPvp SET Kills = Kills + 1 WHERE NAME = '"+killeruuid+"'");

            } else {

                stmt.executeUpdate("INSERT INTO PlayerStatsSkyPvp (Name, Kills, Tode) VALUES ('"+killeruuid+"','1','0');");

            }

            stmt.close();

        }
        catch (SQLException e) {

            e.printStackTrace();

        }


    } //Statistiken ändern wenn Spieler von Spieler gekillt Ende

  //Statistiken ändern wenn Spieler stirbt

    public void addDeath(Player death) {

        UUID deathuuid = UUIDFetcher.getUUID(death.getName());
        int amountdeath = 1;


        try {
            //Testen ob death in db
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT count(*) FROM PlayerStatsSkyPvp WHERE Name = '"+deathuuid+"'");

            while (rs.next()) {

                amountdeath = rs.getInt("count(*)");

                }

            //If Abfragen ob death in db und entsprechende Anweisungen

            if(amountdeath > 0) {

                stmt.executeUpdate("UPDATE PlayerStatsSkyPvp SET Tode = Tode + 1 WHERE NAME = '"+deathuuid+"'");

            } else {

                stmt.executeUpdate("INSERT INTO PlayerStatsSkyPvp (Name, Kills, Tode) VALUES ('"+deathuuid+"','0','1');");

            }

            stmt.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    } //Statistiken ändern wenn Spieler stirbt Ende

    //Getter und Setter Kills
    public int getKills(Player p) {

        int kills = 0;
        UUID playeruuid = UUIDFetcher.getUUID(p.getName());

        try {

            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT Kills FROM PlayerStatsSkyPvp WHERE NAME ='"+playeruuid+"'");

            while(rs.next()) {

                kills = rs.getInt("Kills");

            }

            stmt.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return kills;

    }

    public int getTode(Player p) {

        int tode = 0;
        UUID playeruuid = UUIDFetcher.getUUID(p.getName());

        try {

            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT Tode FROM PlayerStatsSkyPvp WHERE NAME ='"+playeruuid+"'");

            while(rs.next()) {

                tode = rs.getInt("Tode");

            }

            stmt.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return tode;

    } //Getter und Setter Kills Ende

    public boolean exists(Player p) {

        boolean exists = false;
        int amount = 1;
        UUID playeruuid = UUIDFetcher.getUUID(p.getName());

        try {

            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT count(*) FROM PlayerStatsSkyPvp WHERE NAME ='"+playeruuid+"'");

            while(rs.next()) {

                amount = rs.getInt("count(*)");

            }

            if(amount > 0) {

                exists = true;

            } else {

                exists = false;

            }

        } catch (SQLException e) {

            e.printStackTrace();

        }

        return exists;

    }

    public void endConnection() {

        try {

            conn.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }


    }

    public void delete(Player p) {

        UUID playeruuid = UUIDFetcher.getUUID(p.getName());

        try {

            Statement stmt = conn.createStatement();
            stmt.executeUpdate("DELETE FROM PlayerStatsSkyPvp WHERE NAME = '"+playeruuid+"'");
            stmt.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }
    }
}