package skywars.kenny.db;

import com.mysql.jdbc.PreparedStatement;

import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.UUID;

/**
 * @author PrinzKenny1 on 30.06.2016 at 17:33:17
 *         <p>
 *         Nexus Team
 *         <p>
 *         Copyright by Calvin Mende
 */
public class db {

    static final String tablegame = dbmain2.database;
    static String tablekits = "nick";

    //////////////////////////////////////////////
    ////// CREATE USER TO MAKE IT EASIER//////
    //////////////////////////////////////////////

    public static void createUser(UUID uuid, String name, String nick) {
        try {
            PreparedStatement ps = (PreparedStatement) dbmain2.getConnection().prepareStatement("INSERT INTO `"
                    + tablegame + "` (`uuid`, `name`, `nick`) VALUES (?,?,?) ON DUPLICATE KEY UPDATE uuid=?");
            ps.setString(1, uuid.toString());
            ps.setString(2, name);
            ps.setString(3, nick);
            ps.setString(4, uuid.toString());
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /////////////////////////////////////
    //////// IS EXIST ABFRAGE//////////
    /////////////////////////////////////

    public static boolean isUserExists(UUID uuid) {
        try {
            PreparedStatement ps;
            if (!dbmain2.isConnected()) {
                dbmain2.connect();
            }
            ps = (PreparedStatement) dbmain2.getConnection()
                    .prepareStatement("SELECT * FROM " + tablegame + " WHERE UUID = ?");
            ps.setString(1, uuid.toString());
            ResultSet rs = ps.executeQuery();
            return rs.first();
        } catch (SQLException e) {
            try {
                dbmain2.con = DriverManager.getConnection("jdbc:mysql://" + dbmain2.host + ":" + dbmain2.port + "/"
                        + dbmain2.database + "?autoReconnect=true", dbmain2.username, dbmain2.password);
                PreparedStatement ps;
                if (!dbmain2.isConnected()) {
                    dbmain2.connect();
                }
                ps = (PreparedStatement) dbmain2.getConnection()
                        .prepareStatement("SELECT * FROM " + tablegame + " WHERE UUID = ?");
                ps.setString(1, uuid.toString());
                ResultSet rs = ps.executeQuery();
                return rs.first();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
        }
        return false;
    }

    /////////////////////////////////////
    //////// IF DB EXIST ABFRAGE///////
    /////////////////////////////////////

    public static void isTabelexist() {
        PreparedStatement ps;
        try {
            if (!dbmain2.isConnected()) {
                dbmain2.con = DriverManager.getConnection(
                        "jdbc:mysql://" + dbmain2.host + ":" + dbmain2.port + "?autoReconnect=true", dbmain2.username,
                        dbmain2.password);
                ps = (PreparedStatement) dbmain2.getConnection()
                        .prepareStatement("CREATE DATABASE IF NOT EXISTS " + dbmain2.database);
                ps.executeUpdate();
                ps = (PreparedStatement) dbmain2.getConnection().prepareStatement("USE " + dbmain2.database);
                ps.executeUpdate();
                ps = (PreparedStatement) dbmain2.getConnection().prepareStatement("CREATE TABLE IF NOT EXISTS `"
                        + tablegame + "` (`UUID` VARCHAR(100), `name` VARCHAR(100), `nick` VARCHAR(100))");
                ps.executeUpdate();
                ps.executeUpdate();
                dbmain2.con.close();
                dbmain2.con = null;
                dbmain2.connect();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    ////////////////////////////////////////////////////////
    ////////////////////// METHODEN /////////////////////
    ////////////////////////////////////////////////////////

    //////////////////////////////////////////
    ////////// NICK////////////////////////
    //////////////////////////////////////

    public static void SETNick(UUID uuid, String name, String nick) {
        if (isUserExists(uuid)) {
            try {
                PreparedStatement ps = (PreparedStatement) dbmain2.getConnection()
                        .prepareStatement("UPDATE " + dbmain2.database + " SET nick = ? WHERE UUID = ?");
                ps.setString(2, uuid.toString());
                ps.setString(1, nick);
                ps.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        } else {
            createUser(uuid, name, nick);
        }
    }

    public static String GETNick(UUID uuid, String name) {
        if (isUserExists(uuid)) {
            try {
                PreparedStatement ps = (PreparedStatement) dbmain2.getConnection()
                        .prepareStatement("SELECT nick FROM " + dbmain2.database + " WHERE UUID = ?");
                ps.setString(1, uuid.toString());
                ResultSet rs = ps.executeQuery();
                while (rs.next()) {
                    return rs.getString("nick");
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        } else {
            createUser(uuid, name, name);
        }
        return null;
    }

    public static void SETName(UUID uuid, String name, String nick) {
        if (isUserExists(uuid)) {
            try {
                PreparedStatement ps = (PreparedStatement) dbmain2.getConnection()
                        .prepareStatement("UPDATE " + dbmain2.database + " SET name = ? WHERE UUID = ?");
                ps.setString(2, uuid.toString());
                ps.setString(1, nick);
                ps.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        } else {
            createUser(uuid, name, nick);
        }
    }

    public static String GETName(UUID uuid, String name) {
        if (isUserExists(uuid)) {
            try {
                PreparedStatement ps = (PreparedStatement) dbmain2.getConnection()
                        .prepareStatement("SELECT name FROM " + dbmain2.database + " WHERE UUID = ?");
                ps.setString(1, uuid.toString());
                ResultSet rs = ps.executeQuery();
                while (rs.next()) {
                    return rs.getString("name");
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        } else {
            createUser(uuid, name, name);
        }
        return null;
    }

}