package me.CraftDirt.cakebandit.handlers;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.UUID;
import org.bukkit.Bukkit;
import org.bukkit.entity.Player;

public class Database {
    
	   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
	   static final String DB_URL = "jdbc:mysql://localhost/";
	   static final String USER = "root";
	   static final String PASS = "";
	
    private static Connection connection;
    
    public synchronized static void openConnection(){
        
    	
        try{
            
            connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/cakebandit", "root", "");
            
        }catch(Exception e){
            
            e.printStackTrace();
            
        }
        
    }
    
    public synchronized static void closeConnection(){
        
        try{
            
            connection.close();
            
        }catch(Exception e){
            
            e.printStackTrace();
            
        }
        
    }
    
    public synchronized static Connection getConnection(){
        
        return connection;
        
    }
    
    public synchronized static boolean playerTableContainsPlayer(Player player){
        
        try{
            
            PreparedStatement sql = connection.prepareStatement("SELECT * FROM players WHERE uuid = ?;");
            sql.setString(1, player.getUniqueId().toString());
            ResultSet resultSet = sql.executeQuery();
            boolean containsPlayer = resultSet.next();
            
            sql.close();
            resultSet.close();
            
            return containsPlayer;
            
        }catch(Exception e){
            
            e.printStackTrace();
            return false;
            
        }
        
    }
    
    public synchronized static boolean cbTableContainsPlayer(Player player){
        
        try{
            
            PreparedStatement sql = connection.prepareStatement("SELECT * FROM cakebandit WHERE uuid = ?;");
            sql.setString(1, player.getUniqueId().toString());
            ResultSet resultSet = sql.executeQuery();
            boolean containsPlayer = resultSet.next();
            
            sql.close();
            resultSet.close();
            
            return containsPlayer;
            
        }catch(Exception e){
            
            e.printStackTrace();
            return false;
            
        }
        
    }
    
    public synchronized static void addPlayerToPlayerTable(Player player){
        
        try{
            
            DateFormat dateFormat = new SimpleDateFormat("dd/MM/yyyy - hh:mm:ss");
            Date date = new Date();
            
            PreparedStatement newPlayer = connection.prepareStatement("INSERT INTO players(uuid, username, firstlogin, lastlogin, passes) VALUES(?, ?, ?, ?, 0);");
            newPlayer.setString(1, player.getUniqueId().toString());
            newPlayer.setString(2, player.getName());
            newPlayer.setString(3, dateFormat.format(date));
            newPlayer.setString(4, dateFormat.format(date));
            newPlayer.execute();
            
            newPlayer.close();
            
        }catch(Exception e){
        
            e.printStackTrace();
            
        }
        
    }
    
    public synchronized static void addPlayerToCbTable(Player player){
        
        try{
            
            PreparedStatement newPlayer = connection.prepareStatement("INSERT INTO cakebandit VALUES(?, 0, 0, 0, 0, 0, 0, 0);");
            newPlayer.setString(1, player.getUniqueId().toString());
            newPlayer.execute();
            
            newPlayer.close();
            
        }catch(Exception e){
        
            e.printStackTrace();
            
        }
        
    }
    
    public synchronized static void updateLastLogin(Player player){
        
        try{
            
            DateFormat dateFormat = new SimpleDateFormat("dd/MM/yyyy - hh:mm:ss");
            Date date = new Date();
            
            PreparedStatement updatePlayer = connection.prepareStatement("UPDATE players SET lastlogin = ? WHERE uuid = ?;");
            updatePlayer.setString(1, dateFormat.format(date));
            updatePlayer.setString(2, player.getUniqueId().toString());
            updatePlayer.executeUpdate();
            
            updatePlayer.close();
            
        }catch(Exception e){
        
            e.printStackTrace();
            
        }
        
    }
    
    public synchronized static void updateCbTable(Player player, String column, int newValue){
        
        try{
            
            PreparedStatement updatePlayer = connection.prepareStatement("UPDATE cakebandit SET " + column + " = ? WHERE uuid = ?;");
            updatePlayer.setInt(1, newValue);
            updatePlayer.setString(2, player.getUniqueId().toString());
            updatePlayer.executeUpdate();
            
            updatePlayer.close();
            
        }catch(Exception e){
        
            e.printStackTrace();
            
        }
        
    }
    
    public synchronized static void updatePasses(Player player, int newValue){
        
        try{
            
            PreparedStatement updatePlayer = connection.prepareStatement("UPDATE players SET passes = ? WHERE uuid = ?;");
            updatePlayer.setInt(1, newValue);
            updatePlayer.setString(2, player.getUniqueId().toString());
            updatePlayer.executeUpdate();
            
            updatePlayer.close();
            
        }catch(Exception e){
        
            e.printStackTrace();
            
        }
        
    }
    
    public synchronized static int getHighestPoints(){
        
        try{
            
            PreparedStatement getScore = connection.prepareStatement("SELECT MAX(points) FROM cakebandit;");
            ResultSet resultSet = getScore.executeQuery();
            int result = 0;
            
            while(resultSet.next()){
                result = resultSet.getInt(1);
            }
            
            getScore.close();
            
            return result;
            
        }catch(Exception e){
        
            e.printStackTrace();
            
            return 0;
            
        }
        
    }
    
    public synchronized static int getCb(Player player, String column){
        
        try{
            
            PreparedStatement getScore = connection.prepareStatement("SELECT " + column + " FROM cakebandit WHERE uuid = ?;");
            getScore.setString(1, player.getUniqueId().toString());
            ResultSet resultSet = getScore.executeQuery();
            resultSet.next();
           
            int result = resultSet.getInt(column);
            
            getScore.close();
            
            return result;
            
        }catch(Exception e){
        
            e.printStackTrace();
            
            return 0;
            
        }
        
    }
    
    public synchronized static int getPasses(Player player){
        
        try{
            
            PreparedStatement getPasses = connection.prepareStatement("SELECT passes FROM players WHERE uuid = ?;");
            getPasses.setString(1, player.getUniqueId().toString());
            ResultSet resultSet = getPasses.executeQuery();
            resultSet.next();
           
            int result = resultSet.getInt("passes");
            
            getPasses.close();
            
            return result;
            
        }catch(Exception e){
        
            e.printStackTrace();
            
            return 0;
            
        }
        
    }
    
}