Changeset 5416 for TI01-discovery


Ignore:
Timestamp:
25/06/09 11:57:18 (10 years ago)
Author:
sdonegan
Message:

Support extra abstractdocumentingester.py functionality - deletions and updates

File:
1 edited

Legend:

Unmodified
Added
Removed
  • TI01-discovery/branches/ingestAutomation-upgrade/OAIBatch/PostgresDAO.py

    r4854 r5416  
    4848        if dbId: 
    4949            self._record.db_id = dbId[0][0] 
     50             
     51    def getRecordID_using_OriginalDocumentFilename(self): 
     52        ''' 
     53        Looks up a record in the DB and returns its DB ID, if it exists, otherwise  
     54        returns '-1' 
     55        @return: id of record, if it exists, '-1' if it doesn't 
     56        ''' 
     57        logging.info("Looking up original_document_id for filename: " + self._record.filename + " in DB") 
     58         
     59        '''if self._record.db_id is not None and self._record.db_id > 0: 
     60            logging.info("Already looked up record - ID is " + str(self._record.db_id)) 
     61            return self._record.db_id''' 
     62         
     63        sql = "SELECT original_document_id FROM ORIGINAL_DOCUMENT where original_document_filename = '" + self._record.filename + "';" 
     64         
     65        dbId = self.pgc.runSQLCommand(sql) 
     66         
     67        if dbId: 
     68            self._record.db_id = dbId[0][0] 
     69             
     70             
     71    def getDiscoveryID_using_OriginalDocumentFilename(self): 
     72        ''' 
     73        Looks up a record in the DB and returns its discovery ID, if it exists, otherwise  
     74        returns '-1' 
     75        @return: id of record, if it exists, '-1' if it doesn't 
     76        ''' 
     77        logging.info("Looking up discovery_of for filename: " + self._record.filename + " in DB") 
     78         
     79        '''if self._record.db_id is not None and self._record.db_id > 0: 
     80            logging.info("Already looked up record - ID is " + str(self._record.db_id)) 
     81            return self._record.db_id''' 
     82         
     83        sql = "SELECT discovery_id FROM ORIGINAL_DOCUMENT where original_document_filename = '" + self._record.filename + "';" 
     84         
     85        dbId = self.pgc.runSQLCommand(sql) 
     86         
     87        if dbId: 
     88            self._record.discovery_id = dbId[0][0] 
     89             
     90         
     91    def getTemporalDataId(self): 
     92         
     93        ''' 
     94        Looks up the temporal data id using the original document id 
     95        ''' 
     96         
     97        logging.info("Looking up temporal_data_id for filename: " + self._record.filename + " in DB") 
     98         
     99        sql = "SELECT discovery_id FROM ORIGINAL_DOCUMENT where original_document_filename = '" + self._record.filename + "';" 
     100 
     101         
    50102         
    51103 
     
    56108        ''' 
    57109        self.getRecordID() 
    58         if self._record.db_id: 
    59             return self.updateRecord() 
    60         else: 
    61             return self.createRecord() 
     110        returnCode=0 # 0 if failed, 1 if update, 2 if create 
     111         
     112        if self._record.db_id:           
     113            if self.updateRecord(): 
     114                returnCode = 1 
     115        else:             
     116            if self.createRecord(): 
     117                returnCode = 2 
     118                 
     119        return returnCode 
    62120             
    63121 
     
    234292            self._record.discovery_id + "', '" + self._record.docType + "', '" + \ 
    235293            self._record.originalFormat + "', '" + self._record.getAuthorsInfo() + "', '" + \ 
    236             self._record.getParametersInfo() + "', '" + self._record.getScopeInfo() + "');"  
     294            self._record.getParametersInfo() + "', '" + self._record.getScopeInfo() + "', '" + \ 
     295            self._record.dataset_name + "', '" + self._record.datacentre_name + "', '" + self._record.dataset_lastEdit + "');"  
    237296 
    238297        id = self.pgc.runSQLCommand(sqlCmd) 
     
    264323            self._record.discovery_id + "', '" + self._record.docType + "', '" + \ 
    265324            self._record.originalFormat + "', '" + self._record.getAuthorsInfo() + "', '" + \ 
    266             self._record.getParametersInfo() + "', '" + self._record.getScopeInfo() + "', '" + str(self._record.scn) + "');" 
     325            self._record.getParametersInfo() + "', '" + self._record.getScopeInfo() + "', '" + str(self._record.scn) + "', '" + self._record.dataset_name + "', '" + self._record.datacentre_name + "', '" + self._record.dataset_lastEdit +"');" 
     326             
    267327        self.pgc.runSQLCommand(sqlCmd) 
    268328         
    269329        # increment scn - saves doing an additional db call 
    270330        self._record.scn += 1 
     331         
    271332        logging.info("Original document updated in Postgres DB") 
    272333     
Note: See TracChangeset for help on using the changeset viewer.