From cedc35ca8cdcd079b473e469e2505d60bc366a90 Mon Sep 17 00:00:00 2001
From: xiaojian cai <mc02cxj@gmail.com>
Date: Mon, 13 Nov 2017 11:26:56 +0800
Subject: [PATCH] executor: add default database to query log (#5078)

---
 executor/adapter.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/executor/adapter.go b/executor/adapter.go
index d2ee59f47a..3a09feab27 100644
--- a/executor/adapter.go
+++ b/executor/adapter.go
@@ -289,10 +289,12 @@ func (a *ExecStmt) logSlowQuery(succ bool) {
 		sql = fmt.Sprintf("%.*q(len:%d)", cfg.Log.QueryLogMaxLen, sql, len(a.Text))
 	}
 	connID := a.ctx.GetSessionVars().ConnectionID
+	currentDB := a.ctx.GetSessionVars().CurrentDB
 	logEntry := log.NewEntry(logutil.SlowQueryLogger)
 	logEntry.Data = log.Fields{
 		"connectionId": connID,
 		"costTime":     costTime,
+		"database":     currentDB,
 		"sql":          sql,
 	}
 	if costTime < time.Duration(cfg.Log.SlowThreshold)*time.Millisecond {