Revision 892efc69
Added by Andreas Kohlbecker almost 14 years ago
cdmlib-io/src/main/java/eu/etaxonomy/cdm/io/berlinModel/in/BerlinModelAuthorTeamImport.java | ||
---|---|---|
43 | 43 |
private static int modCount = 1000; |
44 | 44 |
private static final String pluralString = "AuthorTeams"; |
45 | 45 |
private static final String dbTableName = "AuthorTeam"; |
46 |
|
|
46 |
|
|
47 | 47 |
//TODO pass it in other way, not as a class variable |
48 | 48 |
private ResultSet rsSequence; |
49 | 49 |
private Source source; |
... | ... | |
66 | 66 |
|
67 | 67 |
String strRecordQuery = getRecordQuery(config); |
68 | 68 |
String strQuerySequence = |
69 |
" SELECT * " + |
|
69 |
" SELECT * " +
|
|
70 | 70 |
" FROM AuthorTeamSequence " + |
71 | 71 |
" ORDER By authorTeamFk, Sequence "; |
72 | 72 |
rsSequence = source.getResultSet(strQuerySequence) ; |
73 |
|
|
73 |
|
|
74 | 74 |
int recordsPerTransaction = config.getRecordsPerTransaction(); |
75 | 75 |
try{ |
76 | 76 |
ResultSetPartitioner partitioner = ResultSetPartitioner.NewInstance(source, strIdQuery, strRecordQuery, recordsPerTransaction); |
... | ... | |
163 | 163 |
logger.error("SQLException:" + e); |
164 | 164 |
return false; |
165 | 165 |
} |
166 |
|
|
166 |
|
|
167 | 167 |
//logger.info(i + " " + pluralString + " handled"); |
168 | 168 |
getAgentService().save((Collection)teamsToSave); |
169 | 169 |
|
... | ... | |
229 | 229 |
if (rsSequence.isAfterLast()){ |
230 | 230 |
return true; |
231 | 231 |
} |
232 |
int sequenceTeamFk = rsSequence.getInt("AuthorTeamFk"); |
|
232 |
int sequenceTeamFk; |
|
233 |
try { |
|
234 |
sequenceTeamFk = rsSequence.getInt("AuthorTeamFk"); |
|
235 |
} catch (SQLException e) { |
|
236 |
if (rsSequence.next() == false){ |
|
237 |
return true; |
|
238 |
}else{ |
|
239 |
throw e; |
|
240 |
} |
|
241 |
} |
|
233 | 242 |
while (sequenceTeamFk < teamId){ |
243 |
logger.warn("Sequence team FK is smaller then team ID. Some teams for a sequence may not be available"); |
|
234 | 244 |
rsSequence.next(); |
235 | 245 |
sequenceTeamFk = rsSequence.getInt("AuthorTeamFk"); |
236 | 246 |
} |
... | ... | |
238 | 248 |
int authorFk = rsSequence.getInt("AuthorFk"); |
239 | 249 |
Person author = personMap.get(String.valueOf(authorFk)); |
240 | 250 |
if (author != null){ |
241 |
team.addTeamMember(author);
|
|
251 |
team.addTeamMember(author); |
|
242 | 252 |
}else{ |
243 | 253 |
logger.error("Author " + authorFk + " was not found for team " + teamId); |
244 | 254 |
} |
Also available in: Unified diff
merging /branches/cdmlib/SPRINT-Chichorieae1/ to trunk