ClickHouse/dbms/include/DB/Interpreters/InterpreterSelectQuery.h

58 lines
1.6 KiB
C
Raw Normal View History

2011-08-28 05:13:24 +00:00
#pragma once
#include <DB/Interpreters/Context.h>
#include <DB/DataStreams/IBlockInputStream.h>
namespace DB
{
/** Интерпретирует запрос SELECT. Возвращает поток блоков с результатами выполнения запроса.
*/
class InterpreterSelectQuery
{
public:
2012-03-05 00:09:41 +00:00
InterpreterSelectQuery(ASTPtr query_ptr_, Context & context_);
2011-08-28 05:13:24 +00:00
2011-10-30 05:19:41 +00:00
/// Выполнить запрос, получить поток блоков для чтения
2011-08-28 05:13:24 +00:00
BlockInputStreamPtr execute();
2011-10-30 05:19:41 +00:00
/** Выполнить запрос, записать результат в нужном формате в buf.
* BlockInputStreamPtr возвращается, чтобы можно было потом получить информацию о плане выполнения запроса.
*/
BlockInputStreamPtr executeAndFormat(WriteBuffer & buf);
2011-08-28 05:13:24 +00:00
DataTypes getReturnTypes();
2011-10-30 05:19:41 +00:00
Block getSampleBlock();
2011-08-28 05:13:24 +00:00
private:
StoragePtr getTable();
2011-11-06 02:29:13 +00:00
void setColumns();
2011-08-28 05:13:24 +00:00
/** Пометить часть дерева запроса некоторым part_id.
* - для того, чтобы потом можно было вычислить только часть выражения из запроса.
*/
void setPartID(ASTPtr ast, unsigned part_id);
enum PartID
{
2011-09-04 05:14:52 +00:00
PART_OTHER = 1,
PART_SELECT = 2,
PART_WHERE = 4,
2011-09-24 20:32:41 +00:00
PART_GROUP = 8,
PART_HAVING = 16,
PART_ORDER = 32,
2011-09-25 03:37:09 +00:00
PART_BEFORE_AGGREGATING = 64, /// Под агрегатной функцией, или в ветке, не содержащей агрегатных функций
PART_AFTER_AGGREGATING = 128,
2011-08-28 05:13:24 +00:00
};
ASTPtr query_ptr;
Context context;
};
}