package eu.fantasiacraft.dev.fantasiacraftmaintenance.sql;

import eu.fantasiacraft.dev.fantasiacraftmaintenance.Main;

import java.sql.*;

public class SQL {

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

    public SQL(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 connect(){
        if(!isConnected()){
            try {
                con = DriverManager.getConnection(urlbase+host+"/"+database,user,pass);
                Main.instance.getProxy().getConsole().sendMessage("§8[§3Fantasia§2Craft§6Maintenance§8] §aSQL <-> Plugin");
            }catch (SQLException e){e.printStackTrace();}
        }
    }

    public void disconnect(){
        if(isConnected()){
            try {
                con.close();
                Main.instance.getProxy().getConsole().sendMessage("§8[§3Fantasia§2Craft§6Maintenance§8] §cSQL <-> Plugin");
            }catch (SQLException e){e.printStackTrace();}
        }
    }

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

    public void setServerMaintenance(String serverName, String maintenanceState){
        try{
            PreparedStatement q = con.prepareStatement(
                    "UPDATE serverState SET serverName = ? WHERE serverStatus = ?");
            q.setString(1, serverName);
            q.setString(2, maintenanceState);
            q.executeUpdate();
            q.close();
        }catch (SQLException e){e.printStackTrace();}
    }

    public String getServerMaintenance(String serverName){
        try{
            PreparedStatement q = con.prepareStatement(
                    "SELECT serverStatus FROM serverState WHERE serverName = ?");
            q.setString(1, serverName);

            String server = "";
            ResultSet rs = q.executeQuery();
            while(rs.next()){
                server = rs.getString("serverStatus");
            }
            q.close();
            return server;
        }catch (SQLException e){e.printStackTrace();}
        return "";
    }
}