package serverrmi;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.io.*;
import static java.lang.Thread.sleep;
import java.rmi.*;
import java.rmi.registry.*;
import java.rmi.server.*;
import java.sql.Statement;

public class ServerRMI extends UnicastRemoteObject implements InterfaceRMI {

    static Connection DBConn_Users = null;        // MySQL connection handle
    static Connection DBConn_Inventory = null;    // MySQL connection handle
    static Connection DBConn_Orders = null;       // MySQL connection handle
    static String line = "-----------------------------------------------";

    public ServerRMI() throws RemoteException{
        super();
    }

    public static void main(String[] args) throws RemoteException {
        int PORTRMI = 8000;
        String SQLServerIP = "localhost";

        System.out.println("Arquitectura de Software 2015");
        System.out.println("Server RMI");
        System.out.println(line);

        //--- Connect to Databases
        try {
            System.out.println("Connecting to the database...");
            // Load JDBC driver class for MySQL
            Class.forName("com.mysql.jdbc.Driver");

            // Define the data source
            String sourceURL_Users = "jdbc:mysql://" + SQLServerIP + ":3306/users";
            String sourceURL_Inventory = "jdbc:mysql://" + SQLServerIP + ":3306/inventory";
            String sourceURL_Orders = "jdbc:mysql://" + SQLServerIP + ":3306/orderinfo";

            // Create a connection to the databases
            DBConn_Users = DriverManager.getConnection(sourceURL_Users,"remote","remote_pass");
            System.out.println("Connected to the database \"users\"");
            DBConn_Inventory = DriverManager.getConnection(sourceURL_Inventory,"remote","remote_pass");
            System.out.println("Connected to the database \"inventory\"");
            DBConn_Orders = DriverManager.getConnection(sourceURL_Orders,"remote","remote_pass");
            System.out.println("Connected to the database \"orders\"");
        } catch (Exception e) {
            System.out.println("   ERRO: Couldn't connect to the database!");
            System.out.println("Exiting...");
            return;
        }

        login("admin", "notsafe");

        //--- Create Server RMI
//        System.out.println(line);
//        try {
//            ServerRMI rmi = new ServerRMI();
//            LocateRegistry.createRegistry(PORTRMI);
//            Naming.rebind("rmi://" + SQLServerIP + ":" + PORTRMI + "/AS", rmi);
//            System.out.println("Servidor RMI Criado ( porta " + PORTRMI + " )");
//            System.out.println("Waiting for connection...");
//        }
//        catch (IOException e) {
//            System.out.println("ERRO: Couldn't listen in port " + PORTRMI);
//            System.out.println("Exiting...");
//            return;
//        }
    }

    public void connect() throws RemoteException {
        System.out.println(line);
        System.out.println("New connection established");
        System.out.println(line);
    }

    public static int login(String username, String password) throws RemoteException {

        try {
            Statement stm = DBConn_Users.createStatement();

            // Create Users
//            String sql = "INSERT INTO users (username, password) VALUES ('Staff_Shipping', 'notsafe');";
//            stm.executeUpdate(sql);

            String sql = "SELECT EXISTS (SELECT 1 FROM users WHERE username = '" + username + "' AND password = '" + password + "');";
            ResultSet resultSet = stm.executeQuery(sql);
            resultSet.next();
	    String result = resultSet.getString(1);
            System.out.println(result);
        } catch (Exception e) {
            System.out.println("Erro: " + e + "!");
            return 0;
        }

        // TODO
        System.out.println("[LOGIN] User: " + username);
        // Insert in logs file
        return 1;
    }

    public void logout(String username) throws RemoteException {
        // TODO
        System.out.println("[LOGOUT] User: " + username);
        // Insert in logs file
    }
}