package me.chocho.points;

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;
import org.bukkit.plugin.java.JavaPlugin;

public class PointsAPI
  extends JavaPlugin
{
  private static String HOST = "localhost";
  private static String DATABASE = "minecraft";
  private static String USER = "root";
  private static String PORT = "3306";
  private static String PASSWORD = "rDTFRaR7T3%y2py6W_!6";
  private static Connection con;

  public void onEnable() {}

  public static Connection getConnection()
  {
    return con;
  }

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

  public static void connect()
  {
    if (!isConnected()) {
      try
      {
        con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":" + PORT + "/" + DATABASE + "?autoReconnect=true", USER, PASSWORD);
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

  public static void disconnect()
  {
    if (isConnected()) {
      try
      {
        con.close();
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

  public static Integer getPoints(String playername)
  {
    try
    {
      PreparedStatement ps = con.prepareStatement("SELECT * FROM Points WHERE Spielername= ?");
      ps.setString(1, playername);
      ResultSet rs = ps.executeQuery();
      rs.next();
      int points = rs.getInt("Punkte");
      rs.close();
      ps.close();
      return Integer.valueOf(points);
    }
    catch (SQLException e)
    {
      e.printStackTrace();
    }
    return Integer.valueOf(-1);
  }

  public static Integer setPoints(Player p, int points)
  {
    try
    {
      PreparedStatement ps = con.prepareStatement("UPDATE Points SET Punkte= ? WHERE Spielername= ?");
      ps.setInt(1, points);
      ps.setString(2, p.getName());
      ps.executeUpdate();
      ps.close();
    }
    catch (SQLException e)
    {
      e.printStackTrace();
    }
    return Integer.valueOf(-1);
  }

  public static void addPoints(Player p, Integer points)
  {
    try
    {
      PreparedStatement ps = con.prepareStatement("UPDATE Points SET Punkte= ? WHERE Spielername= ?");
      ps.setInt(1, getPoints(p.getName()).intValue() + points.intValue());
      ps.setString(2, p.getName());
      ps.executeUpdate();
      ps.close();
    }
    catch (Exception e)
    {
      e.printStackTrace();
    }
  }
}

//MAIN

package me.chocho.points;

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;
import org.bukkit.plugin.java.JavaPlugin;

public class PointsAPI extends JavaPlugin {

	@Override
	public void onEnable() {
		connect();
	}

	private static String HOST = "localhost";
    private static String DATABASE = "minecraft";
    private static String USER = "root";
    private static String PORT = "3306";
    private static String PASSWORD = "rDTFRaR7T3%y2py6W_!6";

    private static Connection con;


    public static Connection getConnection() {
		return con;
	}
	public static boolean isConnected() {
		return con != null;
	}

	public static void connect() {
		if(!isConnected()) {
			try {
				con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":" + PORT + "/" + DATABASE + "?autoReconnect=true", USER, PASSWORD);
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public static void disconnect() {
		if(isConnected()) {
			try {
				con.close();
			} catch(SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public static Integer getPoints(String playername){
    	try {
			PreparedStatement ps = con.prepareStatement("SELECT * FROM Points WHERE Spielername= ?");
			ps.setString(1, playername);
			ResultSet rs = ps.executeQuery();
			rs.next();
			int points = rs.getInt("Punkte");
			rs.close();
			ps.close();
			return points;
		} catch (SQLException e) {
			e.printStackTrace();
		}
    	return -1;
    }

	public static Integer setPoints(Player p, int points){
    	try {
    		PreparedStatement ps = con.prepareStatement("UPDATE Points SET Punkte= ? WHERE Spielername= ?");
			ps.setInt(1, points);
			ps.setString(2, p.getName());
			ps.executeUpdate();
			ps.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
    	return -1;
    }

	public static void addPoints(Player p, Integer points) {
		try {
			PreparedStatement ps = con.prepareStatement("UPDATE Points SET Punkte= ? WHERE Spielername= ?");
			ps.setInt(1, getPoints(p.getName()) + points);
			ps.setString(2, p.getName());
			ps.executeUpdate();
			ps.close();
		}catch(Exception e) {
			e.printStackTrace();
		}
	}

}