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 = "",
					password = "",
					databaseName = "",
					serverAddress = "";

	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;
	}

}