| gvSIG desktop 1

/*

 * Created on 21-abr-2005

 *

 * TODO To change the template for this generated file go to

 * Window - Preferences - Java - Code Style - Code Templates

 */

package es.gva.cit.catalogClient.protocols;

import java.io.ByteArrayInputStream;

import java.io.InputStream;

import java.net.URL;

import org.apache.commons.httpclient.DefaultMethodRetryHandler;

import org.apache.commons.httpclient.HttpClient;

import org.apache.commons.httpclient.HttpStatus;

import org.apache.commons.httpclient.methods.GetMethod;

import org.w3c.dom.Node;

import es.gva.cit.catalogClient.metadataXML.XMLTree;

/**

 * @author jpiera

 *

 * TODO To change the template for this generated type comment go to

 * Window - Preferences - Java - Code Style - Code Templates

 */

public class HTTPGetProtocol implements IProtocols {

        public Node[] doQuery(URL url,Object object,int firstRecord){

                String parameters = (String)object;                

                InputStream is = null;

                ByteArrayInputStream output = null;

                // Solo devuleve un nodo

                Node[] nodes = new Node[1];

                //        Create an instance of HttpClient.

                HttpClient client = new HttpClient();

                //         Create a method instance.

                GetMethod method = new GetMethod("http://" + url.getHost() + ":" + url.getPort()+ url.getPath() + parameters); 

                System.out.println(parameters);

                // Provide custom retry handler is necessary

                DefaultMethodRetryHandler retryhandler = new DefaultMethodRetryHandler();

                retryhandler.setRequestSentRetryEnabled(false);

                retryhandler.setRetryCount(3);

                method.setMethodRetryHandler(retryhandler);

                //method.setQueryString(parametros);

                //System.out.println(method.getQueryString());

                try{

                        // Execute the method.

                        int statusCode = client.executeMethod(method);

                        //System.out.println("QueryString>>> "+ method.getQueryString());

                        if (statusCode != HttpStatus.SC_OK) {

                                System.err.println("Fallo en el m?todo: " + method.getStatusLine());

                                return null;

                        }

                        // Process the answer

                   is = method.getResponseBodyAsStream();

                   byte[] buffer= new byte[256];

                   String str = new String("");

                   while (true) {

                int n = is.read(buffer);

                if (n < 0)

                  break;

                str = str + new String(buffer, 0, n);

              }

                   is.close();

                   System.out.println(str);

                   if (str.equals(""))

                           output = null;

                        else

                                output = new ByteArrayInputStream(str.getBytes());

                }catch (Exception e) {

                        return null;

                }finally{

                        // Release the connection.

                        method.releaseConnection();

                }

                nodes[0] = XMLTree.XMLToTree(output);

                return nodes;

        }

        public static boolean isProtocolSupported(URL url){

                return true;

        }

}