2 * Copyright (C) 2007 EDIT
3 * European Distributed Institute of Taxonomy
4 * http://www.e-taxonomy.eu
6 * The contents of this file are subject to the Mozilla Public License Version 1.1
7 * See LICENSE.TXT at the top of this package for the full license terms.
10 package eu
.etaxonomy
.cdm
.io
.pesi
.erms
;
12 import java
.sql
.ResultSet
;
13 import java
.sql
.SQLException
;
14 import java
.util
.HashMap
;
15 import java
.util
.HashSet
;
19 import org
.apache
.log4j
.Logger
;
20 import org
.springframework
.stereotype
.Component
;
22 import eu
.etaxonomy
.cdm
.io
.common
.IOValidator
;
23 import eu
.etaxonomy
.cdm
.io
.common
.mapping
.DbImportExtensionCreationMapper
;
24 import eu
.etaxonomy
.cdm
.io
.common
.mapping
.DbImportMapping
;
25 import eu
.etaxonomy
.cdm
.io
.common
.mapping
.DbNotYetImplementedMapper
;
26 import eu
.etaxonomy
.cdm
.io
.pesi
.erms
.validation
.ErmsLinkImportValidator
;
27 import eu
.etaxonomy
.cdm
.model
.common
.CdmBase
;
28 import eu
.etaxonomy
.cdm
.model
.common
.Extension
;
29 import eu
.etaxonomy
.cdm
.model
.common
.ExtensionType
;
30 import eu
.etaxonomy
.cdm
.model
.taxon
.TaxonBase
;
39 public class ErmsLinkImport
extends ErmsImportBase
<TaxonBase
> {
40 private static final Logger logger
= Logger
.getLogger(ErmsLinkImport
.class);
42 private DbImportMapping mapping
;
45 private int modCount
= 10000;
46 private static final String pluralString
= "links";
47 private static final String dbTableName
= "links";
48 private static final Class cdmTargetClass
= Extension
.class;
50 public ErmsLinkImport(){
51 super(pluralString
, dbTableName
, cdmTargetClass
);
56 * @see eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportBase#getRecordQuery(eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportConfigurator)
59 protected String
getRecordQuery(ErmsImportConfigurator config
) {
60 String strRecordQuery
=
63 " WHERE ( links.id IN (" + ID_LIST_TOKEN
+ ") )";
64 return strRecordQuery
;
68 * @see eu.etaxonomy.cdm.io.erms.ErmsImportBase#getMapping()
70 protected DbImportMapping
getMapping() {
72 mapping
= new DbImportMapping();
73 ExtensionType extensionType
= ExtensionType
.URL();
74 //TODO do we need to add to TaxonNameBase too?
75 mapping
.addMapper(DbImportExtensionCreationMapper
.NewInstance("tu_id", ErmsTaxonImport
.TAXON_NAMESPACE
, "link_url", "id", extensionType
));
77 mapping
.addMapper(DbNotYetImplementedMapper
.NewInstance("link_text")); //maybe implement as a second extension ?? but this is ambigous!
78 mapping
.addMapper(DbNotYetImplementedMapper
.NewInstance("link_fn"));
79 mapping
.addMapper(DbNotYetImplementedMapper
.NewInstance("note"));
86 * @see eu.etaxonomy.cdm.io.berlinModel.in.IPartitionedIO#getRelatedObjectsForPartition(java.sql.ResultSet)
88 public Map
<Object
, Map
<String
, ?
extends CdmBase
>> getRelatedObjectsForPartition(ResultSet rs
) {
92 Map
<Object
, Map
<String
, ?
extends CdmBase
>> result
= new HashMap
<Object
, Map
<String
, ?
extends CdmBase
>>();
95 Set
<String
> taxonIdSet
= new HashSet
<String
>();
96 Set
<String
> languageIdSet
= new HashSet
<String
>();
98 handleForeignKey(rs
, taxonIdSet
, "tu_id");
102 nameSpace
= TAXON_NAMESPACE
;
103 cdmClass
= TaxonBase
.class;
105 Map
<String
, TaxonBase
> taxonMap
= (Map
<String
, TaxonBase
>)getCommonService().getSourcedObjectsByIdInSource(cdmClass
, idSet
, nameSpace
);
106 result
.put(nameSpace
, taxonMap
);
108 } catch (SQLException e
) {
109 throw new RuntimeException(e
);
115 * @see eu.etaxonomy.cdm.io.common.CdmIoBase#doCheck(eu.etaxonomy.cdm.io.common.IImportConfigurator)
118 protected boolean doCheck(ErmsImportState state
){
119 IOValidator
<ErmsImportState
> validator
= new ErmsLinkImportValidator();
120 return validator
.validate(state
);
125 * @see eu.etaxonomy.cdm.io.common.CdmIoBase#isIgnore(eu.etaxonomy.cdm.io.common.IImportConfigurator)
127 protected boolean isIgnore(ErmsImportState state
){
128 return ! state
.getConfig().isDoLinks();