package com.servercontrol.sql;

import com.servercontrol.ServerControl;
import org.bukkit.Bukkit;
import org.bukkit.configuration.file.FileConfiguration;

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

public class SqlConnection {

    private Connection con;
    private String urlbase,host,database,user,password;
    FileConfiguration config = ServerControl.getInstance().getConfig();


    public SqlConnection(String urlbase, String host, String database, String user, String password){
        this.urlbase = urlbase;
        this.host = host;
        this.database = database;
        this.user = user;
        this.password = password;
    }

    public void connect(){
        if(!isConnected()) {
            try {
                con = DriverManager.getConnection(urlbase + host + "/" + database, user, password);

                    if(config.getBoolean("config.lang.fr", true)){
                        Bukkit.getConsoleSender().sendMessage(config.getString("config.messages.fr.server_connected_database")
                                .replace("&", "§"));
                    }

                    if(config.getBoolean("config.lang.en", true)){
                        Bukkit.getConsoleSender().sendMessage(config.getString("config.messages.en.server_connected_database")
                                .replace("&", "§"));
                    }

            } catch (SQLException e) {e.printStackTrace();}
        }
    }

    public void disconnect(){
        if(isConnected()) {
            try {
                con.close();

                if(config.getBoolean("config.lang.fr", true)){
                    Bukkit.getConsoleSender().sendMessage(config.getString("config.messages.fr.server_disconnected_database")
                            .replace("&", "§"));
                }

                if(config.getBoolean("config.lang.en", true)){
                    Bukkit.getConsoleSender().sendMessage(config.getString("config.messages.en.server_disconnected_database")
                            .replace("&", "§"));
                }

            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

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