package fr.kerwan.calendar;

import org.bukkit.Bukkit;
import org.bukkit.entity.Player;

import java.sql.*;

/**
 * Created by Kerwan on 08/11/2016.
 */
public class Database {

    private static Connection connection;

    public static void close() {
        try {
            if (connection != null && !connection.isClosed()) {
                connection.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }

    }

    public synchronized static void open(){
        Bukkit.getLogger().info(">> Connection to database");
        try{
            connection = DriverManager.getConnection("jdbc:mysql://mineaurion.com:3306/kerwan", "kerwan", "QLar1QV0Bmyss7eZ");
            Bukkit.getLogger().info(">> Connection succesfull");
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    public synchronized static boolean hasVoted(Player p){
        try{
            PreparedStatement sql = connection.prepareStatement("SELECT `Voted` FROM `Calendar` WHERE UUID=?;");
            sql.setString(1, p.getUniqueId().toString());
            ResultSet resultSet = sql.executeQuery();
            boolean containsPlayer = resultSet.next();
            resultSet.close();

            return containsPlayer;
        }catch (Exception e){
            return false;
        }
    }

    public synchronized static boolean containPlayer(Player p){
        try{
            PreparedStatement sql = connection.prepareStatement("SELECT * FROM `Calendar` WHERE UUID=?;");
            sql.setString(1, p.getUniqueId().toString());
            ResultSet resultSet = sql.executeQuery();
            boolean containsPlayer = resultSet.next();
            resultSet.close();

            return containsPlayer;
        }catch (Exception e){
            return false;
        }
    }

    public synchronized static void createPlayer(Player p){
        try {
            PreparedStatement newPlayer = connection.prepareStatement("INSERT INTO `Calendar` values(?,?,0);");
            newPlayer.setString(1, p.getName());
            newPlayer.setString(2, p.getUniqueId().toString());
            newPlayer.execute();
            newPlayer.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public synchronized static void setVoted(Player p){
        try {
            PreparedStatement newAura = connection.prepareStatement("UPDATE `Calendar` SET `Voted`=true WHERE Nickname='" + p.getName() +"';");
            newAura.execute();
            newAura.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public synchronized static void clearDatabase(){
        try {
            PreparedStatement newAura = connection.prepareStatement("DELETE FROM `Calendar`;");
            newAura.execute();
            newAura.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}