package de.raidmc.sky.managers;

import java.sql.*;

/**
 * Created by kevin on 25.06.16.
 */
public class MySQLMgr {

    private String HOST = "";
    private String DATABASE = "";
    private String USER = "";
    private String PASSWORD = "";

    private Connection con;


    public MySQLMgr(String HOST, String DATABASE, String USER, String PASSWORD) {
        this.HOST = HOST;
        this.DATABASE = DATABASE;
        this.USER = USER;
        this.PASSWORD = PASSWORD;

        connect();
        createTables();
    }


    public void connect() {
        try {
            con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":3306/" + DATABASE , USER, PASSWORD);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
 //   jdbc:mysql://" + host + ":" + port + "/" + database, username, password
    public void close() {
        try {
            if(con != null){
                con.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public void update(String qry) {
        try {
            Statement st = con.createStatement();
            st.executeUpdate(qry);
            st.close();
        } catch (SQLException e) {
            connect();
            e.printStackTrace();
        }
    }

    public void query(String qry) {
        try {
            Statement st = con.createStatement();
            st.executeQuery(qry);
        } catch (SQLException e) {
            connect();
            e.printStackTrace();
        }
    }

    public ResultSet getResult(String qry) {
        ResultSet rs = null;
        try {
            Statement st = con.createStatement();
            rs = st.executeQuery(qry);
        } catch (SQLException e) {
            connect();
            System.err.println(e);
        }
        return rs;
    }

    public Connection getConection(){
        return con;
    }



    public String bantable = "RaidBan";
    public String mutetable = "RaidMute";
    public String checktable = "RaidCheck";
    public String historytable = "RaidVerlauf";
    public String teamtable = "RaidTeamStatus";
    public String grouptable = "RaidPermissions";
    public String statstable = "RaidStats";
    public String clanusertable = "RaidClanUser";
    public String clanstatstable = "RaidClanStats";
    public String clanallytable = "RaidClanAlly";
    public String coinstable = "RaidSkyCoins";
    public String kopfgeldtable = "RaidSkyKopfGeld";

    public void createTables() {
        update("CREATE TABLE IF NOT EXISTS " + checktable + " (UUID VARCHAR(100), IP VARCHAR(100), DATE VARCHAR(100));");
        update("CREATE TABLE IF NOT EXISTS " + bantable + " (GEBANNTER VARCHAR(100), BANNER VARCHAR(100), GRUND VARCHAR(100), STATUS VARCHAR(100), ZEITRAUM BIGINT, PERM VARCHAR(100));");
        update("CREATE TABLE IF NOT EXISTS " + mutetable + " (GEMUTETER VARCHAR(100), MUTER VARCHAR(100), GRUND VARCHAR(100), STATUS VARCHAR(100), ZEITRAUM BIGINT);");
        update("CREATE TABLE IF NOT EXISTS " + historytable + " (GEBANNTER VARCHAR(100), BANNER VARCHAR(100), UNBANNER VARCHAR(100), GRUND VARCHAR(100), PERM VARCHAR(100), ENTBANNT VARCHAR(100));");
        update("CREATE TABLE IF NOT EXISTS " + historytable + " (GEBANNTER VARCHAR(100), BANNER VARCHAR(100), UNBANNER VARCHAR(100), GRUND VARCHAR(100), PERM VARCHAR(100), ENTBANNT VARCHAR(100));");
        update("CREATE TABLE IF NOT EXISTS " + teamtable + " (UUID VARCHAR(100), RANK VARCHAR(100), STATUS VARCHAR(100));");
        update("CREATE TABLE IF NOT EXISTS " + grouptable + " (UUID VARCHAR(100), GRUPPE VARCHAR(100));");
        update("CREATE TABLE IF NOT EXISTS " + clanstatstable + " (CLANTAG VARCHAR(100), CLANNAME VARCHAR(100), LEADER VARCHAR(100));");
        update("CREATE TABLE IF NOT EXISTS " + clanusertable + " (SPIELER VARCHAR(100), CLANTAG VARCHAR(100), RANG VARCHAR(100), TITEL VARCHAR(100));");
        update("CREATE TABLE IF NOT EXISTS " + clanallytable + " (CLANTAG VARCHAR(100), ALLYTAG VARCHAR(100));");
        update("CREATE TABLE IF NOT EXISTS " + statstable + " (UUID VARCHAR(100), KILLS INT, DEATHS INT, POINTS INT);");
        update("CREATE TABLE IF NOT EXISTS " + coinstable + " (UUID VARCHAR(100), MONEY INT);");
        update("CREATE TABLE IF NOT EXISTS " + kopfgeldtable + " (UUID VARCHAR(100), MONEY INT);");
    }
}