Changeset 29227 for branches/sc_branches/psps_testing/psi/psi_inquisitor.py

Timestamp:

Sep 23, 2010, 3:38:03 PM (16 years ago)

Author:

Serge CHASTEL

Message:

Test report / product

File:

• branches/sc_branches/psps_testing/psi/psi_inquisitor.py (modified) (5 diffs)

branches/sc_branches/psps_testing/psi/psi_inquisitor.py

@@ -2 +2 @@
 from suds.xsd.doctor import Import, ImportDoctor
 from suds import sudsobject
-from utilities.util import convert
+from utilities.util import psi_convert
 import unicodedata
+from utilities.psps_logger import PsPsLogger
+from utilities.test_report import TestReport
 
 class PsiInquisitor:
@@ -24 +26 @@
         # exec 'from %s import Configuration' % configuration_file
         # self.configuration = Configuration
+        PsPsLogger.debug('Creating PsiInquisitor from %s file' % configuration_file)
         self.configuration = __import__(configuration_file, globals(), locals(), 
-                                        ['Configuration'], -1).Configuration
+                                        ['Configuration'], -1).PsiConfiguration
+        TestReport.info('PsiInquisitor created from %s' % configuration_file)
+        TestReport.info(self.configuration.str())
         self.authClient = Client(self.configuration.authUrl)
         self.sessionID = self.authClient.service.login(self.configuration.userID, 
@@ -39 +44 @@
         Make a query in the fast queue.
         
+        >>> psiInquisitor = PsiInquisitor('psi.web01_configuration')
         >>> query = 'select frameID from FrameMeta where frameID=105439;'
-        >>> psiInquisitor = PsiInquisitor('psi.web01_configuration')
         >>> result = psiInquisitor.query(query)
         >>> # we cannot guarantee the order in result
@@ -49 +54 @@
         >>> print result['types']
         {'[frameID]': 'Integer'}
+
+        >>> query = 'select surveyID from FrameMeta where frameID=105439;'
+        >>> result = psiInquisitor.query(query)
+        >>> # we cannot guarantee the order in result
+        >>> print result['items']
+        [{'surveyID': 0}]
+        >>> print result['fields']
+        ['[surveyID]']
+        >>> print result['types']
+        {'[surveyID]': 'Byte'}
+
+        >>> query = 'select cameraID from FrameMeta where frameID=105439;'
+        >>> result = psiInquisitor.query(query)
+        >>> # we cannot guarantee the order in result
+        >>> print result['items']
+        [{'cameraID': 1}]
+        >>> print result['fields']
+        ['[cameraID]']
+        >>> print result['types']
+        {'[cameraID]': 'Integer'}
+        >>> # It should be something expressing that it is a 16-bits integer
+
+        >>> # REAL 4 bytes
+        >>> query = 'select photoScat from FrameMeta where frameID=105439;'
+        >>> result = psiInquisitor.query(query)
+        >>> # we cannot guarantee the order in result
+        >>> print result['items']
+        [{'photoScat': 0.051822260000000002}]
+        >>> print result['fields']
+        ['[photoScat]']
+        >>> print result['types']
+        {'[photoScat]': 'Float'}
+        >>> # There should be sthg to make the difference between f32 and f64
+
+        >>> # FLOAT 8 bytes
+        >>> query = 'select expStart from FrameMeta where frameID=105439;'
+        >>> result = psiInquisitor.query(query)
+        >>> # we cannot guarantee the order in result
+        >>> print result['items']
+        [{'expStart': 55163.4545890027}]
+        >>> print result['fields']
+        ['[expStart]']
+        >>> print result['types']
+        {'[expStart]': 'Float'}
+        >>> # There should be sthg to make the difference between f32 and f64
+
         >>> # This test has to be completed with exhaustive ones...
         >>> # e.g. unit tests against the csr data base.
         """
+        PsPsLogger.debug('Querying PSI: [%s]' % sql_query)
         results = self.jobsClient.service.executeQuickJob(self.sessionID, 
                                                           self.configuration.schemaGroup,
@@ -94 +146 @@
                                                                '').replace(']', 
                                                                            '')
-                    element[field_name] = convert(types_dictionary[contents['fields'][i]],
+                    element[field_name] = psi_convert(types_dictionary[contents['fields'][i]],
                                                   values[i])
                 contents['items'].append(element)
+        PsPsLogger.debug('Number of answers: %d' % len(contents['items']))
         return contents
 
 if __name__ == '__main__':
+    import logging
+    PsPsLogger.set_stderr()
+    PsPsLogger.setLevel(logging.DEBUG)
     import doctest
     doctest.testmod()