sql_pusher_inline_impl.cc
37bdc45cff01multiuser

sql_pusher_inline_impl.cc
View Options


			template<typename type, bool is_scalar>
			void Pusher::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["
			<< nan_avoider((*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 Pusher::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) << ", "
			<< nan_avoider(*input.value) << ", "
			<< pqxx::to_string(input.step) << ");";
			trans.exec(command);
			}


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