Print

Print


Author: [log in to unmask]
Date: Fri Aug 28 13:06:10 2015
New Revision: 3443

Log:
Change and correct some crawler CLI arguments.

Modified:
    java/trunk/record-util/src/main/java/org/hps/record/evio/crawler/Crawler.java

Modified: java/trunk/record-util/src/main/java/org/hps/record/evio/crawler/Crawler.java
 =============================================================================
--- java/trunk/record-util/src/main/java/org/hps/record/evio/crawler/Crawler.java	(original)
+++ java/trunk/record-util/src/main/java/org/hps/record/evio/crawler/Crawler.java	Fri Aug 28 13:06:10 2015
@@ -55,8 +55,8 @@
      */
     static {
         OPTIONS.addOption("b", "min-date", true, "min date for a file (example \"2015-03-26 11:28:59\")");
-        OPTIONS.addOption("c", "cache", false, "automatically cache files from MSS to cache disk (JLAB only)");
-        OPTIONS.addOption("C", "connection-properties", true, "database connection properties file (required)");
+        OPTIONS.addOption("C", "cache", false, "automatically cache files from MSS to cache disk (JLAB only)");
+        OPTIONS.addOption("p", "connection-properties", true, "database connection properties file (required)");
         OPTIONS.addOption("d", "directory", true, "root directory to start crawling (default is current dir)");
         OPTIONS.addOption("E", "evio-processor", true, "class name of an EvioEventProcessor to execute");
         OPTIONS.addOption("h", "help", false, "print help and exit (overrides all other arguments)");
@@ -65,8 +65,7 @@
         OPTIONS.addOption("r", "run", true, "add a run number to accept (when used others will be excluded)");
         OPTIONS.addOption("t", "timestamp-file", true, "existing or new timestamp file name");
         OPTIONS.addOption("w", "max-cache-wait", true, "total time to allow for file caching (seconds)");
-        OPTIONS.addOption("u", "update", false,
-                "allow replacement of existing data in the run db (not allowed by default)");
+        OPTIONS.addOption("u", "update", false, "allow replacement of existing data in the run db (off by default)");
         OPTIONS.addOption("x", "max-depth", true, "max depth to crawl in the directory tree");
     }
 
@@ -154,8 +153,8 @@
             }
 
             // Database connection properties file (this is not optional).
-            if (cl.hasOption("C")) {
-                final String dbPropPath = cl.getOptionValue("C");
+            if (cl.hasOption("p")) {
+                final String dbPropPath = cl.getOptionValue("p");
                 final File dbPropFile = new File(dbPropPath);
                 if (!dbPropFile.exists()) {
                     throw new IllegalArgumentException("Connection properties file " + dbPropFile.getPath()
@@ -166,7 +165,7 @@
                 LOGGER.config("using " + dbPropPath + " for db connection properties");
             } else {
                 throw new RuntimeException(
-                        "The -C switch providing the database connection properties file is a required argument.");
+                        "The -p switch providing the database connection properties file is a required argument.");
             }
 
             // Root directory for file crawling.
@@ -221,13 +220,13 @@
             }
 
             // Enable updating of run database.
-            if (cl.hasOption("r")) {
+            if (cl.hasOption("i")) {
                 config.setUpdateRunLog(true);
                 LOGGER.config("inserting into run database is enabled");
             }
 
             // Enable file cache usage for running at JLAB.
-            if (cl.hasOption("c")) {
+            if (cl.hasOption("C")) {
                 config.setUseFileCache(true);
                 LOGGER.config("file cache is enabled");
             }
@@ -352,9 +351,9 @@
      */
     private void updateRunDatabase(final RunSummaryMap runs) throws SQLException {
         // Insert the run information into the database.
-        if (config.updateRunLog()) {
-
-            LOGGER.info("updating run database");
+        if (config.updateRunDatabase()) {
+
+            LOGGER.info("updating run database is enabled");
 
             // Open a DB connection.
             final Connection connection = config.connectionParameters().createConnection();
@@ -371,7 +370,7 @@
             LOGGER.info("done updating run database");
 
         } else {
-            LOGGER.info("run database will not be updated");
+            LOGGER.info("updating run database is not enabled");
         }
     }