Created column exception_code in query_log table

dbms/src/Interpreters/QueryLog.cpp

@@ -49,6 +49,7 @@ Block QueryLogElement::createBlock()
         {std::make_shared<DataTypeUInt64>(),                                  "memory_usage"},
 
         {std::make_shared<DataTypeString>(),                                  "query"},
+        {std::make_shared<DataTypeInt32>(),                                   "exception_code"},
         {std::make_shared<DataTypeString>(),                                  "exception"},
         {std::make_shared<DataTypeString>(),                                  "stack_trace"},
 
@@ -107,6 +108,7 @@ void QueryLogElement::appendToBlock(Block & block) const
     columns[i++]->insert(memory_usage);
 
     columns[i++]->insertData(query.data(), query.size());
+    columns[i++]->insert(exception_code);
     columns[i++]->insertData(exception.data(), exception.size());
     columns[i++]->insertData(stack_trace.data(), stack_trace.size());
 

dbms/src/Interpreters/QueryLog.h

@@ -54,6 +54,7 @@ struct QueryLogElement
 
     String query;
 
+    Int32 exception_code{}; // because ErrorCodes are int
     String exception;
     String stack_trace;
 

dbms/src/Interpreters/executeQuery.cpp

@@ -163,6 +163,7 @@ static void onExceptionBeforeStart(const String & query_for_logging, Context & c
     elem.query_start_time = current_time;
 
     elem.query = query_for_logging;
+    elem.exception_code = getCurrentExceptionCode();
     elem.exception = getCurrentExceptionMessage(false);
 
     elem.client_info = context.getClientInfo();
@@ -496,6 +497,7 @@ static std::tuple<ASTPtr, BlockIO> executeQueryImpl(
 
                 elem.event_time = time(nullptr);
                 elem.query_duration_ms = 1000 * (elem.event_time - elem.query_start_time);
+                elem.exception_code = getCurrentExceptionCode();
                 elem.exception = getCurrentExceptionMessage(false);
 
                 QueryStatus * process_list_elem = context.getProcessListElement();

dbms/tests/queries/0_stateless/01070_exception_code_in_query_log_table.reference

@@ -0,0 +1,5 @@
+0
+0
+0
+0
+60

dbms/tests/queries/0_stateless/01070_exception_code_in_query_log_table.sql

@@ -0,0 +1,6 @@
+DROP TABLE IF EXISTS test_table;
+SYSTEM FLUSH LOGS;
+TRUNCATE TABLE system.query_log;
+SELECT * FROM test_table; -- { serverError 60 }
+SYSTEM FLUSH LOGS;
+SELECT exception_code FROM system.query_log;