diff -r 0f28565508ca -r aebaf590a838 src/PassthroughHandler.h --- a/src/PassthroughHandler.h Mon Dec 10 00:06:54 2018 +0100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,79 +0,0 @@ -/** - * 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() { - - } - -}; - -} -} -}