add current DB name to general log (#9332)

pingcap · Feb 18, 2019 · 3e78ebc · 3e78ebc
1 parent 33a961d
commit 3e78ebc
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/session/session.go b/session/session.go
@@ -1641,7 +1641,8 @@ func logStmt(node ast.StmtNode, vars *variable.SessionVars) {
 func logQuery(query string, vars *variable.SessionVars) {
  if atomic.LoadUint32(&variable.ProcessGeneralLog) != 0 && !vars.InRestrictedSQL {
  query = executor.QueryReplacer.Replace(query)
- log.Infof("[GENERAL_LOG] con:%d user:%s schema_ver:%d txn_start_ts:%d sql:%s%s",
- vars.ConnectionID, vars.User, vars.TxnCtx.SchemaVersion, vars.TxnCtx.StartTS, query, vars.GetExecuteArgumentsInfo())
+ log.Infof("[GENERAL_LOG] con:%d user:%s schema_ver:%d txn_start_ts:%d current_db:%s, sql:%s%s",
+ vars.ConnectionID, vars.User, vars.TxnCtx.SchemaVersion, vars.TxnCtx.StartTS, vars.CurrentDB, query,
+ vars.GetExecuteArgumentsInfo())
  }
 }