Function tryToExecuteQuery

src/Databases/MySQL/MaterializeMySQLSyncThread.cpp:45–61

static constexpr auto MYSQL_BACKGROUND_THREAD_NAME = "MySQLDBSync";

static BlockIO tryToExecuteQuery(const String & query_to_execute, ContextMutablePtr query_context, const String & database, const String & comment)
{
    try
    {
        if (!database.empty())
            query_context->setCurrentDatabase(database);

        return executeQuery("/*" + comment + "*/ " + query_to_execute, query_context, true);
    }
    catch (...)
    {
        tryLogCurrentException(
            &Poco::Logger::get("MaterializeMySQLSyncThread(" + database + ")"),
            "Query " + query_to_execute + " wasn't finished successfully");
        throw;
    }
}

MaterializeMySQLSyncThread::~MaterializeMySQLSyncThread()
{