Changeset 1481

Timestamp:

08/18/11 12:25:18 (13 years ago)

Author:

gaba

Message:

pazpar server functionality

Location:

MDService2/trunk/MDService2/src/eu/clarin/cmdi/mdservice/action

Files:

• GenericProxyAction.java (modified) (3 diffs)
• Pz2ProxyAction.java (modified) (5 diffs)

MDService2/trunk/MDService2/src/eu/clarin/cmdi/mdservice/action/GenericProxyAction.java

@@ -523 +523 @@
         }
         
-        public Boolean isSRURepository(){
-                //Boolean issru = false;
-                String typestr = "";
+        public String getRepositoryType(){
+        String typestr = "";
                 
                 if (repositories == null ) {
@@ -548 +547 @@
                         }
                 }
+                
+                return (typestr);
+
+        }
+        public Boolean isSRURepository(){
+                //Boolean issru = false;
+                String typestr = getRepositoryType();
                 
                 return (typestr.equals("sru"));
@@ -594 +600 @@
                 
         }
+        
         
         public void prepare() throws Exception {                

MDService2/trunk/MDService2/src/eu/clarin/cmdi/mdservice/action/Pz2ProxyAction.java

@@ -14 +14 @@
 import javax.xml.parsers.DocumentBuilder;
 import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
 import javax.xml.transform.OutputKeys;
 import javax.xml.transform.Transformer;
@@ -20 +21 @@
 import javax.xml.transform.dom.DOMSource;
 import javax.xml.transform.stream.StreamResult;
+import javax.xml.xpath.XPath;
+import javax.xml.xpath.XPathConstants;
+import javax.xml.xpath.XPathExpression;
+import javax.xml.xpath.XPathExpressionException;
+import javax.xml.xpath.XPathFactory;
 
 import org.w3c.dom.Document;
@@ -25 +31 @@
 import org.w3c.dom.NodeList;
 import org.xml.sax.InputSource;
+import org.xml.sax.SAXException;
 
 import eu.clarin.cmdi.mdservice.model.Query;
@@ -74 +81 @@
                 return block;
         }
+        
+        @Override
+        protected void  initialize(){
+                 super.initialize();
+                 this.setActionkey("pazpar2");                          
+         }
+        
         //TODO cache after analysis
         @Override
@@ -121 +135 @@
         }
         
+
+        @Override
+        public InputStream getSourceStream() throws IOException {
+                if (getCommand().equals("")){
+                        try {
+                                return getSourcePz2();
+                        } catch (Exception e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                        }
+                } 
+                        
+                return super.getSourceStream();
+        }
+        
+        public Document getDocument(InputStream is){
+                Document doc = null;
+                DocumentBuilderFactory docFactory = DocumentBuilderFactory.newInstance();
+        DocumentBuilder docBuilder;
+                try {
+                        docBuilder = docFactory.newDocumentBuilder();
+                        doc = docBuilder.parse(is);
+                } catch (ParserConfigurationException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                } catch (SAXException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                }       
+                return doc;
+        }
+        public String getDocumentData(InputStream is, String expression){
+                String sessionid = "";
+        
+                XPathFactory factory = XPathFactory.newInstance(); 
+            XPath xpath = factory.newXPath(); 
+            XPathExpression expr;
+                try {
+                        expr = xpath.compile(expression);
+                        sessionid = (String) expr.evaluate(getDocument(is), XPathConstants.STRING);
+                } catch (XPathExpressionException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                }
+                        
+                return sessionid;
+                
+        }
+        public InputStream getSourcePz2() throws Exception {
+                
+                InputStream is = null;
+                
+                //init
+                setCommand("init");
+                String sessionID = getDocumentData(this.getSourceStream(), "//init/session");
+                // get result
+                setCommand("search");
+                setSessionID(sessionID);
+                String ok = getDocumentData(this.getSourceStream(),"//search/status");
+                
+                String activeclients = "1";
+                setCommand("show");
+                while (Integer.parseInt(activeclients) > 0){
+                        is = this.getSourceStream();
+                        activeclients = getDocumentData(is, "//show/activeclients");
+                        
+                }
+                return is;
+        }
+
+        
 }