package net.arcanamc.main.database;

import net.arcanamc.main.Module;
import org.bukkit.plugin.java.JavaPlugin;

import java.sql.*;

/**
 * @author Pyxled
 */
public class SQL extends Module {
    private Connection con;
    private static SQL instance;
    public SQL(JavaPlugin plugin) {
        super("MySQL Module", plugin);
        instance=this;
    }

    @Override
    public void initialize(JavaPlugin plugin) {
        new SQL(plugin);
    }

    public void enable(){
        open();
        createTable("CREATE TABLE IF NOT EXISTS `playerdata` (`UUID` varchar(36) NOT NULL, `rank` text NOT NULL, `level` int(5) UNSIGNED, `exp` int(20), `essence` int(20) UNSIGNED, PRIMARY KEY(`UUID`))");
        createTable("CREATE TABLE IF NOT EXISTS `playerprefs` (`UUID` varchar(36) NOT NULL, `show_players` boolean NOT NULL, `messaging` boolean NOT NULL, `anticheat_messages` boolean NOT NULL, PRIMARY KEY(`UUID`))");
        createTable("CREATE TABLE IF NOT EXISTS `punishments` (ID MEDIUMINT AUTO_INCREMENT, player varchar(36) NOT NULL, staff varchar(36) NOT NULL, reason TEXT NOT NULL, type TEXT NOT NULL, time text NOT NULL, date TEXT NOT NULL, severity TEXT NOT NULL, revoked INT DEFAULT '0', PRIMARY KEY(ID))");
        createTable("CREATE TABLE IF NOT EXISTS `delivery` (ID MEDIUMINT AUTO_INCREMENT, `UUID` varchar(36) NOT NULL, `deliveryName` TEXT NOT NULL, `deliveryType` TEXT NOT NULL, `claimed` boolean NOT NULL, PRIMARY KEY(`ID`))");
    }

    public void disable(){
        close();
    }

    private synchronized void open(){
        try {
            con = DriverManager.getConnection("jdbc:mysql://ip:3306/database", "username", "password");
        } catch (SQLException e) {
            System.out.println("Credentials are indeed invalid.");
        }
    }
    private synchronized void close(){
        try {
            if(!con.isClosed() || con != null){
                con.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    public ResultSet executeQuery(String sql){
        try {
            return getConnection().createStatement().executeQuery(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }
    public synchronized void createTable(String sql){
        try {
            getConnection().createStatement().execute(sql);
        }
        catch (SQLException e){
            e.printStackTrace();
        }
    }
    public PreparedStatement prepareStatement(String sql) {
        try {
            return getConnection().prepareStatement(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }
    private Connection getConnection() {
        return con;
    }
    public static SQL getInstance(){
        return instance;
    }
}