SQLConnection

package fr.eloxfire.SimplifiedCoins;

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, mdp;

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

	public void connection(){
		if(!isConnected()){
		try {
			connection = DriverManager.getConnection(urlbase + host + "/" + database, user, mdp);
			System.out.println("Connected ok !");
		} catch (SQLException e) {
			e.printStackTrace();
		}
		}
	}

	/*
	 *  INSERT
	 *  UPDATE
	 *  DELETE
	 * SELECT
	 *
	 * PREPARER ?,?
	 * REMPLACER LES ? PAR DES VALEURS
	 * EXECUTER
	 *
	 *
	 */

	public void disconnect(){
		if(isConnected()){
		try {
			connection.close();
			System.out.println("Disconnected ok !");
		} catch (SQLException e) {
			e.printStackTrace();
		}
		}
	}

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

	public void createAccount(Player player){
		if(!hasAccount(player)){
			//INSERT

	       try {
			PreparedStatement q = connection.prepareStatement("INSERT INTO joueurs(uuid,argent,grade) VALUES (?,?,?)");
			q.setString(1, player.getUniqueId().toString());
			q.setInt(2, 1000);
			q.setString(3, "Membre");
			q.execute();
			q.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		}
	}

	public boolean hasAccount(Player player){
		//SELECT

		try {
			PreparedStatement q = connection.prepareStatement("SELECT uuid FROM joueurs WHERE uuid = ?");
			q.setString(1, player.getUniqueId().toString());
			ResultSet resultat = q.executeQuery();
			boolean hasAccount = resultat.next();
			q.close();
			return hasAccount;

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		return false;
	}

	public int getBalance(Player player){
		//SELECT

		try {
			PreparedStatement q = connection.prepareStatement("SELECT uuid FROM joueurs WHERE uuid = ?");
			q.setString(1, player.getUniqueId().toString());

			int balance = 0;
			ResultSet rs = q.executeQuery();

			while(rs.next()){
            	balance = rs.getInt("argent");
            }

			q.close();

			return balance;

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		return 0;
	}

	public void addMoney(Player player, int amount){
		//UPDATE

		int balance = getBalance(player);
		int newbalance = balance + amount;

		try {
			PreparedStatement rs = connection.prepareStatement("UPDATE joueurs SET argent = ? WHERE uuid = ?");
			rs.setInt(1, newbalance);
			rs.setString(2, player.getUniqueId().toString());
			rs.executeUpdate();
			rs.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}

	}

	public void removeMoney(Player player, int amount){
		//UPDATE

		int balance = getBalance(player);
		int newbalance = balance - amount;

		if(newbalance <= 0){
			return;
		}

		try {
			PreparedStatement rs = connection.prepareStatement("UPDATE joueurs SET argent = ? WHERE uuid = ?");
			rs.setInt(1, newbalance);
			rs.setString(2, player.getUniqueId().toString());
			rs.executeUpdate();
			rs.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

}