connection.hxx

#ifndef PQXX_H_CONNECTION
#define PQXX_H_CONNECTION

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

#include "pqxx/connectionpolicy.hxx"
#include "pqxx/basic_connection.hxx"

namespace pqxx
{


class PQXX_LIBEXPORT connect_direct : public connectionpolicy
{
public:
  explicit connect_direct(const std::string &opts) : connectionpolicy{opts} {}
  virtual handle do_startconnect(handle) override;
};

using connection = basic_connection_base<connect_direct>;



class PQXX_LIBEXPORT connect_lazy : public connectionpolicy
{
public:
  explicit connect_lazy(const std::string &opts) : connectionpolicy{opts} {}
  virtual handle do_completeconnect(handle) override;
};


using lazyconnection = basic_connection_base<connect_lazy>;



class PQXX_LIBEXPORT connect_async : public connectionpolicy
{
public:
  explicit connect_async(const std::string &opts);
  virtual handle do_startconnect(handle) override;
  virtual handle do_completeconnect(handle) override;
  virtual handle do_dropconnect(handle) noexcept override;
  virtual bool is_ready(handle) const noexcept override;

private:
  bool m_connecting;
};


using asyncconnection = basic_connection_base<connect_async>;



class PQXX_LIBEXPORT connect_null  : public connectionpolicy
{
public:
  explicit connect_null(const std::string &opts) : connectionpolicy{opts} {}
};


using nullconnection = basic_connection_base<connect_null>;

}

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

#endif