Changeset 8362
- Timestamp:
- 20/06/12 11:40:21 (9 years ago)
- Location:
- mauRepo/MolesManager/trunk/src/libs/migration
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
mauRepo/MolesManager/trunk/src/libs/migration/processor/deployment.py
r8358 r8362 433 433 if not ge: 434 434 ge = extractGeographicExtentInMigrationDocument(self._dataEntityMigration) 435 geographicExtent = createEX_GeographicBoundingBox(ge['east'], ge['north'], ge['west'], ge['south'])436 437 if not self._deploymentHasBeenProcessed:438 observation.geographicExtent.append(geographicExtent)435 if ge: 436 geographicExtent = createEX_GeographicBoundingBox(ge['east'], ge['north'], ge['west'], ge['south']) 437 if not self._deploymentHasBeenProcessed: 438 observation.geographicExtent.append(geographicExtent) 439 439 return 440 440 #Still have to update observation.geographicExtent -
mauRepo/MolesManager/trunk/src/libs/migration/tests/migrationprocess.py
r8358 r8362 36 36 from libs.migration.processor.loadResources import LoadResources 37 37 from libs.migration.db.classes import MigrationObject 38 from libs.migration.processor.commons import DO_BADC, DS_pUBLISHED, DS_PUBLISHED 38 from libs.migration.processor.commons import DO_BADC, DS_pUBLISHED, DS_PUBLISHED,\ 39 DO_NEODC 39 40 from MolesManager.moles3epb import Moles3EPBFactory 40 41 from libs.migration.processor.migrationProcess import MigrationProcess … … 75 76 for e in ex: 76 77 print e 78 79 self.mp = MigrationProcess(self.epbRepo) 77 80 78 def testMigrationProcess(self): 79 mp = MigrationProcess(self.epbRepo) 80 81 dataEntity = MigrationObject() 82 dataEntity.doc_owner = DO_BADC 83 81 def testMigrationProcess(self): 84 82 #dataEntity.doc_status = DS_pUBLISHED 85 83 #dataEntity.doc_name = 'dataent_csip.atom' … … 90 88 91 89 #Has 3 DOI 92 dataEntity.doc_status = DS_pUBLISHED 93 dataEntity.doc_name = 'dataent_chobs.atom' 94 90 self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_chobs.atom') 95 91 96 ex = mp.process(dataEntity) 97 #ex = [] 98 #ex = mp.process() 92 #IASI 93 self.processDataEntity(DO_NEODC, DS_pUBLISHED, 'dataent_12417810458627666.atom') 94 self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_VIRTEM.atom') 95 self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_12162569915925921.atom') 96 97 #ECMWF 98 self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_ECMWF-ERA.atom') 99 self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_ECMWF-OP.atom') 100 self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_12458543158227759.atom') 101 self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_ECMWF-E40.atom') 102 self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_ECMWF-TRJ.atom') 103 104 105 def processDataEntity(self, doc_owner, doc_status, doc_name): 106 dataEntity = MigrationObject() 107 dataEntity.doc_owner = doc_owner 108 dataEntity.doc_status = doc_status 109 dataEntity.doc_name = doc_name 110 ex = self.mp.process(dataEntity) 99 111 for e in ex: 100 112 print e 101 #self._dropAllTables()113 102 114 103 """104 def _dropAllTables(self):105 session = Moles3EPB.getNewMolesSession()106 f = open('dropAllTables.sql', 'r')107 for line in f.readlines():108 stripped = line.strip()109 if len(stripped) > 0:110 Moles3EPB.executeNative(line.strip(), session)111 session.commit()112 session.close()113 """114 115
Note: See TracChangeset
for help on using the changeset viewer.