" WHERE f.FactCategoryFk = 203 ";\r
if (state.getAlgaTerraConfigurator().isRemoveRestricted()){\r
result = result + " AND df.ProtectedFlag = 0 ";\r
+ logger.warn("DNA with protectedFlag = 0 is currently not imported");\r
}\r
result += " ORDER BY df.DNAFactID ";\r
return result;\r
return strQuery;\r
}\r
\r
- /* (non-Javadoc)\r
- * @see eu.etaxonomy.cdm.io.berlinModel.in.IPartitionedIO#doPartition(eu.etaxonomy.cdm.io.berlinModel.in.ResultSetPartitioner, eu.etaxonomy.cdm.io.berlinModel.in.BerlinModelImportState)\r
- */\r
+ @Override\r
public boolean doPartition(ResultSetPartitioner partitioner, BerlinModelImportState bmState) {\r
boolean success = true;\r
\r
DerivationEvent.NewSimpleInstance(ecoFact, dnaSample, DerivationEventType.DNA_EXTRACTION());\r
samplesToSave.add(ecoFact);\r
}\r
- }\r
- \r
- \r
- \r
+ } \r
}\r
\r
\r
if (sequenceStr == null){\r
logger.warn("PlainSequence is null. Id: " + dnaFactId);\r
}else{\r
- if (sequenceStr.length() != seqLen){\r
+ if (seqLen == null){\r
+ logger.warn("SeqLen is null for dnaFact: " + dnaFactId);\r
+ }else if (sequenceStr.length() != seqLen){\r
logger.warn("SeqLen (" + seqLen+ ") and OriginalLen ("+sequenceStr.length()+") differ for dnaFact: " + dnaFactId);\r
}\r
}\r
}\r
\r
@Override\r
- public Map<Object, Map<String, ? extends CdmBase>> getRelatedObjectsForPartition(ResultSet rs) {\r
+ public Map<Object, Map<String, ? extends CdmBase>> getRelatedObjectsForPartition(ResultSet rs, BerlinModelImportState state) {\r
String nameSpace;\r
Class<?> cdmClass;\r
Set<String> idSet;\r
while (rs.next()){\r
handleForeignKey(rs, taxonIdSet, "taxonId");\r
handleForeignKey(rs, ecoFactFkSet, "ecoFactId");\r
-\r
}\r
\r
//taxon map\r
return validator.validate(state);\r
}\r
\r
-\r
- /* (non-Javadoc)\r
- * @see eu.etaxonomy.cdm.io.common.CdmIoBase#isIgnore(eu.etaxonomy.cdm.io.common.IImportConfigurator)\r
- */\r
+ @Override\r
protected boolean isIgnore(BerlinModelImportState state){\r
return ! ((AlgaTerraImportState)state).getAlgaTerraConfigurator().isDoDna();\r
}\r