session: add transaction id in general log. (pingcap#5803)

stevenberge · Feb 6, 2018 · 69be660 · 69be660
1 parent 26d4887
commit 69be660
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/session.go b/session.go
@@ -1575,6 +1575,6 @@ func logStmt(node ast.StmtNode, vars *variable.SessionVars) {
 
 func logQuery(query string, vars *variable.SessionVars) {
 	if atomic.LoadUint32(&variable.ProcessGeneralLog) != 0 && !vars.InRestrictedSQL {
-		log.Infof("[%d] %s", vars.ConnectionID, query)
+		log.Infof("[con:%d][txn:%d] %s", vars.ConnectionID, vars.TxnCtx.StartTS, query)
 	}
 }