thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-12 09:22:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Delete garbage

Browse Source
This commit is contained in:
Nikita Mikhaylov 2022-09-20 22:53:09 +00:00
parent 502338560c
commit 4d1d87da2c
1 changed files with 0 additions and 63 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
src/Interpreters/tests/gtest_async_inserts.cpp
View File

@ -1,63 +0,0 @@
#include <gtest/gtest.h>
#include <Interpreters/executeQuery.h>
#include <Interpreters/Context.h>
#include "Processors/Executors/PullingPipelineExecutor.h"
#include <Functions/registerFunctions.h>
#include <AggregateFunctions/registerAggregateFunctions.h>
#include <TableFunctions/registerTableFunctions.h>
#include <Storages/registerStorages.h>
#include <Dictionaries/registerDictionaries.h>
#include <Disks/registerDisks.h>
#include <Formats/registerFormats.h>
#include "Common/Exception.h"
using namespace DB;
static SharedContextHolder shared_context;
static ContextMutablePtr context;
static bool initialize()
{
try
{
shared_context = Context::createShared();
context = Context::createGlobal(shared_context.get());
context->makeGlobalContext();
context->setApplicationType(Context::ApplicationType::LOCAL);
// registerFunctions();
// registerAggregateFunctions();
// registerTableFunctions();
// registerStorages();
// registerDictionaries();
// registerDisks();
// registerFormats();
return true;
}
catch (...)
{
tryLogCurrentException(__PRETTY_FUNCTION__);
throw;
}
}
[[ maybe_unused ]] static bool initialized = initialize();
TEST(AsyncInsertQueue, SimpleTest)
{
try
{
auto io = executeQuery("CREATE TABLE SimpleTest ENGINE=Memory()", context, true, QueryProcessingStage::Complete);
PullingPipelineExecutor executor(io.pipeline);
Block res;
while (!res && executor.pull(res));
}
catch (...)
{
tryLogCurrentException(__PRETTY_FUNCTION__);
}
}