Changeset 1279 for TI07-MOLES

Timestamp:

04/07/06 17:06:35 (15 years ago)

Author:

lawrence

Message:

Simple python interface to exist now supports
chunked queries, but fails with the glue
version of eXist (although it works with the
newer version on Kev's). This is proof of concept for
replacing the java server side web services if we
can't easily fix them.

File:

• TI07-MOLES/trunk/PythonCode/existInterface/eXistInterface.py (modified) (5 diffs)

TI07-MOLES/trunk/PythonCode/existInterface/eXistInterface.py

@@ -36 +36 @@
                                             constants.xmlrpc_base_path
                                         )
+        print xmlrpc_uri
         self.xmlrpc = xmlrpclib.Server(xmlrpc_uri)
 
@@ -53 +54 @@
         return self.xmlrpc.retrieve(id,pos,params).data
  
-    def executeChunkedQuery(self,query,start,number,params={}):
+    def executeChunkedQuery(self,xquery,start,number,params={}):
         ''' Execute a query, return a specific part of the result set, and
         dump the session automagically '''
-        r=self.xmlrpc.query(query,number,start,params)
+        xquery=xmlrpclib.Binary(xquery)
+        r=self.xmlrpc.query(xquery,number,start,params)
         return r
         
@@ -100 +102 @@
         except xmlrpclib.Fault:
             return None
+        except KeyError:
+            return None
     
     def sessionRelease(self,id):
@@ -110 +114 @@
             return 0
     
-    def chunkedFullText(self,query,target='DIF',start=0,number=10):
+    def chunkedFullText(self,query,target='DIF',start=1,number=10):
         ''' Execute a chunked full text query and return the result
         set '''
@@ -116 +120 @@
     
     
-        
-    
+    def getDIF(self,entryID,):
+        ''' Get a specific DIF document from a repository by using the entryID '''
+        xq='''for $DE in collection('/db/testdif1')/DIF[Entry_ID='%s'] return $DE'''%entryID
+        xquery='''for $DE in collection('/db/testdif1')/DIF[Entry_ID='%s'] return $DE'''%entryID
+        id,summary=self.executeQuery(xq)#xquery)
+        if summary['hits']==1:
+            r=self.retrieve(id,0,{})
+            self.sessionRelease(id)
+        else:
+            r='none'
+        return r
 
 if __name__=="__main__":
     
     existDB=ndg_eXist()
+    gepidaeDB=ndg_eXist(myhost='gepidae.esc.rl.ac.uk')
+    
+    #these both work fine
     id,summary=existDB.full_text('coapec')
-    print summary
+    print 'GLUE:',summary
+    id,summary=gepidaeDB.full_text('coapec')
+    print 'GEPIDAE: ',summary
+    
+    #we can retrieve them all and look at them ...
     r=1
     while r is not None:
         r=existDB.retrieveNext(id)
-        if r is not None: print r
+        #if r is not None: print r
     existDB.release(id)
+    
+    gepidaeDB.release(id)
     print 'done simple'
-    print dir(existDB.xmlrpc)
     
-    print existDB.chunkedFullText('wdcc')
+    #now try and get the DIF documents alone:
+    #works fine: print gepidaeDB.getDIF('badc.nerc.ac.uk:DIF:dataent10')
+    #crashes: print existDB.getDIF('badc.nerc.ac.uk:DIF:dataent10')
+    
+    print 'done getDIF'
+    
+    print existDB.chunkedFullText('badc')