Revision 4d0649fd
Added by Andreas Müller over 5 years ago
| cdm-pesi/src/main/java/eu/etaxonomy/cdm/io/pesi/erms/ErmsImportBase.java | ||
|---|---|---|
| 115 | 115 |
} |
| 116 | 116 |
|
| 117 | 117 |
@Override |
| 118 |
public boolean doPartition(ResultSetPartitioner partitioner, ErmsImportState state) {
|
|
| 118 |
public boolean doPartition(@SuppressWarnings("rawtypes") ResultSetPartitioner partitioner, ErmsImportState state) {
|
|
| 119 | 119 |
boolean success = true ; |
| 120 | 120 |
Set<CdmBase> objectsToSave = new HashSet<>(); |
| 121 | 121 |
|
| ... | ... | |
| 125 | 125 |
ResultSet rs = partitioner.getResultSet(); |
| 126 | 126 |
try{
|
| 127 | 127 |
while (rs.next()){
|
| 128 |
success &= mapping.invoke(rs,objectsToSave); |
|
| 128 |
success &= mapping.invoke(rs, objectsToSave);
|
|
| 129 | 129 |
} |
| 130 | 130 |
} catch (SQLException e) {
|
| 131 | 131 |
logger.error("SQLException:" + e);
|
| ... | ... | |
| 137 | 137 |
return success; |
| 138 | 138 |
} |
| 139 | 139 |
|
| 140 |
|
|
| 141 |
|
|
| 142 | 140 |
/** |
| 143 | 141 |
* @return |
| 144 | 142 |
*/ |
Also available in: Unified diff
ref #1444 further cleanup ERMS import