diff -r eb2066405f79 -r 8731263d44f1 src/PassthroughHandler.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/PassthroughHandler.h Sun Dec 02 20:17:46 2018 +0100 @@ -0,0 +1,79 @@ +/** + * Relational pipes + * Copyright © 2018 František Kučera (Frantovo.cz, GlobalCode.info) + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see . + */ +#pragma once + +#include +#include +#include +#include +#include +#include +#include +#include + +#include +#include +#include +#include + +#include + +namespace relpipe { +namespace tr { +namespace validator { + +using namespace relpipe; +using namespace relpipe::reader; +using namespace relpipe::reader::handlers; + +// TODO: use rather RelationalReaderStringHadler +class PassthroughHandler : public RelationalReaderStringHadler { +private: + writer::RelationalWriter* relationalWriter; +public: + + PassthroughHandler(std::ostream& output) : relationalWriter(writer::Factory::create(output)) { + } + + virtual ~PassthroughHandler() { + delete relationalWriter; + } + + void startRelation(string_t name, std::vector attributes) override { + // TODO: move to a reusable method (or use same metadata on both reader and writer side?) + std::vector writerMetadata; + for (AttributeMetadata readerMetadata : attributes) { + writerMetadata.push_back({readerMetadata.getAttributeName(), relationalWriter->toTypeId(readerMetadata.getTypeName())}); + } + + relationalWriter->startRelation(name, writerMetadata, true); + } + + void attribute(const string_t& value) override { + relationalWriter->writeAttribute(value); + } + + void endOfPipe() { + + } + +}; + +} +} +}