diff --git a/test/CMakeLists.txt b/test/CMakeLists.txt index 503a8ccdfa68..49e037c171e5 100644 --- a/test/CMakeLists.txt +++ b/test/CMakeLists.txt @@ -25,9 +25,6 @@ if(NOT WIN32 AND NOT SUN) if(${BUILD_TPCE}) add_subdirectory(tpce) endif() - if(${DUCKDB_EXTENSION_TPCH_SHOULD_LINK}) - add_subdirectory(tpch) - endif() add_subdirectory(persistence) endif() diff --git a/test/tpch/CMakeLists.txt b/test/tpch/CMakeLists.txt deleted file mode 100644 index b216a8ebf675..000000000000 --- a/test/tpch/CMakeLists.txt +++ /dev/null @@ -1,4 +0,0 @@ -add_library_unity(test_tpch OBJECT test_tpch.cpp) -set(ALL_OBJECT_FILES - ${ALL_OBJECT_FILES} $ - PARENT_SCOPE) diff --git a/test/tpch/test_tpch.cpp b/test/tpch/test_tpch.cpp deleted file mode 100644 index f1bd8a28ada5..000000000000 --- a/test/tpch/test_tpch.cpp +++ /dev/null @@ -1,42 +0,0 @@ -#include "catch.hpp" -#include "test_helpers.hpp" -#include "tpce.hpp" - -#include -#include - -using namespace duckdb; -using namespace std; - -static void long_running_dbgen(Connection *con, bool *interrupted, std::condition_variable *cv) { - auto result = con->Query("call dbgen(sf=10)"); - if (result->HasError() && result->GetError() == "INTERRUPT Error: Interrupted!") { - *interrupted = true; - } - cv->notify_one(); -} - -TEST_CASE("Test TPC-H Interrupt", "[tpch]") { - auto db = make_uniq(nullptr); - auto con = make_uniq(*db); - - bool interrupted = false; - std::condition_variable cv; - auto background_thread = thread(long_running_dbgen, con.get(), &interrupted, &cv); - - // wait for query to start executing - std::this_thread::sleep_for(std::chrono::milliseconds(100)); - - con->Interrupt(); - - std::mutex m; - std::unique_lock l(m); - if (cv.wait_for(l, std::chrono::milliseconds(5000)) == std::cv_status::timeout) { - FAIL("Query was not interrupted in time"); - } - - // wait for the thread - background_thread.join(); - - REQUIRE(interrupted); -}