stream_base.hxx

#ifndef PQXX_H_STREAM_BASE
#define PQXX_H_STREAM_BASE

#include "pqxx/compiler-public.hxx"
#include "pqxx/compiler-internal-pre.hxx"
#include "pqxx/transaction_base.hxx"
#include "pqxx/util.hxx"

#include <string>


namespace pqxx
{

class PQXX_LIBEXPORT PQXX_NOVTABLE stream_base :
  public internal::transactionfocus
{
public:
  explicit stream_base(transaction_base &);
  // TODO: Can we get rid of the vtable?
  virtual ~stream_base() noexcept =default;
  virtual void complete() = 0;
  operator bool() const noexcept;
  bool operator!() const noexcept;
protected:
  bool m_finished;
  virtual void close();
  template<typename C> static std::string columnlist(const C &);
  template<typename I> static std::string columnlist(I begin, I end);
private:
  stream_base();
  stream_base(const stream_base&);
  stream_base & operator=(const stream_base &);
};

template<typename C> std::string stream_base::columnlist(const C &c)
{
  return columnlist(std::begin(c), std::end(c));
}

template<typename I> std::string stream_base::columnlist(I begin, I end)
{
  return separated_list(",", begin, end);
}

} // namespace pqxx


#include "pqxx/compiler-internal-post.hxx"
#endif