src/StreamRelationalReader.h
author František Kučera <franta-hg@frantovo.cz>
Sun, 16 Sep 2018 00:42:42 +0200
branchv_0
changeset 26 019edca46769
parent 25 fc0d05b72214
child 28 c9e03557c1e1
permissions -rw-r--r--
AttributeMetadata: use smart pointer and avoid memory-leak
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
14
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
     1
#pragma once
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
     2
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
     3
#include <string>
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
     4
#include <iostream>
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
     5
#include <vector>
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
     6
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
     7
#include <relpipe/protocol/constants.h>
26
019edca46769 AttributeMetadata: use smart pointer and avoid memory-leak
František Kučera <franta-hg@frantovo.cz>
parents: 25
diff changeset
     8
#include <memory>
14
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
     9
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    10
#include "../include/relpipe/reader/typedefs.h"
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    11
#include "../include/relpipe/reader/RelationalReader.h"
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    12
#include "../include/relpipe/reader/TypeId.h"
16
9b8139bb0519 handler structure
František Kučera <franta-hg@frantovo.cz>
parents: 14
diff changeset
    13
#include "../include/relpipe/reader/handlers/RelationalReaderBaseHandler.h"
9b8139bb0519 handler structure
František Kučera <franta-hg@frantovo.cz>
parents: 14
diff changeset
    14
#include "../include/relpipe/reader/handlers/RelationalReaderStringHandler.h"
9b8139bb0519 handler structure
František Kučera <franta-hg@frantovo.cz>
parents: 14
diff changeset
    15
#include "../include/relpipe/reader/handlers/RelationalReaderValueHandler.h"
24
6f7acc3b274c AttributeMetadata: pImpl / d-pointer version but with memory-leak and unwanted empty constructor
František Kučera <franta-hg@frantovo.cz>
parents: 22
diff changeset
    16
#include "AttributeMetadataPrivate.h"
14
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    17
#include "DataTypeReaderBase.h"
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    18
#include "types/BooleanDataTypeReader.h"
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    19
#include "types/IntegerDataTypeReader.h"
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    20
#include "types/StringDataTypeReader.h"
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    21
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    22
namespace relpipe {
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    23
namespace reader {
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    24
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    25
using namespace relpipe::protocol;
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    26
21
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    27
using StringHandler = relpipe::reader::handlers::RelationalReaderStringHadler;
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    28
using ValuesHandler = relpipe::reader::handlers::RelationalReaderValueHadler;
26
019edca46769 AttributeMetadata: use smart pointer and avoid memory-leak
František Kučera <franta-hg@frantovo.cz>
parents: 25
diff changeset
    29
using AttributeMetadata = relpipe::reader::handlers::AttributeMetadata;
019edca46769 AttributeMetadata: use smart pointer and avoid memory-leak
František Kučera <franta-hg@frantovo.cz>
parents: 25
diff changeset
    30
using AttributeMetadataPrivate = relpipe::reader::handlers::AttributeMetadataPrivate;
21
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    31
14
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    32
class StreamRelationalReader : public RelationalReader {
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    33
private:
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    34
	std::istream &input;
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    35
	types::BooleanDataTypeReader booleanReader;
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    36
	types::IntegerDataTypeReader integerReader;
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    37
	types::StringDataTypeReader stringReader;
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    38
	std::vector<DataTypeReaderBase*> readers = {&booleanReader, &integerReader, &stringReader};
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    39
21
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    40
	std::vector<StringHandler*> stringHandlers;
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    41
	std::vector<ValuesHandler*> valuesHandlers;
14
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    42
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    43
	/**
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    44
	 * count of columns in the current table
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    45
	 */
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    46
	integer_t columnCount;
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    47
	/**
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    48
	 * number of column (0 = first) that will be written; after writing, the number is increased and prepared for next one
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    49
	 */
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    50
	integer_t currentColumn;
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    51
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    52
	/**
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    53
	 * types of columns in the current table
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    54
	 */
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    55
	std::vector<TypeId> columnTypes;
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    56
	std::vector<string_t> columnNames;
26
019edca46769 AttributeMetadata: use smart pointer and avoid memory-leak
František Kučera <franta-hg@frantovo.cz>
parents: 25
diff changeset
    57
	std::vector<AttributeMetadata> columns;
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    58
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    59
	/**
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    60
	 * TODO: remove?
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    61
	 */
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    62
	string_t readString(std::istream &input, const TypeId typeId) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    63
		for (DataTypeReaderBase* reader : readers) if (reader->supports(typeId)) return reader->readString(input);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    64
		throw RelpipeReaderException(L"Unsupported data type: " + (int) typeId);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    65
	}
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    66
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    67
	void read(std::istream &input, std::function<void(const void *, const std::type_info&) > handler, const TypeId typeId) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    68
		for (DataTypeReaderBase* reader : readers) if (reader->supports(typeId)) return reader->read(input, handler);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    69
		throw RelpipeReaderException(L"Unsupported data type: " + (int) typeId);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    70
	}
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    71
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    72
	void read(std::istream &input, std::function<void(const string_t&, const void *, const std::type_info&) > handler, const TypeId typeId) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    73
		for (DataTypeReaderBase* reader : readers) if (reader->supports(typeId)) return reader->read(input, handler);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    74
		throw RelpipeReaderException(L"Unsupported data type: " + (int) typeId);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
    75
	}
