package com.servercontrol.sql;

import com.servercontrol.ServerControl;

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;


    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(ServerControl.getInstance().getConfig().getBoolean("config.lang.fr") == true) {
                    ServerControl.getInstance().getServer().getConsoleSender().sendMessage(
                            ServerControl.getInstance().getConfig().getString("config.messages.fr.server_connected_database"));
                }
            } catch (SQLException e) {e.printStackTrace();}
        }
    }

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

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

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