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

Timestamp:

07/31/18 12:07:31 (6 years ago)

Author:

tbretz

Message:

Allow an 'ON DUPLICATE KEY UPDATE' clause

File:

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

trunk/FACT++/src/root2sql.cc

@@ -61 +61 @@
         ("max",            var<int64_t>(int64_t(0)),  "Maximum number of events to process (0: all), mainly for test purpose")
         ("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")
         ;
 
@@ -114 +115 @@
         "\n"
         "Sometimes it might also be convenient to skip a leaf. This can be done with "
-        "the --ignore resource. If the given regular expresion yield a match, the "
-        "leaf will be ignored. Note that the regular expression work on the raw-name "
+        "the --ignore resource. If the given regular expresion yields a match, the "
+        "leaf will be ignored. Note that the regular expression works on the raw-name "
         "of the leaf not the readily mapped SQL column names. Example:\n"
         "   --ignore=ThetaSq\\..*\n"
@@ -144 +145 @@
         "\n"
         "All columns are created as NOT NULL as default and the table is created as "
-        "MyISAM (default).\n"
+        "InnoDB (default).\n"
+        "\n"
+        "Usually, the INSERT query would fail if the PRIMARY key exists already. "
+        "This can be avoided using the 'ON DUPLICATE KEY' directive. With the "
+        "--duplicate,you can specify what should be updated in case of a duplicate key. "
+        "For detaily, see the MySQL manual.\n"
         "\n"
         "For debugging purpose, or to just create or drop a table, the final insert "
@@ -291 +297 @@
 
     const string engine          = conf.Get<string>("engine");
+    const string duplicate       = conf.Get<string>("duplicate");
 
     const bool print_branches    = conf.Get<bool>("print-branches");
@@ -550 +557 @@
                 query += " /* "+c->column+" -> "+c->branch+" */";
         }
-        query += "\n)";  // ON DUPLICATE KEY UPDATE\n";
+        query += "\n)";
 
         count ++;
     }
+
+    if (!duplicate.empty())
+        query += "\nON DUPLICATE KEY UPDATE\n   " + duplicate;
 
     if (verbose>0)
@@ -596 +606 @@
         cout << count << " row(s) inserted.\n\n";
         cout << "Total execution time: " << Time().UnixTime()-start.UnixTime() << "s\n" << endl;
-    }
+/*
+        try
+        {
+            const auto resw =
+                connection.query("SHOW WARNINGS").store();
+
+            if (resw.num_rows()>0)
+                cout << "\nWARNINGS:\n\n";
+
+            for (size_t i=0; i<resw.num_rows(); i++)
+            {
+                const mysqlpp::Row &roww = resw[i];
+
+                cout << roww["Level"] << '[' << roww["Code"] << "]: ";
+                cout << roww["Message"] << '\n' << endl;
+            }
+
+        }
+        catch (const exception &e)
+        {
+            cerr << "\nSHOW WARNINGS\n\n";
+            cerr << "SQL query failed:\n" << e.what() << endl;
+            return 6;
+        }*/
+    }
+
 
     return 0;