14
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    76
19
3e1308e7606d add endOfPipe() to handlers
František Kučera <franta-hg@frantovo.cz>
parents: 18
diff changeset
    77
	void endOfPipe() {
21
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    78
		for (StringHandler* handler : stringHandlers) handler->endOfPipe();
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    79
		for (ValuesHandler* handler : valuesHandlers) handler->endOfPipe();
19
3e1308e7606d add endOfPipe() to handlers
František Kučera <franta-hg@frantovo.cz>
parents: 18
diff changeset
    80
	}
3e1308e7606d add endOfPipe() to handlers
František Kučera <franta-hg@frantovo.cz>
parents: 18
diff changeset
    81
14
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    82
public:
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    83
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    84
	StreamRelationalReader(std::istream &input) :
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    85
	input(input) {
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    86
	}
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    87
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    88
	string_t toTypeCode(const TypeId typeId) override {
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    89
		for (DataTypeReaderBase* reader : readers) if (reader->supports(typeId)) return reader->getTypeCode();
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    90
		throw RelpipeReaderException(L"Unsupported data type: " + static_cast<integer_t> (typeId));
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    91
	}
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
    92
21
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    93
	void addHandler(StringHandler* handler) override {
17
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
    94
		stringHandlers.push_back(handler);
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
    95
	}
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
    96
21
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    97
	void addHandler(ValuesHandler* handler) override {
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
    98
		valuesHandlers.push_back(handler);
17
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
    99
	}
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
   100
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
   101
	void process() override {
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   102
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   103
		while (true) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   104
			integer_t dataPart;
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   105
			try {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   106
				dataPart = integerReader.readValue(input);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   107
				// output << "dataPart: " << dataPart << endl;
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   108
			} catch (RelpipeReaderException e) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   109
				if (input.eof() && input.gcount() == 0) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   110
					if (dataPart == DATA_PART_ROW) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   111
						// last part was row
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   112
						// input was fully read
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   113
						// we are finished
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   114
						// TODO: printCachedData(output); ???
19
3e1308e7606d add endOfPipe() to handlers
František Kučera <franta-hg@frantovo.cz>
parents: 18
diff changeset
   115
						endOfPipe();
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   116
						return;
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   117
					} else if (dataPart == DATA_PART_START) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   118
						// Empty relation might be weird but it is valid data.
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   119
						// Actually, it is not so weird as it looks.
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   120
						// fwprintf(stderr, L"Warning: The table has no rows. Weird… but OK.\n");
19
3e1308e7606d add endOfPipe() to handlers
František Kučera <franta-hg@frantovo.cz>
parents: 18
diff changeset
   121
						endOfPipe();
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   122
						return;
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   123
					} else {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   124
						// in current format, there is no other data part
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   125
						// so this will never happen
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   126
						// but maybe later…
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   127
						throw RelpipeReaderException(L"Unexpected EOF");
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   128
					}
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   129
				} else if (input.eof()) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   130
					fwprintf(stderr, L"Error: found some unexpected data on the input stream: %d\n", input.gcount());
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   131
					throw e;
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   132
				} else {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   133
					// other error
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   134
					throw e;
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   135
				}
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   136
			}
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   137
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   138
			if (dataPart == DATA_PART_START) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   139
				// Print data of previous table
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   140
				// TODO: if (values.size() > 0) printCachedData(output); ???
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   141
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   142
				// Read table name
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   143
				string_t tableName = stringReader.readValue(input);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   144
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   145
				// Read column count
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   146
				columnCount = integerReader.readValue(input);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   147
