Method executeCleanup

server/conn_query_exec.go:893–902

executeCleanup runs cleanup statements, ignoring errors (best effort). This is used to clean up temp tables after a multi-statement query.

(cleanup []string)

		return false, nil
	}

	// SELECT
	ctx, cleanup := c.queryContext()
	defer cleanup()

	runQuery := func() (RowSet, error) {
		return c.executor.QueryContext(ctx, executedQuery)
	}

	rows, err := runQuery()
	if err != nil && c.txStatus == txStatusIdle && isDuckLakeTransactionConflict(err) {
		ducklakeConflictTotal.Inc()
		rows, err = retryOnConflict(runQuery)