remove exec sql function from db_copy class

Author: lonvia

db-copy.cpp

@@ -73,9 +73,6 @@ void db_copy_thread_t::worker_thread()
             case db_cmd_t::Cmd_copy:
                 write_to_db(static_cast<db_cmd_copy_t *>(item.get()));
                 break;
-            case db_cmd_t::Cmd_sql:
-                execute_sql(static_cast<db_cmd_sql_t *>(item.get())->buffer);
-                break;
             case db_cmd_t::Cmd_sync:
                 finish_copy();
                 static_cast<db_cmd_sync_t *>(item.get())->barrier.set_value();
@@ -107,13 +104,6 @@ void db_copy_thread_t::connect()
                       "SET synchronous_commit TO off;");
 }
 
-void db_copy_thread_t::execute_sql(std::string const &sql_cmd)
-{
-    finish_copy();
-
-    pgsql_exec_simple(m_conn, PGRES_COMMAND_OK, sql_cmd.c_str());
-}
-
 void db_copy_thread_t::disconnect()
 {
     if (!m_conn)
@@ -218,17 +208,6 @@ void db_copy_mgr_t::delete_id(osmid_t osm_id)
     m_current->deletables.push_back(osm_id);
 }
 
-void db_copy_mgr_t::exec_sql(std::string const &sql_cmd)
-{
-    // finish any ongoing copy operations
-    if (m_current) {
-        m_processor->add_buffer(std::move(m_current));
-    }
-
-    // and add SQL command
-    m_processor->add_buffer(std::unique_ptr<db_cmd_t>(new db_cmd_sql_t(sql_cmd)));
-}
-
 void db_copy_mgr_t::sync()
 {
     // finish any ongoing copy operations

db-copy.hpp

@@ -44,7 +44,6 @@ class db_cmd_t
     enum cmd_t
     {
         Cmd_copy, ///< Copy buffer content into given target.
-        Cmd_sql,  ///< Execute buffer content as SQL command.
         Cmd_sync, ///< Synchronize with parent.
         Cmd_finish
     };
@@ -75,18 +74,6 @@ struct db_cmd_copy_t : public db_cmd_t
     }
 };
 
-struct db_cmd_sql_t : public db_cmd_t
-{
-    /// actual copy buffer
-    std::string buffer;
-
-    explicit db_cmd_sql_t(std::string const &sql_command)
-    : db_cmd_t(db_cmd_t::Cmd_sql), buffer(sql_command)
-    {
-    }
-
-};
-
 struct db_cmd_sync_t : public db_cmd_t
 {
     std::promise<void> barrier;
@@ -135,7 +122,6 @@ class db_copy_thread_t
     void connect();
     void disconnect();
 
-    void execute_sql(std::string const &sql_cmd);
     void write_to_db(db_cmd_copy_t *buffer);
     void start_copy(std::shared_ptr<db_target_descr_t> const &target);
     void finish_copy();
@@ -259,14 +245,6 @@ class db_copy_mgr_t
      */
     void delete_id(osmid_t osm_id);
 
-    /**
-     * Run an SQL statement.
-     *
-     * The statement is run in order. That means any previously submitted
-     * copyblocks are finished first.
-     */
-    void exec_sql(std::string const &sql_cmd);
-
     /**
      * Synchronize with worker.
      *