6#if !defined(PQXX_H_STREAM_QUERY_IMPL)
7# define PQXX_H_STREAM_QUERY_IMPL
11template<
typename...
TYPE>
13 transaction_base &
tx, std::string_view query) :
17 if (
r.columns() !=
sizeof...(TYPE))
19 "Parsing query stream with wrong number of columns: "
21 sizeof...(
TYPE),
" but query returns ",
r.columns(),
".")};
26template<
typename...
TYPE>
45 using value_type = std::tuple<
TYPE...>;
46 using difference_type =
long;
50 m_line{
typename stream_query<TYPE...>::line_handle(
94 m_line = std::move(
rhs.m_line);
96 m_line_size =
rhs.m_line_size;
102 stream_query_input_iterator() {}
111 void consume_line() &
114 m_line = std::move(
line);
121 char *
const ptr{m_line.get()};
130 typename stream_t::line_handle m_line;
133 std::size_t m_line_size;
137template<
typename...
TYPE>
138inline bool operator==(
145template<
typename...
TYPE>
146inline bool operator!=(
159template<
typename...
TYPE>
165 internal::gate::connection_stream_from gate{m_trans->conn()};
168 auto line{gate.read_copy_line()};
171 PQXX_UNLIKELY close();
174 catch (std::exception
const &)
Stream query results from the database. Used by transaction_base::stream.
Definition stream_query.hxx:80
bool done() const &noexcept
Has this stream reached the end of its data?
Definition stream_query.hxx:103
stream_query(transaction_base &tx, std::string_view query)
Execute query on tx, stream results.
Definition stream_query_impl.hxx:12
std::tuple< TYPE... > parse_line(zview line) &
Parse and convert the latest line of data we received.
Definition stream_query.hxx:115
auto begin() &
Begin iterator. Only for use by "range for.".
Definition stream_query_impl.hxx:153
std::pair< line_handle, std::size_t > read_line() &
Read a COPY line from the server.
Definition stream_query_impl.hxx:161
Base class for things that monopolise a transaction's attention.
Definition transaction_focus.hxx:29
Marker-type wrapper: zero-terminated std::string_view.
Definition zview.hxx:38
Error in usage of libpqxx library, similar to std::logic_error.
Definition except.hxx:249
void pqfreemem(void const *ptr) noexcept
Wrapper for PQfreemem(), with C++ linkage.
Definition util.cxx:205
Internal items for libpqxx' own use. Do not use these yourself.
Definition encodings.cxx:33
std::string concat(TYPE... item)
Efficiently combine a bunch of items into one big string.
Definition concat.hxx:31
pqxx::internal::encoding_group enc_group(std::string_view encoding_name)
Convert libpq encoding name to its libpqxx encoding group.
Definition encodings.cxx:35
std::size_t(std::string_view haystack, std::size_t start) char_finder_func
Function type: "find first occurrence of specific any of ASCII characters.".
Definition encoding_group.hxx:70
The end() iterator for a stream_query.
Definition stream_query.hxx:47
constexpr char array_separator
Element separator between SQL array elements of this type.
Definition strconv.hxx:558