2018-09-25 00:21:20 +00:00
|
|
|
#pragma once
|
|
|
|
|
|
|
|
#include <Common/config.h>
|
2018-09-25 14:29:44 +00:00
|
|
|
#include <Common/XDBCBridgeHelper.h>
|
2018-09-25 00:21:20 +00:00
|
|
|
#include <TableFunctions/ITableFunction.h>
|
|
|
|
#include <Poco/Util/AbstractConfiguration.h>
|
2018-09-25 14:29:44 +00:00
|
|
|
#include <Storages/StorageXDBC.h>
|
2018-09-25 00:21:20 +00:00
|
|
|
|
|
|
|
namespace DB
|
|
|
|
{
|
|
|
|
/**
|
|
|
|
* Base class for table functions, that works over external bridge
|
|
|
|
* Xdbc (Xdbc connect string, table) - creates a temporary StorageXDBC.
|
|
|
|
*/
|
|
|
|
class ITableFunctionXDBC : public ITableFunction
|
|
|
|
{
|
|
|
|
private:
|
|
|
|
StoragePtr executeImpl(const ASTPtr & ast_function, const Context & context) const override;
|
|
|
|
|
|
|
|
/* A factory method to create bridge helper, that will assist in remote interaction */
|
|
|
|
virtual BridgeHelperPtr createBridgeHelper(const Poco::Util::AbstractConfiguration & config_,
|
|
|
|
const Poco::Timespan & http_timeout_,
|
|
|
|
const std::string & connection_string_) const = 0;
|
|
|
|
};
|
2018-09-25 14:29:44 +00:00
|
|
|
|
|
|
|
class TableFunctionJDBC : public ITableFunctionXDBC
|
|
|
|
{
|
|
|
|
public:
|
|
|
|
static constexpr auto name = "jdbc";
|
|
|
|
std::string getName() const override
|
|
|
|
{
|
|
|
|
return name;
|
|
|
|
}
|
|
|
|
private:
|
|
|
|
|
|
|
|
BridgeHelperPtr createBridgeHelper(const Poco::Util::AbstractConfiguration & config_,
|
|
|
|
const Poco::Timespan & http_timeout_,
|
|
|
|
const std::string & connection_string_) const override {
|
2018-09-27 15:23:42 +00:00
|
|
|
return std::make_shared<XDBCBridgeHelper<JDBCBridgeMixin>>(config_, http_timeout_, connection_string_);
|
2018-09-25 14:29:44 +00:00
|
|
|
}
|
|
|
|
};
|
|
|
|
|
2018-09-28 02:46:33 +00:00
|
|
|
class TableFunctionODBC : public ITableFunctionXDBC
|
2018-09-25 14:29:44 +00:00
|
|
|
{
|
|
|
|
public:
|
2018-09-28 02:46:33 +00:00
|
|
|
static constexpr auto name = "odbc";
|
2018-09-25 14:29:44 +00:00
|
|
|
std::string getName() const override
|
|
|
|
{
|
|
|
|
return name;
|
|
|
|
}
|
|
|
|
private:
|
|
|
|
|
|
|
|
BridgeHelperPtr createBridgeHelper(const Poco::Util::AbstractConfiguration & config_,
|
|
|
|
const Poco::Timespan & http_timeout_,
|
|
|
|
const std::string & connection_string_) const override {
|
|
|
|
return std::make_shared<XDBCBridgeHelper<ODBCBridgeMixin>>(config_, http_timeout_, connection_string_);
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
2018-09-25 00:21:20 +00:00
|
|
|
}
|