Function collectSingleTablesFromExpr

backend/plugin/parser/mysql/backup.go:250–276

(databaseName string, expr ast.TableExpr, out map[string]*TableReference)

}

func collectSingleTablesFromExpr(databaseName string, expr ast.TableExpr, out map[string]*TableReference) {
	switch e := expr.(type) {
	case *ast.TableRef:
		db := e.Schema
		if db == "" {
			db = databaseName
		}
		ref := &TableReference{
			Database: db,
			Table:    e.Name,
			Alias:    e.Alias,
		}
		key := e.Name
		if e.Alias != "" {
			key = e.Alias
		}
		out[key] = ref
	case *ast.JoinClause:
		if e.Left != nil {
			collectSingleTablesFromExpr(databaseName, e.Left, out)
		}
		if e.Right != nil {
			collectSingleTablesFromExpr(databaseName, e.Right, out)
		}
	default:
	}
}

// collectCTENames extracts CTE names from the SQL text before the statement Loc.
// MySQL's UPDATE/DELETE CTEs are not in the omni AST, so we parse the prefix.