diff --git a/lib/mysql_connection.cpp b/lib/mysql_connection.cpp index 56ee09c88..9e93cbbcd 100644 --- a/lib/mysql_connection.cpp +++ b/lib/mysql_connection.cpp @@ -1548,7 +1548,21 @@ handler_again: async_fetch_row_start=false; if (mysql_row) { if (myds && myds->sess && myds->sess->status == SHOW_WARNINGS) { - proxy_warning("MySQL Warning. Level: [%s], Code: [%s], Message: [%s]\n", mysql_row[0], mysql_row[1], mysql_row[2]); + if (mysql_thread___verbose_query_error) + proxy_warning("Warning during query on (%d,%s,%d,%lu). User '%s@%s', schema '%s'," + " digest_text '%s', level '%s', code '%s', message '%s'\n", + parent->myhgc->hid, parent->address, parent->port, + mysql->thread_id, + myds->sess->client_myds->myconn->userinfo->username, + (myds->sess->client_myds->addr.addr ? myds->sess->client_myds->addr.addr : (char *)"unknown"), + myds->sess->client_myds->myconn->userinfo->schemaname, + myds->sess->CurrentQuery.get_digest_text(), + mysql_row[0], mysql_row[1], mysql_row[2]); + else + proxy_warning("Warning during query on (%d,%s,%d,%lu). " + "Level '%s', code '%s',"" message '%s'\n", + parent->myhgc->hid, parent->address, parent->port, + mysql->thread_id, mysql_row[0], mysql_row[1], mysql_row[2]); } unsigned int br=MyRS->add_row(mysql_row); __sync_fetch_and_add(&parent->bytes_recv,br);