package Objects;

import com.microsoft.sqlserver.jdbc.SQLServerDataSource;
import java.sql.*;

public class ConnectMSSQLServer {
    private Connection con = null;

    public ConnectMSSQLServer() {
    }

    public String connect(String serverName, int portNumber, String databaseName, String user, String password) {

        // Create a variable for the connection string.
        // String connectionUrl = "jdbc:sqlserver://localhost:1433;" + "databaseName=AdventureWorks;user=UserName;password=*****";

        try {

            // Register JDBC driver for SQL Server.
            // Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

            // Establish the connection.
            SQLServerDataSource ds = new SQLServerDataSource();

            ds.setServerName(serverName);
            ds.setPortNumber(portNumber);
            ds.setDatabaseName(databaseName);
            ds.setUser(user);
            ds.setPassword(password);

            con = ds.getConnection();
        }
        catch (Exception e) {
            return e.getMessage();
        }
        return null;
    }

    public ResultSet executeSQLStatement(String sql) {
        ResultSet rs = null;

        try {
            Statement statement = con.createStatement();
            rs = statement.executeQuery(sql);
        }
        catch (Exception e) {

        }

        return rs;
    }

}