Application: gvSIG desktop

        package es.gva.cit.catalogClient.drivers;

import java.net.URL;

import java.util.StringTokenizer;

import org.apache.commons.httpclient.NameValuePair;

import org.w3c.dom.Node;

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

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

import es.gva.cit.catalogClient.protocols.HTTPGetProtocol;

import es.gva.cit.catalogClient.protocols.HTTPPostProtocol;

import es.gva.cit.catalogClient.protocols.SOAPProtocol;

import es.gva.cit.catalogClient.querys.Query;

import es.gva.cit.catalogClient.querys.SRWQuery;

/* Generated by Together */

public class SRWCatalogServiceDriver extends AbstractCatalogServiceDriver {

    private String version = "1.1";

        private String recordXPath;

    private String resultSetTTL;

        /* (non-Javadoc)

         * @see ICatalogServerDriver#GetCapabilities(java.lang.String, java.lang.String)

        */

    public Node[] getCapabilities(URL url){

            Node[] nodos = new HTTPGetProtocol().doQuery(url,getMessageCapabilities(),0);

                if (nodos != null){

                        setCommunicationProtocol("GET");

                        return nodos;

                }

                nodos = new HTTPPostProtocol().doQuery(url,getMessageCapabilities(),0);

                if (nodos != null){

                        setCommunicationProtocol("POST");

                        return nodos;

                }

                nodos = new SOAPProtocol().doQuery(url,getSOAPMessageCapabilities(),0);

                if (nodos != null){

                        setCommunicationProtocol("SOAP");

                }

                return nodos;

    }

        /* (non-Javadoc)

         * @see ICatalogServerDriver#GetRecords(java.lang.String, java.lang.String, java.lang.String, int, int, java.lang.String, java.lang.String)

         */

        public Node[] getRecords(URL url ,Query query, int firstRecord) {

                setQuery(query);

                Node[] answerNodes = null;

                Node[] nodes = null;

                if (getCommunicationProtocol().equals("GET"))                

                        nodes = new HTTPGetProtocol().doQuery(url,getMessageRecords(getQuery(),firstRecord),firstRecord);

                if (getCommunicationProtocol().equals("POST"))                

                        nodes = new HTTPPostProtocol().doQuery(url,getMessageRecords(getQuery(),firstRecord),firstRecord);

                if (getCommunicationProtocol().equals("SOAP"))                

                        nodes = new SOAPProtocol().doQuery(url,getMessageRecords(getQuery(),firstRecord),firstRecord);

                String prefix = new StringTokenizer(nodes[0].getNodeName(),":").nextToken();

                if (prefix.equals(nodes[0].getNodeName()))

                        prefix = "";

                else                

                        prefix = prefix + ":";                

                //Hay que capturar la excepci?n. 

                int numberOfRecords = Integer.parseInt(XMLTree.searchNodeValue(nodes[0],prefix + "numberOfRecords"));

                if (numberOfRecords > 10)

                        answerNodes = new Node[11];

                else

                        answerNodes = new Node[numberOfRecords + 1];

                answerNodes[0] = XMLTreeNumberOfRecordsAnswer.getNode(numberOfRecords,

                                firstRecord,

                                firstRecord + numberOfRecords );

                nodes = XMLTree.searchMultipleNode(nodes[0],prefix + "records->" + prefix + "record");

                for (int i = 1; (i <= numberOfRecords) && (i <= 10) ; i++)

                        answerNodes[i] = nodes[i-1];

                return answerNodes;

        }

        public NameValuePair[] getMessageCapabilities(){

                NameValuePair nvp1= new NameValuePair("OPERATION","explain");

                NameValuePair nvp2= new NameValuePair("VERSION",this.version);

                return new NameValuePair[]{nvp1,nvp2};

        }

        public NameValuePair[] getMessageRecords(Query query,int firstRecord){

                SRWQuery qsrwd = new SRWQuery(query); 

                NameValuePair nvp1= new NameValuePair("operation","searchRetrieve");

                NameValuePair nvp2= new NameValuePair("version",this.version);

                NameValuePair nvp3= new NameValuePair("query",qsrwd.getQuery());

                NameValuePair nvp4= new NameValuePair("maximumRecords","10");

                NameValuePair nvp5= new NameValuePair("recordPacking",getOutputFormat() );

                NameValuePair nvp6= new NameValuePair("startRecord",new String(new Integer(firstRecord).toString()));

                return new NameValuePair[]{nvp1,nvp2,nvp3,nvp4,nvp5,nvp6};

        }

