package fr.core.furiousspawners.spawnersapi;

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

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

public class MySQLSpawners {

	/* TO-DO LIST
	 * */

	private String urlbase, host, name, username, password;
	private Connection connection;

	public MySQLSpawners(String urlbase, String host, String name, String username, String password){
		this.urlbase = urlbase;
		this.host = host;
		this.name = name;
		this.username = username;
		this.password = password;
	}

	public void connection(){
		if(!isConnected()){
			try{
				connection = DriverManager.getConnection(urlbase + host + "/" + name, username, password);
				Bukkit.getServer().getConsoleSender().sendMessage("FuriousSpawners - INFO: "+ChatColor.GREEN+"Connected!");
			} catch(SQLException ex){
				ex.printStackTrace();
			}
		} else {
			Bukkit.getServer().getConsoleSender().sendMessage("FuriousSpawners - INFO: Already connected");
		}
	}

	public void deconnection(){
		if(isConnected()){
			try{
				connection.close();
				Bukkit.getServer().getConsoleSender().sendMessage("FuriousSpawners - INFO:"+ChatColor.RED+" Disconnectd!");
			} catch (SQLException ex){
				ex.printStackTrace();
			}
		}
	}

	private Connection getConnection(){
		return connection;
	}

	public boolean isConnected(){
		return connection != null;
	}

	public void createAccount(Player player) {
		if(!hasAccount(player)){
			try{
				PreparedStatement sts = getConnection().prepareStatement("INSERT INTO fsCredits(playername, zombie_credit, skeleton_credit, pigmen_credit, cow_credit, blaze_credit, spider_credit) VALUES (?,?,?,?,?,?,?)");
				sts.setString(1, player.getName());
				sts.setInt(2, 0);
				sts.setInt(3, 0);
				sts.setInt(4, 0);
				sts.setInt(5, 0);
				sts.setInt(6, 0);
				sts.setInt(7, 0);
				sts.execute();
				sts.close();

				Bukkit.getServer().getConsoleSender().sendMessage("§aCompte correctement créé pour "+player.getName());
			} catch(SQLException ex) {
				ex.printStackTrace();
			}
		}
	}

	public boolean hasAccount(Player player) {
		try {
			PreparedStatement sts = getConnection().prepareStatement("SELECT playername FROM fsCredits WHERE playername = ?");
			sts.setString(1, player.getName());
			ResultSet result = sts.executeQuery();
			boolean hasAccount = result.next();
			sts.close();

			return hasAccount;
		} catch (SQLException ex) {
			ex.printStackTrace();
		}
		return false;
	}
}