Revision eeba57bc
Added by Andreas Müller over 10 years ago
| app-import/src/main/java/eu/etaxonomy/cdm/io/berlinModel/in/BerlinModelWebMarkerImport.java | ||
|---|---|---|
| 49 | 49 |
super(dbTableName, pluralString); |
| 50 | 50 |
} |
| 51 | 51 |
|
| 52 |
|
|
| 53 |
/* (non-Javadoc) |
|
| 54 |
* @see eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportBase#getIdQuery() |
|
| 55 |
*/ |
|
| 56 | 52 |
@Override |
| 57 | 53 |
protected String getIdQuery(BerlinModelImportState state) {
|
| 58 | 54 |
String result = " SELECT markerId FROM " + getTableName(); |
| ... | ... | |
| 62 | 58 |
return result; |
| 63 | 59 |
} |
| 64 | 60 |
|
| 65 |
/* (non-Javadoc) |
|
| 66 |
* @see eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportBase#getRecordQuery(eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportConfigurator) |
|
| 67 |
*/ |
|
| 68 | 61 |
@Override |
| 69 | 62 |
protected String getRecordQuery(BerlinModelImportConfigurator config) {
|
| 70 | 63 |
String strQuery = |
| ... | ... | |
| 72 | 65 |
" FROM webMarker INNER JOIN webTableName ON webMarker.TableNameFk = webTableName.TableNameId " + |
| 73 | 66 |
" WHERE (markerId IN ("+ ID_LIST_TOKEN + ") )";
|
| 74 | 67 |
return strQuery; |
| 75 |
|
|
| 76 | 68 |
} |
| 77 | 69 |
|
| 78 |
/* (non-Javadoc) |
|
| 79 |
* @see eu.etaxonomy.cdm.io.berlinModel.in.IPartitionedIO#doPartition(eu.etaxonomy.cdm.io.berlinModel.in.ResultSetPartitioner, eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportState) |
|
| 80 |
*/ |
|
| 70 |
@Override |
|
| 81 | 71 |
public boolean doPartition(ResultSetPartitioner partitioner, BerlinModelImportState state) {
|
| 82 | 72 |
boolean success = true ; |
| 83 | 73 |
|
| 84 |
MapWrapper<Taxon> taxonMap = (MapWrapper<Taxon>)state.getStore(ICdmIO.TAXON_STORE);
|
|
| 74 |
Map<String, TaxonBase> taxonMap = (Map<String, TaxonBase>) partitioner.getObjectMap(BerlinModelTaxonImport.NAMESPACE);
|
|
| 85 | 75 |
Set<TaxonBase> taxaToBeSaved = new HashSet<TaxonBase>(); |
| 86 | 76 |
|
| 87 | 77 |
Map<String, DefinedTermBase> definedTermMap = state.getDbCdmDefinedTermMap(); |
| ... | ... | |
| 132 | 122 |
return success; |
| 133 | 123 |
} |
| 134 | 124 |
|
| 135 |
|
|
| 136 |
/* (non-Javadoc) |
|
| 137 |
* @see eu.etaxonomy.cdm.io.berlinModel.in.IPartitionedIO#getRelatedObjectsForPartition(java.sql.ResultSet) |
|
| 138 |
*/ |
|
| 125 |
@Override |
|
| 139 | 126 |
public Map<Object, Map<String, ? extends CdmBase>> getRelatedObjectsForPartition(ResultSet rs) {
|
| 140 | 127 |
String nameSpace; |
| 141 |
Class cdmClass; |
|
| 128 |
Class<?> cdmClass;
|
|
| 142 | 129 |
Set<String> idSet; |
| 143 | 130 |
Map<Object, Map<String, ? extends CdmBase>> result = new HashMap<Object, Map<String, ? extends CdmBase>>(); |
| 144 | 131 |
|
| ... | ... | |
| 151 | 138 |
logger.warn("A marker is not related to table PTaxon. This case is not handled yet!");
|
| 152 | 139 |
}else{
|
| 153 | 140 |
handleForeignKey(rs, taxonIdSet, "RIdentifierFk"); |
| 154 |
} |
|
| 141 |
}
|
|
| 155 | 142 |
} |
| 156 | 143 |
|
| 157 | 144 |
//taxon map |
| ... | ... | |
| 167 | 154 |
return result; |
| 168 | 155 |
} |
| 169 | 156 |
|
| 170 |
|
|
| 171 | 157 |
private boolean addMarker(AnnotatableEntity annotatableEntity, boolean activeFlag, int markerCategoryFk, Map<String, DefinedTermBase> map ){
|
| 172 | 158 |
MarkerType markerType = (MarkerType)map.get("webMarkerCategory_" + markerCategoryFk);
|
| 173 | 159 |
if (markerType == null){
|
| ... | ... | |
| 179 | 165 |
|
| 180 | 166 |
} |
| 181 | 167 |
|
| 182 |
|
|
| 183 |
/* (non-Javadoc) |
|
| 184 |
* @see eu.etaxonomy.cdm.io.common.CdmIoBase#doCheck(eu.etaxonomy.cdm.io.common.IoStateBase) |
|
| 185 |
*/ |
|
| 186 | 168 |
@Override |
| 187 | 169 |
protected boolean doCheck(BerlinModelImportState state){
|
| 188 | 170 |
IOValidator<BerlinModelImportState> validator = new BerlinModelWebMarkerImportValidator(); |
| 189 | 171 |
return validator.validate(state); |
| 190 | 172 |
} |
| 191 | 173 |
|
| 192 |
|
|
| 193 |
/* (non-Javadoc) |
|
| 194 |
* @see eu.etaxonomy.cdm.io.common.CdmIoBase#isIgnore(eu.etaxonomy.cdm.io.common.IImportConfigurator) |
|
| 195 |
*/ |
|
| 174 |
@Override |
|
| 196 | 175 |
protected boolean isIgnore(BerlinModelImportState state){
|
| 197 | 176 |
return ! state.getConfig().isDoMarker(); |
| 198 | 177 |
} |
| 199 |
|
|
| 200 |
|
|
| 201 | 178 |
} |
Also available in: Unified diff
fix WebMarker import for BerlinModel