postgresql_async_streaming_source.hpp File Reference

#include "../results/streaming_result.hpp"
#include "postgresql_async_connection.hpp"
#include <memory>
#include <optional>
#include <string>
#include <vector>
#include <boost/asio.hpp>
#include <boost/asio/awaitable.hpp>

Go to the source code of this file.

Classes
struct	relx::connection::is_awaitable< T >
	Helper trait to detect if a type is boost::asio::awaitable. More...
struct	relx::connection::is_awaitable< boost::asio::awaitable< T > >
class	relx::connection::PostgreSQLAsyncStreamingSource
	Async PostgreSQL streaming data source for processing large result sets. More...
class	relx::connection::AsyncStreamingResultSet< DataSource >
	Async streaming result set that yields rows asynchronously. More...
class	relx::connection::AsyncStreamingResultSet< DataSource >::async_streaming_iterator
	Iterator that reads data on demand asynchronously. More...

Namespaces
namespace	relx
	relx database connection
namespace	relx::connection

Typedefs
using	PGconn = pg_conn

Functions
template<typename... Args>
AsyncStreamingResultSet< PostgreSQLAsyncStreamingSource >	relx::connection::create_async_streaming_result (PostgreSQLAsyncConnection &connection, const std::string &sql, Args &&... args)
	Create an async streaming result set from a PostgreSQL async connection and query.

Variables
template<typename T >
constexpr bool	relx::connection::is_awaitable_v = is_awaitable<T>::value

Typedef Documentation

PGconn

using PGconn = pg_conn

Definition at line 16 of file postgresql_async_streaming_source.hpp.