package org.hyperion.util.sql;

import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.logging.Level;
import java.util.logging.Logger;

public class SQLManager {

    private static String user = "codeusa5_rage",
                    password = "iloveyou",
                    databaseName = "codeusa5_forums",
                    serverAddress = "174.36.60.193";

    private static final Logger logger = Logger.getLogger(SQLManager.class.getName());

    private static String connectionAddress = "jdbc:mysql://"+serverAddress+"/"+databaseName+"?user="+user+"&password="+password;

    public static Connection createConnection() {
        try {
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            logger.log(Level.INFO, "Connecting to SQL Server: "+serverAddress);
            Connection c = DriverManager.getConnection(connectionAddress);
            return c;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    public static ResultSet executeStatement(Connection sqlConnection, String statement) {
        try {
            Statement s = sqlConnection.createStatement();
            if(s.execute(statement)) {
                sqlConnection.close();
                return s.getResultSet();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    public static ResultSet executeQuery(Connection sqlConnection, String statement) {
        try {
            ResultSet s = sqlConnection.createStatement().executeQuery(statement);
            return s;
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }

}