        public String getSOAPMessageCapabilities(){

                String soapMessage = "<SOAP:Envelope xmlns:SOAP=\"http://schemas.xmlsoap.org/soap/envelope/\">" +

                                                "<SOAP:Body><SRW:explainRequest xmlns:SRW=\"http://www.loc.gov/zing/srw/\">" +

                                                "<SRW:version>" + version + "</SRW:version>" +

                                                "</SRW:explainRequest>" +

                                                "</SOAP:Body>" +

                                                "</SOAP:Envelope>";

                return soapMessage;

        }

        public String getSOAPMessageRecords(Query query){

           SRWQuery qsrwd = new SRWQuery(query); 

           String soapMessage = "<soap:Envelope xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"> <soap:Body>" +

                          "<srw:searchRetrieveRequest xmlns:srw=\"http://www.loc.gov/zing/srw/\">" + 

                            "<srw:query><![CDATA[" + qsrwd.getQuery() + "]]></srw:query>" +

                            "<srw:sortKeys xsi:nil=\"true\"/>" +

                            "<srw:startRecord>" + getStartPosition()  + "</srw:startRecord>" +

                            "<srw:maximumRecords>" + getMaxRecords() + "</srw:maximumRecords>" + 

                            "<srw:recordPacking>" + getOutputFormat() + "</srw:recordPacking>" + 

                            "<srw:recordSchema>" + getOutputSchema()[0] + "</srw:recordSchema>" + 

                            "<srw:resultSetTTL>" + getResultSetTTL() + "</srw:resultSetTTL>" + 

                          "</srw:searchRetrieveRequest>" +

                        "</soap:Body></soap:Envelope>";

           return soapMessage;

        }

        /**

         * @return Returns the recordXPath.

         */

        public String getRecordXPath() {

                return recordXPath;

        }

        /**

         * @param recordXPath The recordXPath to set.

         */

        public void setRecordXPath(String recordXPath) {

                this.recordXPath = recordXPath;

        }

        /**

         * @return Returns the resultSetTTL.

         */

        public String getResultSetTTL() {

                return resultSetTTL;

        }

        /**

         * @param resultSetTTL The resultSetTTL to set.

         */

        public void setResultSetTTL(String resultSetTTL) {

                this.resultSetTTL = resultSetTTL;

        }

        /**

         * @return Returns the version.

         */

        public String getVersion() {

                return version;

        }

        /**

         * @param version The version to set.

         */

        public void setVersion(String version) {

                this.version = version;

        }

        /* (non-Javadoc)

         * @see catalogClient.ICatalogServerDriver#ServerReady(java.lang.String, int)

         */

        /* (non-Javadoc)

         * @see catalogClient.ICatalogServerDriver#setParameters(java.util.Properties)

         */

        public boolean setParameters(Node[] nodes) {

                if (nodes[0].getNodeName() != null){

                        String prefix = new StringTokenizer(nodes[0].getNodeName(),":").nextToken();

                        prefix = prefix + ":";

                        this.setOutputSchema(XMLTree.searchNodeValue(nodes[0],prefix + "record->" + prefix + "recordSchema"));

                        this.setOutputFormat(XMLTree.searchNodeValue(nodes[0],prefix + "record->" + prefix + "recordPacking"));

                        this.setStartPosition("1");

                        this.setMaxRecords("10");

                        this.setRecordXPath("");

                        this.setResultSetTTL("0");

                        this.setServerAnswerReady("Titulo: " +

                                        XMLTree.searchNodeValue(nodes[0],prefix + "record->" + prefix + "recordData->explain->databaseInfo->title") +

                                "\nDescripcion: " +

                                XMLTree.searchNodeValue(nodes[0],prefix + "record->" + prefix + "recordData->explain->databaseInfo->description")

                        );

                }

                return true;

        }

        /* (non-Javadoc)

         * @see es.gva.cit.catalogClient.drivers.ICatalogServiveDriver#isTheProtocol(java.net.URL)

         */

        public boolean isProtocolSupported(URL url) {

                return SOAPProtocol.isProtocolSupported(url);

        }

}