Add fetch variant that takes an existing DB connection, suitable for use in transaction blocks etcicetray-0.1.4

1 files changed, 9 insertions, 1 deletions

diff --git a/icetray/icetray/abstractDatabaseClient.h b/icetray/icetray/abstractDatabaseClient.h
index 4c65ff7..3242553 100644
--- a/icetray/icetray/abstractDatabaseClient.h
+++ b/icetray/icetray/abstractDatabaseClient.h
@@ -18,7 +18,15 @@ namespace IceTray {
 			fetch(const SqlSource & sql, const Params & ... params)
 			{
 				auto c = db->get();
-				auto s = sql.select(c.get());
+				return fetch<Domain, Params...>(c.get(), sql, params...);
+			}
+
+			template<typename Domain, typename ... Params>
+			inline
+			Domain
+			fetch(DB::Connection * c, const SqlSource & sql, const Params & ... params)
+			{
+				auto s = sql.select(c);
 				bind(0, s.get(), params...);
 				return Slicer::DeserializeAny<Slicer::SqlSelectDeserializer, Domain>(*s);
 			}