#include "IdentifierQuoteHandler.h" #if USE_ODBC # include # include # include # include # include # include # include # include # include # include # include # include # include # include "getIdentifierQuote.h" # include "validateODBCConnectionString.h" # define POCO_SQL_ODBC_CLASS Poco::Data::ODBC namespace DB { void IdentifierQuoteHandler::handleRequest(Poco::Net::HTTPServerRequest & request, Poco::Net::HTTPServerResponse & response) { Poco::Net::HTMLForm params(request, request.stream()); LOG_TRACE(log, "Request URI: " + request.getURI()); auto process_error = [&response, this](const std::string & message) { response.setStatusAndReason(Poco::Net::HTTPResponse::HTTP_INTERNAL_SERVER_ERROR); if (!response.sent()) response.send() << message << std::endl; LOG_WARNING(log, message); }; if (!params.has("connection_string")) { process_error("No 'connection_string' in request URL"); return; } try { std::string connection_string = params.get("connection_string"); POCO_SQL_ODBC_CLASS::SessionImpl session(validateODBCConnectionString(connection_string), DBMS_DEFAULT_CONNECT_TIMEOUT_SEC); SQLHDBC hdbc = session.dbc().handle(); auto identifier = getIdentifierQuote(hdbc); WriteBufferFromHTTPServerResponse out(request, response, keep_alive_timeout); writeStringBinary(identifier, out); } catch (...) { process_error("Error getting identifier quote style from ODBC '" + getCurrentExceptionMessage(false) + "'"); tryLogCurrentException(log); } } } #endif