Changeset 19103 for trunk/FACT++/src/root2sql.cc

Timestamp:

07/31/18 13:48:35 (6 years ago)

Author:

tbretz

Message:

Possibility to add the IGNORE keyword to the INSERT query.

File:

• trunk/FACT++/src/root2sql.cc (modified) (11 diffs)

trunk/FACT++/src/root2sql.cc

@@ -62 +62 @@
         ("engine",         var<string>("InnoDB"),     "Database engine to be used when a new table is created")
         ("duplicate",      var<string>(""),           "Specifies an assignment_list for an 'ON DUPLICATE KEY UPDATE' expression")
+        ("ignore-errors",  po_switch(),               "Adds the IGNORE keyword to the INSERT query (turns errors into warnings, ignores rows with errors)")
         ;
 
@@ -159 +160 @@
         "end.\n"
         "\n"
+        "Another possibility is to add the IGNORE keyword to the INSERT query by "
+        "--ignore-errors, which essentially ignores all errors and turns them into "
+        "warnings which are printed after the query succeeded.\n"
+        "\n"
         "Using a higher verbosity level (-v), an overview of the written columns or all "
         "processed leaves is printed depending on the verbosity level. The output looks "
@@ -301 +306 @@
     const string duplicate       = conf.Get<string>("duplicate");
 
+    const bool ignore_errors     = conf.Get<bool>("ignore-errors");
+
     const bool print_branches    = conf.Get<bool>("print-branches");
     const bool print_leaves      = conf.Get<bool>("print-leaves");
@@ -452 +459 @@
     // Checking for database connection
 
+    Database connection(uri);
+
     try
     {
         if (!force)
-            Database(uri).connected();
+            connection.connected();
     }
     catch (const exception &e)
@@ -485 +494 @@
             // => Simple result
             if (!dry_run)
-                Database(uri).query("DROP TABLE `"+table+"`").execute();
+                connection.query("DROP TABLE `"+table+"`").execute();
             if (verbose>0)
                 cout << "Table `" << table << "` dropped." << endl;
@@ -500 +509 @@
     {
         if (create && !dry_run)
-            Database(uri).query(query).execute();
+            connection.query(query).execute();
     }
     catch (const exception &e)
@@ -521 +530 @@
 
     //query = update ? "UPDATE" : "INSERT";
-    query = "INSERT `"+table+"`\n"
+    query = "INSERT ";
+    if (ignore_errors)
+        query += "IGNORE ";
+    query += "`"+table+"`\n"
         "(\n";
 
@@ -589 +601 @@
         if (!noinsert && !dry_run)
             // => Simple result
-            Database(uri).query(query).execute();
+            connection.query(query).execute();
         else
             cout << "Insert query skipped!" << endl;
@@ -608 +620 @@
         cout << count << " row(s) inserted.\n\n";
         cout << "Total execution time: " << Time().UnixTime()-start.UnixTime() << "s\n" << endl;
-/*
+
         try
         {
@@ -622 +634 @@
 
                 cout << roww["Level"] << '[' << roww["Code"] << "]: ";
-                cout << roww["Message"] << '\n' << endl;
+                cout << roww["Message"] << '\n';
             }
+            cout << endl;
 
         }
@@ -630 +643 @@
             cerr << "\nSHOW WARNINGS\n\n";
             cerr << "SQL query failed:\n" << e.what() << endl;
-            return 6;
-        }*/
-    }
-
+            return 7;
+        }
+    }
 
     return 0;