relpipe/relpipe-tr-sql.cpp: src/SqlHandler.h@0b932e05aa9f (annotated)

0 c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	1	/**
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	2	* Relational pipes
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	3	* Copyright © 2019 František Kučera (Frantovo.cz, GlobalCode.info)
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	4	*
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	5	* This program is free software: you can redistribute it and/or modify
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	6	* it under the terms of the GNU General Public License as published by
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	7	* the Free Software Foundation, either version 3 of the License, or
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	8	* (at your option) any later version.
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	9	*
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	10	* This program is distributed in the hope that it will be useful,
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	11	* but WITHOUT ANY WARRANTY; without even the implied warranty of
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	12	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	13	* GNU General Public License for more details.
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	14	*
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	15	* You should have received a copy of the GNU General Public License
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	16	* along with this program. If not, see <http://www.gnu.org/licenses/>.
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	17	*/
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	18	#pragma once
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	19
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	20	#include <memory>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	21	#include <string>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	22	#include <vector>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	23	#include <locale>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	24	#include <codecvt>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	25
1 eb7134dfdcc5 link to the sqlite3 library František Kučera <franta-hg@frantovo.cz> parents: 0 diff changeset	26	#include <sqlite3.h>
eb7134dfdcc5 link to the sqlite3 library František Kučera <franta-hg@frantovo.cz> parents: 0 diff changeset	27
0 c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	28	#include <relpipe/reader/typedefs.h>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	29	#include <relpipe/reader/TypeId.h>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	30	#include <relpipe/reader/handlers/RelationalReaderStringHandler.h>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	31	#include <relpipe/reader/handlers/AttributeMetadata.h>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	32
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	33	#include <relpipe/writer/Factory.h>
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	34
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	35	#include "Configuration.h"
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	36	#include "SqlException.h"
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	37
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	38	namespace relpipe {
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	39	namespace tr {
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	40	namespace sql {
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	41
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	42	using namespace std;
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	43	using namespace relpipe;
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	44	using namespace relpipe::reader;
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	45	using namespace relpipe::reader::handlers;
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	46
3 0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	47	class PreparedStatement {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	48	private:
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	49	sqlite3_stmt* stmt;
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	50
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	51	public:
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	52
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	53	PreparedStatement(sqlite3_stmt* stmt) : stmt(stmt) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	54	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	55
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	56	virtual ~PreparedStatement() {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	57	sqlite3_finalize(stmt);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	58	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	59
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	60	void setString(int parameterIndex, std::string value) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	61	int result = sqlite3_bind_text(stmt, parameterIndex, value.c_str(), -1, SQLITE_TRANSIENT);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	62	if (result != SQLITE_OK) throw SqlException(L"Unable to set SQLite parameter.");
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	63	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	64
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	65	void setNull(int parameterIndex) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	66	int result = sqlite3_bind_null(stmt, parameterIndex);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	67	if (result != SQLITE_OK) throw SqlException(L"Unable to set SQLite parameter.");
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	68	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	69
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	70	bool next() {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	71	int result = sqlite3_step(stmt);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	72	if (result == SQLITE_ROW) return true;
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	73	else if (result == SQLITE_DONE) return false;
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	74	else throw SqlException(L"Error while iterating over SQLite result.");
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	75	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	76
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	77	int getColumnCount() {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	78	return sqlite3_column_count(stmt);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	79	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	80
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	81	std::string getColumName(int columnIndex) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	82	const char* name = sqlite3_column_name(stmt, columnIndex);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	83	if (name) return name;
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	84	else throw SqlException(L"Unable to get SQLite column name.");
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	85	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	86
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	87	// TODO: sqlite3_column_type
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	88
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	89	std::string getString(int columnIndex) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	90	return (char *) sqlite3_column_text(stmt, columnIndex);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	91	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	92
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	93	};
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	94
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	95	class Connection {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	96	private:
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	97	sqlite3* db;
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	98	public:
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	99
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	100	Connection(const char* filename) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	101	int result = sqlite3_open(filename, &db);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	102	if (result != SQLITE_OK) throw SqlException(L"Unable to open SQLite database.");
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	103	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	104
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	105	virtual ~Connection() {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	106	sqlite3_close(db);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	107	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	108
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	109	PreparedStatement prepareStatement(const char* sql) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	110	const char* remaining;
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	111	sqlite3_stmt *stmt;
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	112	int result = sqlite3_prepare(db, sql, -1, &stmt, &remaining);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	113	if (result == SQLITE_OK) return PreparedStatement(stmt);
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	114	else throw SqlException(L"Unable to prepare SQLite statement.");
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	115	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	116
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	117	};
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	118
0 c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	119	class SqlHandler : public RelationalReaderStringHandler {
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	120	private:
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	121	Configuration configuration;
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	122	writer::RelationalWriter* relationalWriter;
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	123	std::wstring_convert<codecvt_utf8<wchar_t>> convertor; // TODO: support also other encodings
3 0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	124	std::unique_ptr<Connection> connection;
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	125
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	126	void processStatement(const Statement& statement) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	127	PreparedStatement prepared = connection->prepareStatement(convertor.to_bytes(statement.sql).c_str());
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	128	int columnCount = prepared.getColumnCount();
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	129	int parameterCount = statement.parameters.size();
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	130
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	131	for (int i = 0; i < parameterCount; i++) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	132	prepared.setString(i + 1, convertor.to_bytes(statement.parameters[i].value));
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	133	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	134
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	135	for (int i = 0; i < columnCount; i++) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	136	printf("column %d ~ %s\n", i, prepared.getColumName(i).c_str());
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	137	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	138
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	139	while (prepared.next()) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	140	for (int i = 0; i < columnCount; i++) {
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	141	printf("column %d ~ %s = %s\n", i, prepared.getColumName(i).c_str(), prepared.getString(i).c_str());
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	142	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	143	}
0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	144	}
0 c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	145
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	146	public:
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	147
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	148	SqlHandler(writer::RelationalWriter* relationalWriter, Configuration& configuration) : relationalWriter(relationalWriter), configuration(configuration) {
3 0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	149	connection.reset(new Connection(":memory:"));
1 eb7134dfdcc5 link to the sqlite3 library František Kučera <franta-hg@frantovo.cz> parents: 0 diff changeset	150	}
eb7134dfdcc5 link to the sqlite3 library František Kučera <franta-hg@frantovo.cz> parents: 0 diff changeset	151
eb7134dfdcc5 link to the sqlite3 library František Kučera <franta-hg@frantovo.cz> parents: 0 diff changeset	152	virtual ~SqlHandler() {
0 c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	153	}
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	154
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	155	void startRelation(string_t name, vector<AttributeMetadata> attributes) override {
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	156
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	157	}
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	158
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	159	void attribute(const string_t& value) override {
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	160
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	161	}
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	162
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	163	void endOfPipe() {
3 0b932e05aa9f sqlite wrapper objects + execute query František Kučera <franta-hg@frantovo.cz> parents: 1 diff changeset	164	for (const Statement& statement : configuration.statements) processStatement(statement);
0 c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	165	}
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	166
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	167	};
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	168
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	169	}
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	170	}
c205f5d06418 project skeleton František Kučera <franta-hg@frantovo.cz> parents: diff changeset	171	}

author	František Kučera <franta-hg@frantovo.cz>
	Tue, 30 Jul 2019 14:01:21 +0200
branch	v_0
changeset 3	0b932e05aa9f
parent 1	eb7134dfdcc5
child 4	925b15fb5c63
permissions	-rw-r--r--