*: fix slow query nil pointer panic when get session for TTL (#39865)

close #39864
pingcap · Dec 13, 2022 · b7e21a0 · b7e21a0
1 parent 621115b
commit b7e21a0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/executor/adapter.go b/executor/adapter.go
@@ -1538,7 +1538,7 @@ func (a *ExecStmt) LogSlowQuery(txnTS uint64, succ bool, hasMoreResults bool) {
 	if a.retryCount > 0 {
 		slowItems.ExecRetryTime = costTime - sessVars.DurationParse - sessVars.DurationCompile - time.Since(a.retryStartTime)
 	}
-	if _, ok := a.StmtNode.(*ast.CommitStmt); ok {
+	if _, ok := a.StmtNode.(*ast.CommitStmt); ok && sessVars.PrevStmt != nil {
 		slowItems.PrevStmt = sessVars.PrevStmt.String()
 	}
 	slowLog := sessVars.SlowLogFormat(slowItems)

diff --git a/ttl/ttlworker/session.go b/ttl/ttlworker/session.go
@@ -60,7 +60,8 @@ func getSession(pool sessionPool) (session.Session, error) {
 		pool.Put(resource)
 	})
 
-	if _, err = se.ExecuteSQL(context.Background(), "commit"); err != nil {
+	// Force rollback the session to guarantee the session is not in any explicit transaction
+	if _, err = se.ExecuteSQL(context.Background(), "ROLLBACK"); err != nil {
 		se.Close()
 		return nil, err
 	}