package at.fhooe.mc.vis;

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Properties;
import java.util.Vector;

/**
 * The BeerServer. Stores different kinds of beer in a DB and manages them.
 */
public class BeerServer extends UnicastRemoteObject implements RMIBeerInterface {

	private static String USERNAME = "mc";
	private static String PASSWORD = "mc";
	private static String SERVERNAME = "localhost";
	private static String PORT = "3306";
	private static String DBNAME = "beerdb";

	private static final long serialVersionUID = 1L;
	private Connection m_conn;

	/**
	 * Constructor
	 * 
	 * @throws RemoteException
	 */
	protected BeerServer() throws RemoteException {
		super();
		m_conn = null;
		connect();
	}

	protected void connect() {
		Properties connectionProperties = new Properties();
		connectionProperties.put("user", USERNAME);
		connectionProperties.put("password", PASSWORD);

		try {
			Class.forName("com.mysql.jdbc.Driver").newInstance();
		} catch (Exception _e) {
			_e.printStackTrace();
		}

		try {
			// connect
			m_conn = DriverManager.getConnection("jdbc:mysql://" + SERVERNAME
					+ ":" + PORT + "/" + DBNAME, connectionProperties);

		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	/**
	 * Returns a String array containing all BeerType Object's names in the
	 * storage.
	 */
	@Override
	public String[] requestBeerTypes() throws RemoteException {
		Statement stmt;
		String[] output = null;
		Vector<String> buffer = new Vector<String>();
		try {
			stmt = m_conn.createStatement();

			// query db
			ResultSet result = stmt.executeQuery("SELECT name FROM beers");

			// process result
			while (result.next()) {
				buffer.add(result.getString(1));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return buffer.toArray(new String[buffer.size()]);
	}

	/**
	 * Returns how many crates of the requested BeerType are available.
	 */
	@Override
	public int requestContingent(String _type) throws RemoteException {
		int output = -1;
		Statement stmt;
		try {
			stmt = m_conn.createStatement();

			// query db
			ResultSet result = stmt
					.executeQuery("SELECT amount FROM beers WHERE name = \""
							+ _type + "\"");
			result.next();
			output = result.getInt(1);

		} catch (SQLException e) {
			e.printStackTrace();
		}
		return output;
	}

	/**
	 * Returns the price of the requested BeerType.
	 */
	@Override
	public double requestPrice(String _type) throws RemoteException {
		float output = (float) -1.0;
		Statement stmt;
		try {
			stmt = m_conn.createStatement();

			// query db
			ResultSet result = stmt
					.executeQuery("SELECT price FROM beers WHERE name = \""
							+ _type + "\"");
			result.next();
			output = result.getFloat(1);

		} catch (SQLException e) {
			e.printStackTrace();
		}
		return output;
	}

	public void close() {
		try {
			m_conn.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	/**
	 * Fills the Server with some data.
	 */
	/*
	 * private void createDummyData() { addBeer(new BeerType("Stiegl", 20,
	 * (float) 15.3)); addBeer(new BeerType("Freistaedter", 10, (float) 12.3));
	 * addBeer(new BeerType("Zwettler", 15, (float) 14.3)); addBeer(new
	 * BeerType("Ottakringer", 20, (float) 13.3)); addBeer(new
	 * BeerType("Zipfer", 18, (float) 16.3));
	 * 
	 * }
	 */
}