25
fc0d05b72214 AttributeMetadata: use vector.reserve() instead of resize() and [i] and thus avoid unwanted AttributeMetadata() constructor call
František Kučera <franta-hg@frantovo.cz>
parents: 24
diff changeset
   148
				columnTypes.reserve(columnCount);
fc0d05b72214 AttributeMetadata: use vector.reserve() instead of resize() and [i] and thus avoid unwanted AttributeMetadata() constructor call
František Kučera <franta-hg@frantovo.cz>
parents: 24
diff changeset
   149
				columnNames.reserve(columnCount);
fc0d05b72214 AttributeMetadata: use vector.reserve() instead of resize() and [i] and thus avoid unwanted AttributeMetadata() constructor call
František Kučera <franta-hg@frantovo.cz>
parents: 24
diff changeset
   150
				columns.reserve(columnCount);
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   151
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   152
				// Read column names
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   153
				for (int i = 0; i < columnCount; i++) {
25
fc0d05b72214 AttributeMetadata: use vector.reserve() instead of resize() and [i] and thus avoid unwanted AttributeMetadata() constructor call
František Kučera <franta-hg@frantovo.cz>
parents: 24
diff changeset
   154
					columnNames.push_back(stringReader.readValue(input));
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   155
				}
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   156
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   157
				// Read column types
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   158
				for (int i = 0; i < columnCount; i++) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   159
					TypeId typeId = (TypeId) integerReader.readValue(input); // TODO: přetypování OK?
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   160
					string_t typeCode = toTypeCode(typeId); // validate typeId TODO: je potřeba?
25
fc0d05b72214 AttributeMetadata: use vector.reserve() instead of resize() and [i] and thus avoid unwanted AttributeMetadata() constructor call
František Kučera <franta-hg@frantovo.cz>
parents: 24
diff changeset
   161
					columnTypes.push_back(typeId);
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   162
22
e81019af67dc use AttributeMetadata instead of std::pair for relation header
František Kučera <franta-hg@frantovo.cz>
parents: 21
diff changeset
   163
					// put together names, type ids and type codes:
26
019edca46769 AttributeMetadata: use smart pointer and avoid memory-leak
František Kučera <franta-hg@frantovo.cz>
parents: 25
diff changeset
   164
					columns.push_back(std::shared_ptr<AttributeMetadataPrivate>(new AttributeMetadataPrivate({columnNames[i], columnTypes[i], typeCode})));
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   165
				}
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   166
21
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
   167
				for (StringHandler* handler : stringHandlers) handler->startRelation(tableName, columns);
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
   168
				for (ValuesHandler* handler : valuesHandlers) handler->startRelation(tableName, columns);
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   169
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   170
			} else if (dataPart == DATA_PART_ROW) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   171
				for (int i = 0; i < columnCount; i++) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   172
					TypeId typeId = columnTypes[i];
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   173
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   174
					if (stringHandlers.empty()) {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   175
						read(input, [&](const void * rawValue, const std::type_info & typeInfo) {
21
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
   176
							for (ValuesHandler* handler : valuesHandlers) handler->attribute(rawValue, typeInfo);
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   177
						}, typeId);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   178
					} else {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   179
						read(input, [&](const string_t& stringValue, const void * rawValue, const std::type_info & typeInfo) {
21
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
   180
							for (StringHandler* handler : stringHandlers) handler->attribute(stringValue);
abd3e7f26584 use for-each and type aliases
František Kučera <franta-hg@frantovo.cz>
parents: 19
diff changeset
   181
							for (ValuesHandler* handler : valuesHandlers) handler->attribute(rawValue, typeInfo);
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   182
						}, typeId);
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   183
					}
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   184
				}
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   185
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   186
			} else {
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   187
				throw RelpipeReaderException(L"Unknown data part");
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   188
			}
17
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
   189
		}
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
   190
18
e11f1ad20826 read using std::function
František Kučera <franta-hg@frantovo.cz>
parents: 17
diff changeset
   191
		throw RelpipeReaderException(L"Unexpected exception"); // should never happen
17
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
   192
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
   193
	}
ec750c536705 interface + dummy implementation
František Kučera <franta-hg@frantovo.cz>
parents: 16
diff changeset
   194
14
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
   195
};
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
   196
e8de089f95dd refactoring, move files, use TypeId instead of integer_t
František Kučera <franta-hg@frantovo.cz>
parents:
diff changeset
   197
}
19
3e1308e7606d add endOfPipe() to handlers
František Kučera <franta-hg@frantovo.cz>
parents: 18
diff changeset
   198
}