package nl.dusdavidgames.test;

import com.zaxxer.hikari.HikariDataSource;
import org.bukkit.Bukkit;
import org.bukkit.configuration.file.YamlConfiguration;

import java.io.File;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

/**
 * Created by michi on 27/02/2017.
 */
public class DatabaseManager {

    private static String USERNAME;
    private static String PASSWORD;
    private static String DB_URL;
    private static String DB_NAME;

    public static HikariDataSource datasource;

    public static HikariDataSource getDatasource() {
        return datasource;
    }

    public static DatabaseManager instance;

    public static DatabaseManager getInstance() {
        return instance;
    }

    public DatabaseManager() {
        try{
            openConnection();
        } catch (Exception e){
            e.printStackTrace();
        }

    }

    public void openConnection() {
        /*
            database:
              username: root
              isolation: REPEATABLEREAD
              driver: com.mysql.jdbc.Driver
              password: Pidiboe002
              url: jdbc:mysql://localhost:3306/test
              name: test
                 */

        YamlConfiguration bukkitYml = YamlConfiguration.loadConfiguration(new File(Bukkit.getWorldContainer().getAbsoluteFile(), "bukkit.yml"));

        USERNAME = bukkitYml.getString("database.username");
        PASSWORD = bukkitYml.getString("database.password");
        DB_URL = bukkitYml.getString("database.url");
        DB_NAME = bukkitYml.getString("database.name");

        datasource = new HikariDataSource();

        datasource.setMaximumPoolSize(10);
        datasource.setDataSourceClassName("com.mysql.jdbc.jdbc2.optional.MysqlDataSource");
        datasource.addDataSourceProperty("serverName", DB_URL);
        datasource.addDataSourceProperty("port", 3306);
        try {
            datasource.addDataSourceProperty("databaseName", DB_NAME);
        } catch (NullPointerException e) {

        }
        datasource.addDataSourceProperty("user", USERNAME);
        datasource.addDataSourceProperty("password", PASSWORD);
    }

    public void closeConnection() {
        if (datasource != null)
            datasource.close();
        if (datasource == null)
            Messages.getInstance().info("Datascoure was not closed!");
    }

    public void insertQuery(String query) throws Exception {
        Connection connection = null;
        PreparedStatement pStatement = null;

        try {
            connection = datasource.getConnection();
            pStatement = connection.prepareStatement(query);
            pStatement.execute();
        } catch (Exception e) {
            e.printStackTrace();
            Messages.getInstance().info("Something went wrong on inserting Query @ DatabaseManager:insertQuery");
        } finally {
            try {
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException ex) {
                Messages.getInstance().info("Couldn't close DB Connection");
            }
            try {
                if (pStatement != null) {
                    pStatement.close();
                }
            } catch (SQLException ex) {
                Messages.getInstance().info("Couldn't close DB PreparedStatement");
            }
        }
    }
}