/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 2108

Added by Duane Costa about 20 years ago

Omit HARVEST_OPERATION_TABLE and store harvest operations in properties file instead

        */
       private static final String marker =
     "*****************************************************************************";
       static Properties properties;
       /*
-...
       /**
        * Loads Harvester properties from a configuration file.
        */
       private static Properties loadProperties() {
       private static void loadProperties() {
         File configfile = new File("../../lib/harvester", "harvester.properties");
         Properties properties = new Properties();
         properties = new Properties();
         try {
           properties.load(new FileInputStream(configfile));
-...
           System.out.println("IOException: " + e.getMessage());
           System.exit(1);
+        }
         return properties;
+      }
-...
         int maxHarvests = maxHarvestsDefault.intValue(); // Max number of harvests
         Integer mh;                              // used in determining max harvests
         int nHarvests = 0;                      // counts the number of harvest runs
         final long oneHour = (60 * 60 * 1000);
         final long oneSecond = 1000;
         final long oneHour = (60 * 60 * 1000);   // milliseconds in one hour
         Integer periodDefault = new Integer(24); // Default hours between harvests
         int period = periodDefault.intValue();   // Hours between harvests
         Integer p;                               // Used in determining the period
         Properties properties;
         long startTime;                          // time that a harvest starts
         long startTime;                          // time that a harvest run starts
         System.out.println(marker);
         System.out.println("Starting Harvester");
         properties = Harvester.loadProperties();
         properties.list(System.out);
         Harvester.loadProperties();
         //properties.list(System.out);
         // Parse the delay property. Use default if necessary.
         try {
-...
           if (nHarvests < maxHarvests) {
             try {
     //          Thread.sleep((period * oneHour) - delta);
               Thread.sleep((period * oneSecond) - delta);
               Thread.sleep((period * oneHour) - delta);
+            }
             catch (InterruptedException e) {
               System.err.println("InterruptedException: " + e.getMessage());
-...
       /** SMTP server for sending mail messages */
       String smtpServer;
       /** The timestamp for this harvest run. Used for output only. */
       String timestamp;
       /*
        * Object methods
-...
         out.println(marker);
         out.println("*");
         out.println("* METACAT HARVESTER REPORT");
         out.println("* METACAT HARVESTER REPORT: " + timestamp);
         out.println("*");
         if (nErrors > 0) {
-...
         String from = harvesterAdministrator;
         MailMessage msg;
         int siteScheduleID = 0;
         String subject = "Report from Metacat Harvester";
         String subject = "Report from Metacat Harvester: " + timestamp;
         String to = harvesterAdministrator;
         if (!to.equals("")) {
-...
         try {
           // Close the database connection
           System.out.println("Closing the database connection");
           conn.close();
+        }
         catch (SQLException e) {
-...
         Properties properties;
         //String response;
         String sessionId;
         String timestamp;
     		String url;
         String user;
         String userName = System.getProperty("user.name");
-...
         // Log startup operation
         System.out.println(Harvester.marker);
         now = new Date();
         timestamp = now.toString() + ": ";
         System.out.println(timestamp + "Starting Next Harvest (" +
         timestamp = now.toString();
         System.out.println(timestamp + ": Starting Next Harvest (" +
                            nHarvests + "/" + maxHarvests + ")");
         properties = loadProperties();
         Harvester.loadProperties();
         properties = Harvester.properties;
         ctm = Boolean.valueOf(properties.getProperty("connectToMetacat", "true"));
         connectToMetacat = ctm.booleanValue();
         dbDriver = properties.getProperty("dbDriver");

     import java.sql.Statement;
     import java.text.SimpleDateFormat;
     import java.util.Date;
     import java.util.Properties;
     import java.util.StringTokenizer;
     /**
-...
         this.siteScheduleID = siteScheduleID;
         harvestOperationCodeLevel =
                 dbGetHarvestOperationCodeLevel(harvestOperationCode);
         explanation = dbGetExplanation(harvestOperationCode);
                 getHarvestOperationCodeLevel(harvestOperationCode);
         explanation = getExplanation(harvestOperationCode);
         dbInsertHarvestLogEntry();   // Insert this entry to the HARVEST_LOG table
+      }
-...
         this.harvestDetailLog = new HarvestDetailLog(harvester, harvestLogID,
                                                      harvestDocument, errorMessage);
         harvestOperationCodeLevel =
                 dbGetHarvestOperationCodeLevel(harvestOperationCode);
         explanation = dbGetExplanation(harvestOperationCode);
                 getHarvestOperationCodeLevel(harvestOperationCode);
         explanation = getExplanation(harvestOperationCode);
         dbInsertHarvestLogEntry();               // Insert to the HARVEST_LOG table
         harvestDetailLog.dbInsertHarvestDetailLogEntry(); // and HARVEST_DETAIL_LOG
+      }
       /**
        * Retrieves the value of the EXPLANATION field of the HARVEST_OPERATION
        * table based on the value of the HARVEST_OPERATION_CODE field.
+       *
        * @param  harvestOperationCode  string value of the harvest operation code
        * @return the explanation for this harvest operation, a String
        */
       String dbGetExplanation(String harvestOperationCode) {
         String explanation;
         String fieldName = "EXPLANATION";
         explanation = dbQueryHarvestOperation(fieldName, harvestOperationCode);
         return explanation;
+      }
       /**
        * Retrieves the value of the HARVEST_OPERATION_CODE_LEVEL field of the
        * HARVEST_OPERATION table based on the value of the HARVEST_OPERATION_CODE
        * field.
+       *
        * @param  harvestOperationCode  string value of the harvest operation code
        * @return the code level value, a String, one of the following:
        *         "error", "warning", "notice", "info", or "debug"
        */
       String dbGetHarvestOperationCodeLevel(String harvestOperationCode) {
         String harvestOperationCodeLevel;
         String fieldName = "HARVEST_OPERATION_CODE_LEVEL";
         harvestOperationCodeLevel =
                 dbQueryHarvestOperation(fieldName, harvestOperationCode);
         return harvestOperationCodeLevel;
+      }
       /**
        * Inserts a new entry into the HARVEST_LOG table, based on the contents of
        * this HarvestLog object. Not yet implemented.
        */
-...
       /**
        * Maps each code level to an integer value.
+       *
        * @param codeLevel        the code level: "error", "warning", "notice",
        *                         "info", or "debug"
        * @return codeLevelValue  the corresponding code level value
        */
       int getCodeLevelValue(String codeLevel) {
         int codeLevelValue = 0;
         if (codeLevel.equalsIgnoreCase("error")) {
           codeLevelValue = 1;
+        }
         else if (codeLevel.equalsIgnoreCase("warning")) {
           codeLevelValue = 2;
+        }
         else if (codeLevel.equalsIgnoreCase("notice")) {
           codeLevelValue = 3;
+        }
         else if (codeLevel.equalsIgnoreCase("info")) {
           codeLevelValue = 4;
+        }
         else if (codeLevel.equalsIgnoreCase("debug")) {
           codeLevelValue = 5;
+        }
         return codeLevelValue;
+      }
       /**
        * Retrieves the value of the EXPLANATION field of the HARVEST_OPERATION
        * table based on the value of the HARVEST_OPERATION_CODE field.
+       *
        * @param  harvestOperationCode  string value of the harvest operation code
        * @return the explanation for this harvest operation, a String
        */
       String getExplanation(String harvestOperationCode) {
         String explanation;
         String fieldName = "EXPLANATION";
         explanation = getHarvestOperation(fieldName, harvestOperationCode);
         return explanation;
+      }
       /**
        * Retrieves the value of the either the EXPLANATION field or the
        * HARVEST_OPERATION_CODE_LEVEL field of the HARVEST_OPERATION table based on
        * the value of the HARVEST_OPERATION_CODE field.
-...
        * @param  harvestOperationCode  string value of the harvest operation code
        * @return the explanation string or the harvestOperationCodeLevel string
        */
       String dbQueryHarvestOperation(String fieldName,
                                      String harvestOperationCode
                                     ) {
       String getHarvestOperation(String fieldName, String harvestOperationCode) {
         String explanation = "No explanation available";
         String harvestOperationCodeLevel = "debug";
         String queryString;
         Properties properties = Harvester.properties;
         String propertyValue;
         String returnString = "";
         ResultSet rs;
         Statement stmt;
         SQLWarning warn;
         StringTokenizer stringTokenizer;
         queryString = "SELECT EXPLANATION, HARVEST_OPERATION_CODE_LEVEL " +
                       "FROM HARVEST_OPERATION " +
                       "WHERE HARVEST_OPERATION_CODE=" +
                       "'" + harvestOperationCode + "'";
         try {                           // Query the HARVEST_OPERATION table
           stmt = harvester.conn.createStatement();
           rs = stmt.executeQuery(queryString);
           warn = rs.getWarnings();
           if (warn != null) {
             System.out.println("\n---Warning---\n");
             while (warn != null) {
               System.out.println("Message: " + warn.getMessage());
               System.out.println("SQLState: " + warn.getSQLState());
               System.out.print("Vendor error code: ");
               System.out.println(warn.getErrorCode());
               System.out.println("");
               warn = warn.getNextWarning();
+            }
+          }
           while (rs.next()) {
             explanation = rs.getString("EXPLANATION");
             harvestOperationCodeLevel = rs.getString("HARVEST_OPERATION_CODE_LEVEL");
             warn = rs.getWarnings();
             if (warn != null) {
               System.out.println("\n---Warning---\n");
               while (warn != null) {
                 System.out.println("Message: " + warn.getMessage());
                 System.out.println("SQLState: " + warn.getSQLState());
                 System.out.print("Vendor error code: ");
                 System.out.println(warn.getErrorCode());
                 System.out.println("");
                 warn = warn.getNextWarning();
+              }
+            }
+          }
           rs.close();
           stmt.close();
+        }
         catch (SQLException e) {
           System.out.println("SQLException: Database access failed: " + e);
+        }
         propertyValue = properties.getProperty(harvestOperationCode);
         stringTokenizer = new StringTokenizer(propertyValue, ",");
         explanation = (String) stringTokenizer.nextElement();
         harvestOperationCodeLevel = (String) stringTokenizer.nextElement();
         if (fieldName.equals("EXPLANATION")) {
           returnString = explanation;
+        }
-...
       /**
        * Maps each code level to an integer value.
        * Retrieves the value of the HARVEST_OPERATION_CODE_LEVEL field of the
        * HARVEST_OPERATION table based on the value of the HARVEST_OPERATION_CODE
        * field.
+       *
        * @param codeLevel        the code level: "error", "warning", "notice",
        *                         "info", or "debug"
        * @return codeLevelValue  the corresponding code level value
        * @param  harvestOperationCode  string value of the harvest operation code
        * @return the code level value, a String, one of the following:
        *         "error", "warning", "notice", "info", or "debug"
        */
       int getCodeLevelValue(String codeLevel) {
         int codeLevelValue = 0;
       String getHarvestOperationCodeLevel(String harvestOperationCode) {
         String harvestOperationCodeLevel;
         String fieldName = "HARVEST_OPERATION_CODE_LEVEL";
         if (codeLevel.equalsIgnoreCase("error")) {
           codeLevelValue = 1;
+        }
         else if (codeLevel.equalsIgnoreCase("warning")) {
           codeLevelValue = 2;
+        }
         else if (codeLevel.equalsIgnoreCase("notice")) {
           codeLevelValue = 3;
+        }
         else if (codeLevel.equalsIgnoreCase("info")) {
           codeLevelValue = 4;
+        }
         else if (codeLevel.equalsIgnoreCase("debug")) {
           codeLevelValue = 5;
+        }
         return codeLevelValue;
         harvestOperationCodeLevel =
                 getHarvestOperation(fieldName, harvestOperationCode);
         return harvestOperationCodeLevel;
+      }

         String maxCodeLevel = "info";
         MailMessage msg;
         int nErrors = 0;
         String subject = "Report from Metacat Harvester";
         String subject = "Report from Metacat Harvester: " + harvester.timestamp;
         String to = contactEmail;
         if (!to.equals("")) {

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 2108

Added by Duane Costa about 20 years ago