YQ Connector: move tests from yql to ydb (OSS)

Перенос папки с тестами на Коннектор из папки yql в папку ydb (синхронизируется с github).

1 files changed, 36 insertions, 0 deletions

diff --git a/contrib/clickhouse/src/TableFunctions/TableFunctionPostgreSQL.h b/contrib/clickhouse/src/TableFunctions/TableFunctionPostgreSQL.h
new file mode 100644
index 00000000000..8559409c60c
--- /dev/null
+++ b/contrib/clickhouse/src/TableFunctions/TableFunctionPostgreSQL.h
@@ -0,0 +1,36 @@
+#pragma once
+#include "clickhouse_config.h"
+
+#if USE_LIBPQXX
+#include <TableFunctions/ITableFunction.h>
+#include <Core/PostgreSQL/PoolWithFailover.h>
+#include <Storages/ExternalDataSourceConfiguration.h>
+#include <Storages/StoragePostgreSQL.h>
+
+
+namespace DB
+{
+
+class TableFunctionPostgreSQL : public ITableFunction
+{
+public:
+    static constexpr auto name = "postgresql";
+    std::string getName() const override { return name; }
+
+private:
+    StoragePtr executeImpl(
+            const ASTPtr & ast_function, ContextPtr context,
+            const std::string & table_name, ColumnsDescription cached_columns, bool is_insert_query) const override;
+
+    const char * getStorageTypeName() const override { return "PostgreSQL"; }
+
+    ColumnsDescription getActualTableStructure(ContextPtr context, bool is_insert_query) const override;
+    void parseArguments(const ASTPtr & ast_function, ContextPtr context) override;
+
+    postgres::PoolWithFailoverPtr connection_pool;
+    std::optional<StoragePostgreSQL::Configuration> configuration;
+};
+
+}
+
+#endif