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 r.expect_columns(
sizeof...(TYPE));
23template<
typename... TYPE>
25 transaction_base &tx, std::string_view query, params
const &parms) :
28 auto const r{tx.exec(
internal::concat(
"COPY (", query,
") TO STDOUT"), parms)
30 if (r.columns() !=
sizeof...(TYPE))
32 "Parsing query stream with wrong number of columns: "
34 sizeof...(TYPE),
" but query returns ", r.columns(),
".")};
39template<
typename... TYPE>
43 auto const group{
enc_group(tx.conn().encoding_id())};
44 return get_s_char_finder<'\t', '\\'>(group);
58 using value_type = std::tuple<TYPE...>;
59 using difference_type = long;
63 m_line{
typename stream_query<TYPE...>::line_handle(
107 m_line = std::move(rhs.m_line);
109 m_line_size = rhs.m_line_size;
115 stream_query_input_iterator() {}
118 bool done() const noexcept {
return m_home->
done(); }
124 void consume_line() &
127 m_line = std::move(line);
134 char *
const ptr{m_line.get()};
135 assert(ptr[size] ==
'\n');
143 typename stream_t::line_handle m_line;
146 std::size_t m_line_size;
150template<
typename... TYPE>
151inline bool operator==(
152 stream_query_end_iterator, stream_query_input_iterator<TYPE...>
const &i)
158template<
typename... TYPE>
159inline bool operator!=(
160 stream_query_end_iterator, stream_query_input_iterator<TYPE...>
const &i)
172template<
typename... TYPE>
173inline std::pair<
typename stream_query<TYPE...>::line_handle, std::size_t>
178 internal::gate::connection_stream_from gate{m_trans->conn()};
181 auto line{gate.read_copy_line()};
184 PQXX_UNLIKELY close();
187 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:106
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:118
auto begin() &
Begin iterator. Only for use by "range for.".
Definition stream_query_impl.hxx:166
std::pair< line_handle, std::size_t > read_line() &
Read a COPY line from the server.
Definition stream_query_impl.hxx:174
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