sql_pusher.cc
f916dcd8f847master

sql_pusher.cc
View Options

			template<typename type, bool is_scalar>
			void SqlPusher<type, is_scalar>::operator()(transaction & trans) {
			std::stringstream command;
			command << "INSERT INTO " << pqxx::to_string(input.tablename)
			<< " (run_id, quantity_id, measurement, step) VALUES ("
			<< pqxx::to_string(input.run_id) << ", " << pqxx::to_string(input.quantity_id) << ", ARRAY["
			<< this->template nan_avoider<type>((*input.value)[0]);
			for (UInt i = 1; i < input.value->size(); ++i) {
			command << ", " << nan_avoider((*input.value)[i]);
			}

			command << "], " << input.step << ");";

			try {
			trans.exec(command);
			} catch (std::runtime_error & e) {
			FATAL("Failed to execute query: "
			<< command.str() << std::endl << " with message: " << e.what());
			}
			}

			/* -------------------------------------------------------------------------- */


			template<typename type>
			void SqlPusher<type, true>::operator()(transaction & trans) {
			std::stringstream command;
			command << "INSERT INTO " << input.tablename
			<< " (run_id, quantity_id, measurement, step) VALUES ("
			<< pqxx::to_string(input.run_id) << ", "
			<< pqxx::to_string(input.quantity_id) << ", "
			<< this->template nan_avoider(*input.value) << ", "
			<< pqxx::to_string(input.step) << ");";
			trans.exec(command);
			}