package utils;

import java.sql.*;

public class MySQL {


        public static String host = "localhost";
        public static String port = "3306";
        public static String database = "plugintest";
        public static String username = "root";
        public static String password = "puX8ABIYj6IQwN7n";
        public static Connection con;

        public static void connect() {
            if (!isConnected()) {
                try {
                    con = DriverManager.getConnection("jdbc:mysql://"
                            + host +
                            ":"
                            + port
                            + "/" +
                            database, username, password);
                    System.out.println("[MySQL] Verbindung aufgebaut!");
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

        }

        public static void disconnect() {
            if (isConnected()) {
                try {
                    con.close();
                    System.out.println("[MySQL] Verbindung getrennt!");
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }

        public static boolean isConnected() {
            return (con == null ? false : true);

        }

        public static void update(String qry) {
            try {
                PreparedStatement ps = con.prepareStatement(qry);
                ps.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        public static ResultSet getResult(String qry) {
            try {
                PreparedStatement ps = con.prepareStatement(qry);
                return ps.executeQuery();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            return null;


        }

        public static ResultSet query(String qry) {
            ResultSet rs = null;

            try {
                Statement st = con.createStatement();
                rs = st.executeQuery(qry);
            } catch (SQLException e) {
                connect();
                System.err.println(e);
            }
            return rs;
        }


}