WebHCat and knox

[Rachna Jotwani <rj...@dag.com>]

Could someone send me an example of how to authenticate with apache knox  for templeton ?
I tried the example below , but it doesn't work.

Thanks
Rachna


package com.test.hadoop;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.ProtocolException;
import java.net.URL;
import java.sql.Timestamp;
import java.util.Map;
import java.util.logging.Level;
import java.util.logging.Logger;

import org.apache.commons.codec.binary.Base64;

public class TempletonTest {

                private static final String LISTDATABASES = "/database";
                private static final String PACKAGE_NAME = TempletonTest.class
                                                .getPackage().getName();

                /** Logger for this package */
                private static final Logger logger = Logger.getLogger(PACKAGE_NAME);
                public TempletonTest(Map options) {

                                try {
                                                logger.info("EXECUTING TEMPLETON TEST");
                String templetonURL = "https://{gateway-host}:{gateway-port}/gateway/default/templeton/v1/ddl";
                                                String user = "user1";
                                                String password = "user1-password";

                                                String url = templetonURL.replace("ddl", "status");
                                                logger.info("calling url.... " + url);
                                                long start = System.currentTimeMillis();
                                                logger.info("Start Time : " + new Timestamp(start));
                                                String authString = user+":"+password;
                                                byte[] authEncBytes = Base64.encodeBase64(authString.getBytes());
                                                String navigatorAuthStringEncoded = new String(authEncBytes);
                                                StringBuilder response = sendRequestToUrl(url, navigatorAuthStringEncoded);

                                                //print result
                                                logger.info("**************************************");
                                                logger.info(response.toString());
                                                logger.info("**************************************");

                                                url =templetonURL+LISTDATABASES;

                                                logger.info("calling url.... " + url);
                                                start = System.currentTimeMillis();
                                                logger.info("Start Time : " + new Timestamp(start));
                                                response = sendRequestToUrl(url, navigatorAuthStringEncoded);

                                                //print result
                                                logger.info("**************************************");
                                                logger.info(response.toString());
                                                logger.info("**************************************");
                                } catch (Throwable e) {
                                                logger.log(Level.SEVERE,"error executing test\n"+e.getMessage() ,e);
                                }

                }

                private static StringBuilder sendRequestToUrl(String url, String navigatorAuthStringEncoded)
                                                throws MalformedURLException, IOException, ProtocolException {

                                URL obj = new URL(url);
                                HttpURLConnection con = (HttpURLConnection) obj.openConnection();
                                // optional default is GET
                                con.setRequestMethod("GET");
                                //add request header
                                con.setRequestProperty("Content-Type", "application/json");

                                // Adding HTTP Basic Authentication for Navigator
                                con.setRequestProperty("Authorization", "Basic " + navigatorAuthStringEncoded);

                                int responseCode = con.getResponseCode();

                                int length = con.getContentLength();

                                logger.info("\nSending 'GET' request to URL : " + url);
                                logger.info("Response Code : " + responseCode);
                                BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
                                String inputLine;
                                StringBuilder response = new StringBuilder();
                                while ((inputLine = in.readLine()) != null) {
                                                response.append(inputLine);
                                }
                                in.close();
                                return response;
                }
}