13 #ifndef PQXX_H_STREAM_FROM 14 #define PQXX_H_STREAM_FROM 16 #if !defined(PQXX_HEADER_PRE) 17 # error "Include libpqxx headers as <pqxx/header>, not <pqxx/header.hxx>." 23 #include "pqxx/connection.hxx" 24 #include "pqxx/except.hxx" 25 #include "pqxx/internal/concat.hxx" 26 #include "pqxx/internal/encoding_group.hxx" 27 #include "pqxx/internal/stream_iterator.hxx" 28 #include "pqxx/separated_list.hxx" 29 #include "pqxx/transaction_focus.hxx" 82 std::pair<std::unique_ptr<char, void(*)(void const *)>, std::size_t>;
97 [[deprecated(
"Use transaction_base::stream instead.")]]
static stream_from 100 #include "pqxx/internal/ignore-deprecated-pre.hxx" 102 #include "pqxx/internal/ignore-deprecated-post.hxx" 133 [[deprecated(
"Use transaction_base::stream instead.")]]
static stream_from 136 std::string_view columns =
""sv);
141 [[deprecated(
"Use transaction_base::stream instead.")]]
static stream_from 144 std::initializer_list<std::string_view> columns = {});
150 [[deprecated(
"Use transaction_base::stream instead.")]]
stream_from(
156 [[deprecated(
"Use transaction_base::stream instead.")]] stream_from(
162 template<
typename Iter>
163 [[deprecated(
"Use transaction_base::stream instead.")]] stream_from(
165 Iter columns_begin, Iter columns_end);
170 template<
typename Columns>
171 [[deprecated(
"Use transaction_base::stream() instead.")]] stream_from(
173 Columns
const &columns);
175 #include "pqxx/internal/ignore-deprecated-pre.hxx" 177 [[deprecated(
"Use transaction_base::stream instead.")]]
stream_from(
181 #include "pqxx/internal/ignore-deprecated-post.hxx" 184 template<
typename Columns>
185 [[deprecated(
"Use transaction_base::stream instead.")]]
stream_from(
191 template<
typename Iter>
192 [[deprecated(
"Use transaction_base::stream instead.")]] stream_from(
196 ~stream_from() noexcept;
199 [[nodiscard]] constexpr
operator bool() const noexcept
201 return not m_finished;
226 template<
typename Tuple> stream_from &operator>>(Tuple &);
229 template<
typename... Vs>
230 stream_from &operator>>(std::variant<Vs...> &) =
delete;
237 template<
typename... TYPE> [[nodiscard]]
auto iter() &
239 return pqxx::internal::stream_input_iteration<TYPE...>{*
this};
259 std::vector<zview>
const *read_row() &;
278 template<
typename Tuple, std::size_t... indexes>
279 void extract_fields(Tuple &t, std::index_sequence<indexes...>)
const 281 (extract_value<Tuple, indexes>(t), ...);
284 pqxx::internal::char_finder_func *m_char_finder;
290 std::vector<zview> m_fields;
292 bool m_finished =
false;
296 template<
typename Tuple, std::
size_t index>
297 void extract_value(Tuple &)
const;
304 template<
typename Columns>
307 Columns
const &columns) :
309 tx,
from_table, table_name, std::begin(columns), std::end(columns)}
313 template<
typename Iter>
316 Iter columns_begin, Iter columns_end) :
326 PQXX_UNLIKELY
return *
this;
327 static constexpr
auto tup_size{std::tuple_size_v<Tuple>};
328 m_fields.reserve(tup_size);
331 PQXX_UNLIKELY
return *
this;
333 if (std::size(m_fields) != tup_size)
335 "Tried to extract ", tup_size,
" field(s) from a stream of ",
336 std::size(m_fields),
".")};
338 extract_fields(t, std::make_index_sequence<tup_size>{});
343 template<
typename Tuple, std::
size_t index>
344 inline void stream_from::extract_value(Tuple &t)
const 348 assert(index < std::size(m_fields));
349 if constexpr (nullity::always_null)
351 if (std::data(m_fields[index]) !=
nullptr)
354 else if (std::data(m_fields[index]) ==
nullptr)
356 if constexpr (nullity::has_null)
357 std::get<index>(t) = nullity::null();
364 std::get<index>(t) = from_string<field_type>(m_fields[index]);
Error in usage of libpqxx library, similar to std::logic_error.
Definition: except.hxx:237
Stream data from the database.
Definition: stream_from.hxx:78
Interface definition (and common code) for "transaction" classes.
Definition: transaction_base.hxx:87
Value conversion failed, e.g. when converting "Hello" to int.
Definition: except.hxx:267
std::remove_cv_t< std::remove_reference_t< TYPE > > strip_t
Remove any constness, volatile, and reference-ness from a type.
Definition: types.hxx:91
The home of all libpqxx classes, functions, templates, etc.
Definition: array.hxx:32
Marker for stream_from constructors: "stream from table.".
Definition: types.hxx:67
Traits describing a type's "null value," if any.
Definition: strconv.hxx:92
static stream_from query(transaction_base &tx, std::string_view q)
Factory: Execute query, and stream the results.
Definition: stream_from.hxx:98
void PQXX_COLD throw_null_conversion(std::string const &type)
Definition: strconv.cxx:253
stream_from(transaction_base &tx, std::string_view table, Columns const &columns)
End a code block started by "ignore-deprecated-pre.hxx".
Definition: stream_from.hxx:185
constexpr from_table_t from_table
Pass this to a stream_from constructor to stream table contents.
Definition: stream_from.hxx:34
constexpr from_query_t from_query
Pass this to a stream_from constructor to stream query results.
Definition: stream_from.hxx:44
std::initializer_list< std::string_view > table_path
Representation of a PostgreSQL table path.
Definition: connection.hxx:185
auto iter() &
Iterate over this stream. Supports range-based "for" loops.
Definition: stream_from.hxx:237
Base class for things that monopolise a transaction's attention.
Definition: transaction_focus.hxx:28
stream_from & operator>>(Tuple &)
Read one row into a tuple.
Definition: stream_from.hxx:323
std::string separated_list(std::string_view sep, ITER begin, ITER end, ACCESS access)
Represent sequence of values as a string, joined by a given separator.
Definition: separated_list.hxx:44
Marker for stream_from constructors: "stream from query.".
Definition: types.hxx:73
static stream_from table(transaction_base &tx, table_path path, std::initializer_list< std::string_view > columns={})
Factory: Stream data from a given table.
Definition: stream_from.cxx:87
std::pair< std::unique_ptr< char, void(*)(void const *)>, std::size_t > raw_line
Definition: stream_from.hxx:82
stream_from(transaction_base &tx, std::string_view table)
Definition: stream_from.hxx:177
stream_from(stream_from &&)=delete
constexpr bool operator!() const noexcept
Has this stream produced all the data it is going to produce?
Definition: stream_from.hxx:204