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:
|
|
|
|
|
InterpreterSelectQuery(ASTPtr query_ptr_, Context & context_, size_t max_block_size_ = DEFAULT_BLOCK_SIZE);
|
|
|
|
|
|
|
|
|
|
BlockInputStreamPtr execute();
|
|
|
|
|
|
|
|
|
|
DataTypes getReturnTypes();
|
|
|
|
|
|
|
|
|
|
private:
|
|
|
|
|
StoragePtr getTable();
|
|
|
|
|
|
|
|
|
|
/** Пометить часть дерева запроса некоторым 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;
|
|
|
|
|
size_t max_block_size;
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|