package SqlConnection;

/**
 * Created by Sergio on 6/8/2016.
 */

import java.sql.*;
import java.sql.ResultSet;


public class SqlConnection {

    //Ponemos las variables globales dentro de la clase para poder accesarlas

    String strConnectionUrl = "jdbc:sqlserver://localhost:1433;databaseName=Arkus_Test;user=sa;password=7g8hc9trn";
    String strQuery = "SELECT * FROM Mails";
    String strQueryResult = null;

    Connection obj_Conection;
    ResultSet Obj_Rs;

    public SqlConnection(){
        try{
            connectAndMakeQuery();
        }catch(Exception e){}
    }

    public void connectAndMakeQuery() throws SQLException, ClassNotFoundException {
        Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

        obj_Conection = DriverManager.getConnection(strConnectionUrl);
        System.out.println("DB Connected");
        Statement Obj_Sta = obj_Conection.createStatement();
        Obj_Rs = Obj_Sta.executeQuery(strQuery);
    }

    public Entry<String,String> getNextData() {
        if(Obj_Rs.next()){
            return new Abstract.SimpleEntry<String,String>(Obj_Rs.getString("Mail"), Obj_Rs.getString("Password"));
        }
        return null;
    }

    public void close(){
        obj_Conection.close();
    }

//    public String GetValueFromDB() throws SQLException, ClassNotFoundException {
//
//        String strConnectionUrl = "jdbc:sqlserver://localhost:1433;databaseName=Arkus_Test;user=sa;password=7g8hc9trn";
////        String strConnectionUrl = "jdbc:sqlserver://172.20.10.68:1433;databaseName=Arkus_Test;user=ArkusTest;password=Arkus123";
//        String strQuery = "SELECT * FROM Mails";
//        String strQueryResult = null;
//
//        Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
//
//        Connection obj_Conection = DriverManager.getConnection(strConnectionUrl);
//        System.out.println("DB Connected");
//        Statement Obj_Sta = obj_Conection.createStatement();
//        ResultSet Obj_Rs = Obj_Sta.executeQuery(strQuery);
//
//        if (Obj_Rs.next()) {
//            while (Obj_Rs.next()) {
//                System.out.println(Obj_Rs.getString("Mail"));
//                strQueryResult = Obj_Rs.getString("Mail");
//            }
//
//            obj_Conection.close();
//
//        }
//
//
//        return strQueryResult;
//    }
}