ClickHouse/dbms/src/Storages/tests/system_numbers.cpp

44 lines
1.2 KiB
C++
Raw Normal View History

2010-03-04 19:21:31 +00:00
#include <iostream>
#include <IO/WriteBufferFromOStream.h>
#include <Storages/System/StorageSystemNumbers.h>
#include <DataStreams/LimitBlockInputStream.h>
#include <Formats/FormatFactory.h>
#include <DataStreams/copyData.h>
#include <DataTypes/DataTypesNumber.h>
#include <Interpreters/Context.h>
2010-03-04 19:21:31 +00:00
2017-12-02 02:47:12 +00:00
int main(int, char **)
try
2010-03-04 19:21:31 +00:00
{
using namespace DB;
StoragePtr table = StorageSystemNumbers::create("numbers", false);
2010-03-05 15:29:17 +00:00
Names column_names;
column_names.push_back("number");
2010-03-05 15:29:17 +00:00
Block sample;
ColumnWithTypeAndName col;
col.type = std::make_shared<DataTypeUInt64>();
sample.insert(std::move(col));
2010-06-04 18:25:25 +00:00
WriteBufferFromOStream out_buf(std::cout);
2012-05-22 18:32:45 +00:00
2018-04-23 19:05:46 +00:00
QueryProcessingStage::Enum stage = table->getQueryProcessingStage(Context::createGlobal());
2015-09-24 03:50:09 +00:00
auto context = Context::createGlobal();
LimitBlockInputStream input(table->read(column_names, {}, context, stage, 10, 1)[0], 10, 96);
BlockOutputStreamPtr out = FormatFactory::instance().getOutput("TabSeparated", out_buf, sample, context);
2015-09-24 03:50:09 +00:00
copyData(input, *out);
2010-03-04 19:21:31 +00:00
return 0;
2010-03-04 19:21:31 +00:00
}
catch (const DB::Exception & e)
{
std::cerr << e.what() << ", " << e.displayText() << std::endl;
return 1;
}