diff --git a/lib/MySQL_Session.cpp b/lib/MySQL_Session.cpp index d2ac2998ac..99afae7fbf 100644 --- a/lib/MySQL_Session.cpp +++ b/lib/MySQL_Session.cpp @@ -6032,6 +6032,8 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C string nq=string((char *)CurrentQuery.QueryPointer,CurrentQuery.QueryLength); RE2::GlobalReplace(&nq,(char *)"^/\\*!\\d\\d\\d\\d\\d SET(.*)\\*/",(char *)"SET\\1"); RE2::GlobalReplace(&nq,(char *)"(?U)/\\*.*\\*/",(char *)""); + // remove trailing space and semicolon if present. See issue#4380 + nq.erase(nq.find_last_not_of(" ;") + 1); /* // we do not threat SET SQL_LOG_BIN as a special case if (match_regexes && match_regexes[0]->match(dig)) { diff --git a/test/tap/tests/set_testing-240-t.cpp b/test/tap/tests/set_testing-240-t.cpp index 7ac4f17a2f..6d8dc01160 100644 --- a/test/tap/tests/set_testing-240-t.cpp +++ b/test/tap/tests/set_testing-240-t.cpp @@ -82,6 +82,29 @@ class var_counter { } }; +// Generate string containing randomly chosen characters between +// ';' and ' ', with length between 1 and 8 +std::string generate_random_noise() { + // Seed the random number generator with the current time + std::srand(static_cast(std::time(nullptr))); + + static const char characters[] = { ';', ' ' }; + static const int numCharacters = sizeof(characters) / sizeof(char); + + // max lengh of string is 8 + const int length = std::rand() % 8 + 1; + + std::string randomString; + randomString.reserve(length); + + for (int i = 0; i < length; ++i) { + char randomChar = characters[std::rand() % numCharacters]; + randomString.push_back(randomChar); + } + + return randomString; +} + //std::unordered_map unknown_var_counters; std::unordered_map vars_counters; @@ -160,6 +183,7 @@ void * my_conn_thread(void *arg) { diag("Thread_id: %lu, random number: %d . Query/ies: %s", mysql->thread_id, r2, testCases[r2].command.c_str()); std::vector commands = split(testCases[r2].command.c_str(), ';'); for (auto c : commands) { + c += generate_random_noise(); if (mysql_query(mysql, c.c_str())) { if (silent==0) { fprintf(stderr,"ERROR while running -- \"%s\" : (%d) %s\n", c.c_str(), mysql_errno(mysql), mysql_error(mysql));