- Timestamp:
- 02/07/12 15:15:39 (9 years ago)
- Location:
- mauRepo/MolesManager/trunk/src
- Files:
-
- 6 edited
Legend:
- Unmodified
- Added
- Removed
-
mauRepo/MolesManager/trunk/src/dropAllTables.sql
r8409 r8424 67 67 DROP SEQUENCE IF EXISTS nt_junction_id_seq CASCADE; 68 68 DROP TABLE IF EXISTS angle CASCADE; 69 DROP TABLE IF EXISTS anyCASCADE;69 DROP TABLE IF EXISTS "any" CASCADE; 70 70 DROP TABLE IF EXISTS cc_concatenatedoperation CASCADE; 71 71 DROP TABLE IF EXISTS cc_concatenatedoperation_cc_concatenatedoperation CASCADE; -
mauRepo/MolesManager/trunk/src/libs/migration/MigrationEPB.py
r8336 r8424 109 109 setattr(coll, k, val) 110 110 EPB.persistInstance(coll, self._session) 111 112 def loadAttributes(self, instance, attributes):113 """114 Returns the attribute of an instance. The parameter "attributes" is a single string or a list of attributes115 owned by the instance of "clazz". Furthermore such list may contain116 also the children of the main attributes. For example "attrs" may look117 like118 ['resultAccumulation', 'identifier.authority', 'resultTime.position.dateTime8601.month', \119 'relatedParty.party', 'result.source.function', 'permission', \120 'geographicExtent', 'phenomenonTime', 'keywords', 'description', \121 'inSupportOf.abstract', 'dataLineage']122 the first parameter refers to the main class so is equivalent to123 clazz.resultAccumulation124 the second parameter is equivalent to invoke125 clazz.identifier.authority126 As single string "attributes" could be as well just 'identifier.authority'127 @param instance: an instance containing the appropriate id128 @param attributes: the attribute value required129 @param session: the session to use for the operation130 @return: a detached instance (or array of instances) of the required attribute.131 """132 instance = self._session.merge(instance)133 EPB.loadAttributes(instance, attributes)134 return instance135 111 136 112 def search(self, clazz, inst_id): … … 139 115 ret = EPB.search(clazz, inst_id, self._session) 140 116 return ret 141 -
mauRepo/MolesManager/trunk/src/libs/migration/processor/commons.py
r8416 r8424 77 77 DS_WORKING = 'working' 78 78 DS_PUBLISHED = 'Published' 79 docStatus= (DS_pUBLISHED, DS_WORKING, DS_PUBLISHED)79 DOC_STATUS = (DS_pUBLISHED, DS_WORKING, DS_PUBLISHED) 80 80 81 81 DT_DEPLOYMENTS = 'deployments' … … 83 83 DT_DEPLOYMENT_DATA = 'deployment_data' 84 84 DT_DATA_GRANULES = 'data_granules' 85 docTypes= (DT_DEPLOYMENTS, DT_DATA_ENTITIES, DT_DEPLOYMENT_DATA, DT_DATA_GRANULES)85 DOC_TYPES = (DT_DEPLOYMENTS, DT_DATA_ENTITIES, DT_DEPLOYMENT_DATA, DT_DATA_GRANULES) 86 86 87 87 DO_BADC = 'badc.nerc.ac.uk' -
mauRepo/MolesManager/trunk/src/libs/migration/processor/dataEntity.py
r8423 r8424 47 47 from MolesManager.codelist import MM_ObservationPublicationStateValue,\ 48 48 getCLValue 49 from ea_model.ceda_metadatamodel.ceda_observationcollection.ceda_observationcollection import CEDA_ObservationCollection 50 49 from ea_model.ceda_metadatamodel.ceda_observationcollection.ceda_observationcollection import CEDA_ObservationCollection 51 50 CEDA_TITLE = 'ceda_title' 52 51 -
mauRepo/MolesManager/trunk/src/libs/migration/processor/deployment.py
r8416 r8424 283 283 i_category = getCLValue(CEDA_CurationValue.cl_a) 284 284 if infodb_de and infodb_de.has_key('category') and infodb_de['category']: 285 i_category = CEDA_CurationValue.from_string(infodb_de['category'].lower())285 i_category = getCLValue(CEDA_CurationValue.from_string(infodb_de['category'].lower())) 286 286 287 287 if not self._deploymentHasBeenProcessed: -
mauRepo/MolesManager/trunk/src/libs/migration/processor/loadResources.py
r8358 r8424 31 31 @author: Maurizio Nagni 32 32 ''' 33 from libs.migration.processor.commons import docStatus, getCollectionRefs,\33 from libs.migration.processor.commons import DOC_STATUS, getCollectionRefs,\ 34 34 findMolesCreationDate, findID, stringToTimestamp, buildExistTypePath,\ 35 35 buildExistDocPath, DT_DATA_ENTITIES, DT_DEPLOYMENTS, DT_DEPLOYMENT_DATA,\ 36 getOwnerRefs, getAtomDocumentAsElementtree , getAtomDocumentHash36 getOwnerRefs, getAtomDocumentAsElementtree 37 37 from libs.migration.exception.exceptions import NoCreationDate, NoDocumentID 38 38 from libs.migration.db.classes import DeploymentDataMigration,\ … … 52 52 """ 53 53 ex = [] 54 for status in docStatus:54 for status in DOC_STATUS: 55 55 ex.extend(self._loadCollections(status, DT_DATA_ENTITIES, DataEntityMigration)) 56 56 ex.extend(self._loadCollections(status, DT_DEPLOYMENTS, DeploymentsMigration))
Note: See TracChangeset
for help on using the changeset viewer.