#pragma once #include #include #include namespace DB { struct QueryLogElement; /** Interpreters interface for different queries. */ class IInterpreter { public: /** For queries that return a result (SELECT and similar), sets in BlockIO a stream from which you can read this result. * For queries that receive data (INSERT), sets a thread in BlockIO where you can write data. * For queries that do not require data and return nothing, BlockIO will be empty. */ virtual BlockIO execute() = 0; virtual bool ignoreQuota() const { return false; } virtual bool ignoreLimits() const { return false; } // Fill query log element with query kind, query databases, query tables and query columns. void extendQueryLogElem( QueryLogElement & elem, const ASTPtr & ast, ContextPtr context, const String & query_database, const String & query_table) const; virtual void extendQueryLogElemImpl(QueryLogElement &, const ASTPtr &, ContextPtr) const {} virtual ~IInterpreter() = default; }; }