Revision 2385
Added by Duane Costa almost 20 years ago
| src/edu/ucsb/nceas/metacat/harvesterClient/HarvesterRegistration.java | ||
|---|---|---|
| 98 | 98 |
|
| 99 | 99 |
// Check validity of the Harvest List URL field |
| 100 | 100 |
if (documentListURL.equals("")) {
|
| 101 |
out.println( |
|
| 102 |
"A value must be specified in the Harvest List URL field" |
|
| 103 |
); |
|
| 101 |
out.println("A value must be specified in the Harvest List URL field");
|
|
| 104 | 102 |
validValues = false; |
| 105 | 103 |
} |
| 106 | 104 |
|
| ... | ... | |
| 159 | 157 |
Date dnh; // Date of next harvest |
| 160 | 158 |
Date now; // Today's date |
| 161 | 159 |
String query; |
| 162 |
Statement stmt;
|
|
| 160 |
Statement stmt;
|
|
| 163 | 161 |
long timeNextHarvest; |
| 164 | 162 |
SimpleDateFormat writeFormat = new SimpleDateFormat("dd-MMM-yyyy");
|
| 165 | 163 |
|
| ... | ... | |
| 179 | 177 |
dnh = new Date(timeNextHarvest); |
| 180 | 178 |
dateNextHarvest = writeFormat.format(dnh); |
| 181 | 179 |
|
| 182 |
try {
|
|
| 183 |
stmt = conn.createStatement();
|
|
| 184 |
query = "insert into HARVEST_SITE_SCHEDULE " +
|
|
| 185 |
"(SITE_SCHEDULE_ID, CONTACT_EMAIL, DOCUMENTLISTURL, LDAPDN, LDAPPWD, " + |
|
| 186 |
"UNIT, UPDATEFREQUENCY, DATENEXTHARVEST) " + |
|
| 187 |
"values(" + siteScheduleID + "," +
|
|
| 188 |
quoteString(contactEmail) + "," +
|
|
| 189 |
quoteString(documentListURL) + "," +
|
|
| 190 |
quoteString(ldapDN) + "," +
|
|
| 191 |
quoteString(ldapPwd) + "," +
|
|
| 192 |
quoteString(unit) + "," +
|
|
| 193 |
updateFrequency + "," +
|
|
| 194 |
quoteString(dateNextHarvest) + ")";
|
|
| 180 |
try {
|
|
| 181 |
stmt = conn.createStatement();
|
|
| 182 |
query = "insert into HARVEST_SITE_SCHEDULE " +
|
|
| 183 |
"(SITE_SCHEDULE_ID, CONTACT_EMAIL, DOCUMENTLISTURL, LDAPDN, LDAPPWD, " +
|
|
| 184 |
"UNIT, UPDATEFREQUENCY, DATENEXTHARVEST) " +
|
|
| 185 |
"values(" + siteScheduleID + "," +
|
|
| 186 |
quoteString(contactEmail) + "," + |
|
| 187 |
quoteString(documentListURL) + "," + |
|
| 188 |
quoteString(ldapDN) + "," + |
|
| 189 |
quoteString(ldapPwd) + "," + |
|
| 190 |
quoteString(unit) + "," + |
|
| 191 |
updateFrequency + "," + |
|
| 192 |
quoteString(dateNextHarvest) + ")"; |
|
| 195 | 193 |
|
| 196 | 194 |
System.out.println(query); |
| 197 | 195 |
stmt.executeUpdate(query); |
| 198 |
stmt.close();
|
|
| 196 |
stmt.close();
|
|
| 199 | 197 |
reportResults(out, ldapDN, contactEmail, documentListURL, updateFrequency, |
| 200 | 198 |
unit, dateNextHarvest); |
| 201 |
}
|
|
| 199 |
}
|
|
| 202 | 200 |
catch(SQLException e) {
|
| 203 |
System.out.println("SQLException: " + e.getMessage());
|
|
| 204 |
}
|
|
| 205 |
}
|
|
| 201 |
System.out.println("SQLException: " + e.getMessage());
|
|
| 202 |
} |
|
| 203 |
} |
|
| 206 | 204 |
|
| 207 | 205 |
|
| 208 | 206 |
/** |
| ... | ... | |
| 221 | 219 |
String query = "DELETE FROM HARVEST_SITE_SCHEDULE WHERE " + |
| 222 | 220 |
"SITE_SCHEDULE_ID=" + siteScheduleID; |
| 223 | 221 |
int nRecords = 0; |
| 224 |
Statement stmt;
|
|
| 222 |
Statement stmt; |
|
| 225 | 223 |
|
| 226 |
try {
|
|
| 227 |
stmt = conn.createStatement();
|
|
| 224 |
try {
|
|
| 225 |
stmt = conn.createStatement();
|
|
| 228 | 226 |
System.out.println(query); |
| 229 | 227 |
nRecords = stmt.executeUpdate(query); |
| 230 | 228 |
stmt.close(); |
| ... | ... | |
| 237 | 235 |
out.println("A problem was encountered removing registration for user "
|
| 238 | 236 |
+ ldapDN); |
| 239 | 237 |
} |
| 240 |
}
|
|
| 238 |
}
|
|
| 241 | 239 |
catch(SQLException e) {
|
| 242 |
System.out.println("SQLException: " + e.getMessage());
|
|
| 243 |
}
|
|
| 244 |
}
|
|
| 240 |
System.out.println("SQLException: " + e.getMessage());
|
|
| 241 |
}
|
|
| 242 |
} |
|
| 245 | 243 |
|
| 246 | 244 |
|
| 247 | 245 |
/** |
| ... | ... | |
| 275 | 273 |
Date dlh; // Date of last harvest |
| 276 | 274 |
Date dnh; // Date of next harvest |
| 277 | 275 |
Date now = new Date(); // Today's date |
| 278 |
// SimpleDateFormat readFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.S");
|
|
| 276 |
// SimpleDateFormat readFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.S");
|
|
| 279 | 277 |
SimpleDateFormat readFormat = new SimpleDateFormat("yyyy-MM-dd");
|
| 280 | 278 |
SimpleDateFormat writeFormat = new SimpleDateFormat("dd-MMM-yyyy");
|
| 281 |
Statement stmt;
|
|
| 279 |
Statement stmt;
|
|
| 282 | 280 |
long timeLastHarvest; |
| 283 | 281 |
long timeNextHarvest; |
| 284 | 282 |
long timeNow = now.getTime(); |
| ... | ... | |
| 314 | 312 |
dnh = new Date(timeNextHarvest); |
| 315 | 313 |
dateNextHarvest = writeFormat.format(dnh); |
| 316 | 314 |
|
| 317 |
try {
|
|
| 318 |
stmt = conn.createStatement();
|
|
| 319 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET CONTACT_EMAIL=" +
|
|
| 315 |
try {
|
|
| 316 |
stmt = conn.createStatement();
|
|
| 317 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET CONTACT_EMAIL=" +
|
|
| 320 | 318 |
quoteString(contactEmail) + |
| 321 | 319 |
" WHERE SITE_SCHEDULE_ID = " + siteScheduleID); |
| 322 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET DOCUMENTLISTURL=" +
|
|
| 320 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET DOCUMENTLISTURL=" +
|
|
| 323 | 321 |
quoteString(documentListURL) + |
| 324 | 322 |
" WHERE SITE_SCHEDULE_ID = " + siteScheduleID); |
| 325 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET LDAPPWD=" +
|
|
| 323 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET LDAPPWD=" +
|
|
| 326 | 324 |
quoteString(ldapPwd) + |
| 327 | 325 |
" WHERE SITE_SCHEDULE_ID = " + siteScheduleID); |
| 328 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET UNIT=" +
|
|
| 326 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET UNIT=" +
|
|
| 329 | 327 |
quoteString(unit) + |
| 330 | 328 |
" WHERE SITE_SCHEDULE_ID = " + siteScheduleID); |
| 331 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET UPDATEFREQUENCY=" +
|
|
| 329 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET UPDATEFREQUENCY=" +
|
|
| 332 | 330 |
updateFrequency + |
| 333 | 331 |
" WHERE SITE_SCHEDULE_ID = " + siteScheduleID); |
| 334 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET DATENEXTHARVEST=" +
|
|
| 332 |
stmt.executeUpdate("UPDATE HARVEST_SITE_SCHEDULE SET DATENEXTHARVEST=" +
|
|
| 335 | 333 |
quoteString(dateNextHarvest) + |
| 336 | 334 |
" WHERE SITE_SCHEDULE_ID = " + siteScheduleID); |
| 337 |
stmt.close();
|
|
| 335 |
stmt.close();
|
|
| 338 | 336 |
reportResults(out, ldapDN, contactEmail, documentListURL, updateFrequency, |
| 339 | 337 |
unit, dateNextHarvest); |
| 340 |
}
|
|
| 338 |
}
|
|
| 341 | 339 |
catch(SQLException e) {
|
| 342 |
System.out.println("SQLException: " + e.getMessage());
|
|
| 343 |
}
|
|
| 344 |
|
|
| 340 |
System.out.println("SQLException: " + e.getMessage());
|
|
| 341 |
}
|
|
| 342 |
|
|
| 345 | 343 |
} |
| 346 | 344 |
|
| 347 | 345 |
|
| ... | ... | |
| 365 | 363 |
String ldapPwd; |
| 366 | 364 |
String query; |
| 367 | 365 |
int siteScheduleID; |
| 368 |
Statement stmt;
|
|
| 366 |
Statement stmt;
|
|
| 369 | 367 |
String unit = "days"; |
| 370 | 368 |
int updateFrequency = 1; |
| 371 | 369 |
|
| ... | ... | |
| 389 | 387 |
query = "SELECT * FROM HARVEST_SITE_SCHEDULE WHERE SITE_SCHEDULE_ID=" + |
| 390 | 388 |
siteScheduleID; |
| 391 | 389 |
|
| 392 |
try {
|
|
| 393 |
stmt = conn.createStatement();
|
|
| 394 |
ResultSet rs = stmt.executeQuery(query);
|
|
| 395 |
|
|
| 396 |
while (rs.next()) {
|
|
| 390 |
try {
|
|
| 391 |
stmt = conn.createStatement();
|
|
| 392 |
ResultSet rs = stmt.executeQuery(query);
|
|
| 393 |
|
|
| 394 |
while (rs.next()) {
|
|
| 397 | 395 |
contactEmail = rs.getString("CONTACT_EMAIL");
|
| 398 | 396 |
documentListURL = rs.getString("DOCUMENTLISTURL");
|
| 399 | 397 |
updateFrequency = rs.getInt("UPDATEFREQUENCY");
|
| 400 | 398 |
unit = rs.getString("UNIT");
|
| 401 | 399 |
} |
| 402 |
|
|
| 403 |
stmt.close();
|
|
| 404 |
}
|
|
| 400 |
|
|
| 401 |
stmt.close();
|
|
| 402 |
}
|
|
| 405 | 403 |
catch (SQLException ex) {
|
| 406 |
System.out.println("SQLException: " + ex.getMessage());
|
|
| 407 |
}
|
|
| 404 |
System.out.println("SQLException: " + ex.getMessage());
|
|
| 405 |
}
|
|
| 408 | 406 |
} |
| 409 | 407 |
|
| 410 | 408 |
res.setContentType("text/html");
|
| ... | ... | |
| 635 | 633 |
String dateLastHarvest = ""; |
| 636 | 634 |
String query = "SELECT DATELASTHARVEST FROM HARVEST_SITE_SCHEDULE " + |
| 637 | 635 |
"WHERE SITE_SCHEDULE_ID=" + siteScheduleID; |
| 638 |
Statement stmt;
|
|
| 636 |
Statement stmt; |
|
| 639 | 637 |
|
| 640 |
try {
|
|
| 641 |
stmt = conn.createStatement();
|
|
| 642 |
ResultSet rs = stmt.executeQuery(query);
|
|
| 638 |
try {
|
|
| 639 |
stmt = conn.createStatement();
|
|
| 640 |
ResultSet rs = stmt.executeQuery(query);
|
|
| 643 | 641 |
|
| 644 |
while (rs.next()) {
|
|
| 642 |
while (rs.next()) {
|
|
| 645 | 643 |
dateLastHarvest = rs.getString("DATELASTHARVEST");
|
| 646 | 644 |
if (rs.wasNull()) {
|
| 647 | 645 |
dateLastHarvest = ""; // Convert null value to empty string |
| 648 | 646 |
} |
| 649 |
}
|
|
| 650 |
|
|
| 651 |
stmt.close();
|
|
| 652 |
}
|
|
| 647 |
}
|
|
| 648 |
|
|
| 649 |
stmt.close();
|
|
| 650 |
}
|
|
| 653 | 651 |
catch (SQLException ex) {
|
| 654 |
System.out.println("SQLException: " + ex.getMessage());
|
|
| 655 |
}
|
|
| 652 |
System.out.println("SQLException: " + ex.getMessage());
|
|
| 653 |
}
|
|
| 656 | 654 |
|
| 657 | 655 |
return dateLastHarvest; |
| 658 | 656 |
} |
| ... | ... | |
| 669 | 667 |
private int getMaxValue(Connection conn, String tableName, String fieldName) {
|
| 670 | 668 |
int maxValue = 0; |
| 671 | 669 |
int fieldValue; |
| 672 |
String query = "SELECT " + fieldName + " FROM " + tableName;
|
|
| 673 |
Statement stmt;
|
|
| 670 |
String query = "SELECT " + fieldName + " FROM " + tableName;
|
|
| 671 |
Statement stmt;
|
|
| 674 | 672 |
|
| 675 |
try {
|
|
| 676 |
stmt = conn.createStatement();
|
|
| 677 |
ResultSet rs = stmt.executeQuery(query);
|
|
| 678 |
|
|
| 679 |
while (rs.next()) {
|
|
| 680 |
fieldValue = rs.getInt(fieldName);
|
|
| 673 |
try {
|
|
| 674 |
stmt = conn.createStatement();
|
|
| 675 |
ResultSet rs = stmt.executeQuery(query);
|
|
| 676 |
|
|
| 677 |
while (rs.next()) {
|
|
| 678 |
fieldValue = rs.getInt(fieldName);
|
|
| 681 | 679 |
maxValue = Math.max(maxValue, fieldValue); |
| 682 |
}
|
|
| 683 |
|
|
| 684 |
stmt.close();
|
|
| 685 |
}
|
|
| 680 |
}
|
|
| 681 |
|
|
| 682 |
stmt.close();
|
|
| 683 |
}
|
|
| 686 | 684 |
catch (SQLException ex) {
|
| 687 |
System.out.println("SQLException: " + ex.getMessage());
|
|
| 688 |
}
|
|
| 685 |
System.out.println("SQLException: " + ex.getMessage());
|
|
| 686 |
}
|
|
| 689 | 687 |
|
| 690 | 688 |
return maxValue; |
| 691 | 689 |
} |
| ... | ... | |
| 703 | 701 |
String ldapDNValue; // value of LDAPDN field |
| 704 | 702 |
String query = "SELECT * FROM HARVEST_SITE_SCHEDULE"; |
| 705 | 703 |
int siteScheduleID = 0; |
| 706 |
Statement stmt;
|
|
| 704 |
Statement stmt;
|
|
| 707 | 705 |
|
| 708 |
try {
|
|
| 709 |
stmt = conn.createStatement(); |
|
| 710 |
ResultSet rs = stmt.executeQuery(query); |
|
| 711 |
|
|
| 712 |
while (rs.next()) {
|
|
| 706 |
|
|
| 707 |
try {
|
|
| 708 |
stmt = conn.createStatement(); |
|
| 709 |
ResultSet rs = stmt.executeQuery(query); |
|
| 710 |
|
|
| 711 |
while (rs.next()) {
|
|
| 713 | 712 |
ldapDNValue = rs.getString("LDAPDN");
|
| 714 | 713 |
|
| 715 | 714 |
if (ldapDNValue.equalsIgnoreCase(ldapDN)) {
|
| 716 |
siteScheduleID = rs.getInt("SITE_SCHEDULE_ID");
|
|
| 715 |
siteScheduleID = rs.getInt("SITE_SCHEDULE_ID");
|
|
| 717 | 716 |
} |
| 718 |
}
|
|
| 719 |
|
|
| 720 |
stmt.close();
|
|
| 721 |
}
|
|
| 717 |
}
|
|
| 718 |
|
|
| 719 |
stmt.close();
|
|
| 720 |
}
|
|
| 722 | 721 |
catch (SQLException ex) {
|
| 723 |
System.out.println("SQLException: " + ex.getMessage());
|
|
| 724 |
}
|
|
| 722 |
System.out.println("SQLException: " + ex.getMessage());
|
|
| 723 |
}
|
|
| 725 | 724 |
|
| 726 | 725 |
return siteScheduleID; |
| 727 | 726 |
} |
Also available in: Unified diff
Formatting improvements.