src/StreamRelationalWriter.h
branchv_0
changeset 26 8ae93a43fed2
parent 25 135ef93a4ac2
child 27 a64afb2d24c9
equal deleted inserted replaced
25:135ef93a4ac2 26:8ae93a43fed2
    60 	TypeId toTypeId(const string_t typeCode) override {
    60 	TypeId toTypeId(const string_t typeCode) override {
    61 		for (DataTypeWriterBase* writer : writers) if (writer->supports(typeCode)) return writer->getTypeId();
    61 		for (DataTypeWriterBase* writer : writers) if (writer->supports(typeCode)) return writer->getTypeId();
    62 		throw RelpipeWriterException(L"Unsupported data type: " + typeCode);
    62 		throw RelpipeWriterException(L"Unsupported data type: " + typeCode);
    63 	}
    63 	}
    64 
    64 
    65 	string_t toTypeCode(const TypeId typeId) override {
       
    66 		for (DataTypeWriterBase* writer : writers) if (writer->supports(typeId)) return writer->getTypeCode();
       
    67 		throw RelpipeWriterException(L"Unsupported data type: " + static_cast<integer_t> (typeId));
       
    68 	}
       
    69 
       
    70 	void startRelation(string_t name, std::vector<std::pair<string_t, TypeId> > attributes, boolean_t writeHeader) override {
    65 	void startRelation(string_t name, std::vector<std::pair<string_t, TypeId> > attributes, boolean_t writeHeader) override {
    71 		string_t tableName = name;
    66 		string_t tableName = name;
    72 		columnCount = attributes.size();
    67 		columnCount = attributes.size();
    73 		currentColumn = 0;
    68 		currentColumn = 0;
    74 
    69