package de.finn.lobbysystem.adventskalender;

import de.finn.lobbysystem.LobbySystem;
import org.bukkit.Bukkit;
import org.bukkit.scheduler.BukkitRunnable;

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

public class MySQL {

    private String host;
    private String database;
    private String user;
    private String password;


    public MySQL(String host, String database, String user, String password) throws ClassNotFoundException {

        Class.forName("com.mysql.jdbc.Driver");

        this.host = host;
        this.database = database;
        this.user = user;
        this.password = password;

    }

    private Connection con;
    public Connection openConnection() throws Exception {

        System.out.println("MySQL Connected.");
        return con = DriverManager.getConnection("jdbc:mysql://" + this.host + "/" + this.database + "?user=" + this.user + "&password=" + this.password + "&?autoreconnect=true");

    }

    public void createTable() {

        this.queryUpdate("CREATE TABLE `DATENBANK`.`adventskalender` ( `id` INT(11) NOT NULL AUTO_INCREMENT , `UUID` VARCHAR(255) NOT NULL , `LastReward` INT(11) NOT NULL , PRIMARY KEY (`id`)) ENGINE = InnoDB;");

    }

    public Connection getConnection() {
        return con;
    }

    public void queryUpdate(String query) {

        PreparedStatement st = null;
        try {
            st = (PreparedStatement)con.prepareStatement(query);
            st.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            closeRessources(null, st);
        }

    }

    public void closeRessources(ResultSet rs, PreparedStatement st) {

        if(rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(st != null) {
            try {
                st.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }

    public void closeConnection() {
        try {
            con.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public ResultSet query(String query) {
        ResultSet rs = null;
        try {
            Statement st = con.createStatement();
            rs = st.executeQuery(query);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return rs;
    }

}