diff --git a/src/sql/LogDB.cc b/src/sql/LogDB.cc index 288768b931..6bcc77589f 100644 --- a/src/sql/LogDB.cc +++ b/src/sql/LogDB.cc @@ -330,24 +330,20 @@ int LogDB::insert(uint64_t index, unsigned int term, const std::string& sql, if (replace) { - oss << "UPDATE " << table << " SET " - << "term = " << term << ", " - << "sqlcmd = '" << sql_db << "', " - << "timestamp = " << tstamp << ", " - << "fed_index = " << fed_index << ", " - << "applied = " << applied - << " WHERE log_index = " << index; + oss << "REPLACE"; } else { - oss << "INSERT INTO " << table << " ("<< db_names <<") VALUES (" + oss << "INSERT"; + } + + oss << " INTO " << table << " ("<< db_names <<") VALUES (" << index << "," << term << "," << "'" << sql_db << "'," << tstamp << "," << fed_index << "," << applied << ")"; - } int rc = db->exec_wr(oss);