package org.hyperion.mysql;

import java.sql.*;
import java.util.logging.Logger;

import org.hyperion.Server;

public class Database {
        private static String MySQLURL = "jdbc:mysql://localhost/euroscape";
        private static String MySQLUser = "root";
        private static String MySQLPassword = "hello";
        private static java.sql.Connection conn = null;
        private static Statement statement = null;
        private static final Logger logger = Logger.getLogger(Server.class.getName());

        public static void init(){
            try{
                if(conn == null){
                    Class.forName("com.mysql.jdbc.Driver").newInstance();
                    conn = DriverManager.getConnection(MySQLURL, MySQLUser, MySQLPassword);
                    statement = conn.createStatement();
                } else {
                    conn.close();
                    if(statement != null)
                    statement.close();
                    Class.forName("com.mysql.jdbc.Driver").newInstance();
                    conn = DriverManager.getConnection(MySQLURL, MySQLUser, MySQLPassword);
                    statement = conn.createStatement();
                }
            } catch (Exception e){
                mysql_error(e.getMessage());
            }
        }
        public static boolean mysql_connect(){
            try{
                Class.forName("com.mysql.jdbc.Driver").newInstance();
                conn = DriverManager.getConnection(MySQLURL, MySQLUser, MySQLPassword);
                statement = conn.createStatement();
                return true;
            } catch(Exception e){
                logger.info(e.getMessage());
            }
            return false;
            }
        public static ResultSet ResultSet(String query){
            mysql_connect();
            try{
                return statement.executeQuery(query);
            } catch(Exception e){
                mysql_disconnect();
                mysql_error(e.getMessage());
            }
            return null;
        }
        public static boolean Query(String query){
            mysql_connect();
                try {
                    statement.executeUpdate(query);
                    mysql_disconnect();
                    return true;
                } catch (Exception e) {
                    mysql_disconnect();
                    logger.info("" +e);
                    return false;
                }
        }
        public static void mysql_disconnect(){
            try{
                conn.close();
            } catch(SQLException e){
                mysql_error(e.getMessage());
            }
        }
        public static void mysql_error(String error){
            System.out.println(error);
        }
    }