package net.mrzinki.SpruceEconomic;

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

import org.bukkit.entity.Player;

public class SQLConnection {

	private Connection connection;
	private String urlbase,host,database,user,pass;


	public SQLConnection(String urlbase, String host, String database, String user, String pass) {
		this.urlbase = urlbase;
		this.host = host;
		this.database = database;
		this.user = user;
		this.pass = pass;
	}

	public void connection(){
		if(!isConnected()){
			try{
				connection = DriverManager.getConnection(urlbase+host+"/"+database, user, pass);
				System.out.println("SpruceEconomic : Database connected.");
			}catch (SQLException e){
				e.printStackTrace();
			}
		}
	}

	public void disconnect(){
		if(isConnected()){
			try{
				connection.close();
				System.out.println("SpruceEconomic : Database disconnected.");
			}catch (SQLException e){
				e.printStackTrace();
			}
		}
	}

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

	public void createAccount(Player player){
		if(!hasAccount(player)){
			try{
				PreparedStatement q = connection.prepareStatement("INSERT INTO spruceeconomie(uuid,coins) VALUES (?,?)");
				q.setString(1, player.getUniqueId().toString());
				q.setInt(2, 100);
				q.execute();
				q.close();
			}catch (SQLException e){
				e.printStackTrace();
			}
		}
	}

	public boolean hasAccount(Player player){
		try{
			PreparedStatement q = connection.prepareStatement("SELECT uuid FROM spruceeconomie WHERE uuid = ?");
			q.setString(1, player.getUniqueId().toString());
			ResultSet resultat = q.executeQuery();
			boolean hasAccount = resultat.next();
			q.close();
			return hasAccount;
		}catch (SQLException e){
			e.printStackTrace();
		}
		return false;
	}

	public int getBalance(Player player){
		try{
			PreparedStatement q = connection.prepareStatement("SELECT coins FROM spruceeconomie WHERE uuid = ?");
			q.setString(1, player.getUniqueId().toString());
			int balance = 0;
			ResultSet rs = q.executeQuery();
			while(rs.next()){
				balance = rs.getInt("coins");
			}
			q.close();
			return balance;
		}catch (SQLException e){
			e.printStackTrace();
		}
		return 0;
	}

	public void addMoney(Player player,int amount){
		int balance = getBalance(player);
		int newbalance = balance + amount;
		if(newbalance <= 0){
			return;
		}
		try{
			PreparedStatement q = connection.prepareStatement("UPDATE spruceeconomie SET coins = ? WHERE uuid = ?");
			q.setInt(1, newbalance);
			q.setString(2, player.getUniqueId().toString());
			q.executeUpdate();
			q.close();
		}catch (SQLException e){
			e.printStackTrace();
		}
	}

	public void delMoney(Player player,int amount){
		int balance = getBalance(player);
		int newbalance = balance - amount;
		if(newbalance <= 0){
			return;
		}
		try{
			PreparedStatement q = connection.prepareStatement("UPDATE spruceeconomie SET coins = ? WHERE uuid = ?");
			q.setInt(1, newbalance);
			q.setString(2, player.getUniqueId().toString());
			q.executeUpdate();
			q.close();
		}catch (SQLException e){
			e.printStackTrace();
		}
	}

}