\n- \n+ \n
\n blob.hxx
stream_from.hxx
\n-
\n+, not .\"\n 18#endif\n 19\n- 20#include \n- 21\n- 22#if defined(PQXX_HAVE_PATH)\n- 23# include \n- 24#endif\n- 25\n- 26#if defined(PQXX_HAVE_RANGES) && __has_include()\n- 27# include \n- 28#endif\n- 29\n- 30#if defined(PQXX_HAVE_SPAN) && __has_include()\n- 31# include \n- 32#endif\n- 33\n- 34#include \"pqxx/dbtransaction.hxx\"\n+ 20#include \n+ 21#include \n+ 22\n+ 23#include \"pqxx/connection.hxx\"\n+ 24#include \"pqxx/except.hxx\"\n+ 25#include \"pqxx/internal/concat.hxx\"\n+ 26#include \"pqxx/internal/encoding_group.hxx\"\n+ 27#include \"pqxx/internal/stream_iterator.hxx\"\n+ 28#include \"pqxx/separated_list.hxx\"\n+ 29#include \"pqxx/transaction_focus.hxx\"\n+ 30\n+ 31\n+ 32namespace pqxx\n+ 33{\n+ 34class transaction_base;\n 35\n 36\n- 37namespace pqxx\n- 38{\n-52class PQXX_LIBEXPORT blob\n- 53{\n- 54public:\n- 56\n- 60 [[nodiscard]] static oid create(dbtransaction &, oid = 0);\n- 61\n- 63 static void remove(dbtransaction &, oid);\n- 64\n- 66 [[nodiscard]] static blob open_r(dbtransaction &, oid);\n- 67 // Open blob for writing. Any attempt to read from it will fail.\n- 68 [[nodiscard]] static blob open_w(dbtransaction &, oid);\n- 69 // Open blob for reading and/or writing.\n- 70 [[nodiscard]] static blob open_rw(dbtransaction &, oid);\n- 71\n- 73\n-76 blob() = default;\n- 77\n- 79 blob(blob &&);\n- 81 blob &operator=(blob &&);\n- 82\n-83 blob(blob const &) = delete;\n-84 blob &operator=(blob const &) = delete;\n- 85 ~blob();\n+ 38\n+40constexpr from_table_t from_table;\n+ 42\n+44constexpr from_query_t from_query;\n+ 45\n+ 46\n+ 48\n+78class PQXX_LIBEXPORT stream_from : transaction_focus\n+ 79{\n+ 80public:\n+81 using raw_line =\n+ 82 std::pair, std::size_t>;\n+ 83\n+84 stream_from(stream_from &&) = delete;\n+85 stream_from &operator=(stream_from &&) = delete;\n 86\n 88\n-94 static constexpr std::size_t chunk_limit = 0x7fffffff;\n- 95\n- 97\n- 105 std::size_t read(std::basic_string &buf, std::size_t size);\n- 106\n- 107#if defined(PQXX_HAVE_SPAN)\n- 109\n- 114 template\n- 115 std::span read(std::span buf)\n- 116 {\n- 117 return buf.subspan(0, raw_read(std::data(buf), std::size(buf)));\n- 118 }\n- 119#endif // PQXX_HAVE_SPAN\n- 120\n- 121#if defined(PQXX_HAVE_CONCEPTS) && defined(PQXX_HAVE_SPAN)\n- 123\n- 128 template std::span read(DATA &buf)\n- 129 {\n- 130 return {std::data(buf), raw_read(std::data(buf), std::size(buf))};\n- 131 }\n- 132#else // PQXX_HAVE_CONCEPTS && PQXX_HAVE_SPAN\n- 134\n- 146 template\n-147 std::basic_string_view read(std::vector &buf)\n- 148 {\n- 149 return {std::data(buf), raw_read(std::data(buf), std::size(buf))};\n- 150 }\n- 151#endif // PQXX_HAVE_CONCEPTS && PQXX_HAVE_SPAN\n+ 97 [[deprecated(\"Use transaction_base::stream instead.\")]] static stream_from\n+98 query(transaction_base &tx, std::string_view q)\n+ 99 {\n+ 100#include \"pqxx/internal/ignore-deprecated-pre.hxx\"\n+ 101 return {tx, from_query, q};\n+ 102#include \"pqxx/internal/ignore-deprecated-post.hxx\"\n+ 103 }\n+ 104\n+ 115\n+ 117\n+ 133 [[deprecated(\"Use transaction_base::stream instead.\")]] static stream_from\n+ 134 raw_table(\n+ 135 transaction_base &tx, std::string_view path,\n+ 136 std::string_view columns = \"\"sv);\n+ 137\n+ 139\n+ 141 [[deprecated(\"Use transaction_base::stream instead.\")]] static stream_from\n+ 142 table(\n+ 143 transaction_base &tx, table_path path,\n+ 144 std::initializer_list columns = {});\n+ 146\n+ 148\n+ 150 [[deprecated(\"Use transaction_base::stream instead.\")]] stream_from(\n+ 151 transaction_base &, from_query_t, std::string_view query);\n 152\n- 153#if defined(PQXX_HAVE_CONCEPTS)\n- 155\n- 173 template void write(DATA const &data)\n- 174 {\n- 175 raw_write(std::data(data), std::size(data));\n- 176 }\n- 177#else\n- 179\n-197 template void write(DATA const &data)\n- 198 {\n- 199 raw_write(std::data(data), std::size(data));\n- 200 }\n- 201#endif\n- 202\n- 204\n- 210 void resize(std::int64_t size);\n- 211\n- 213 [[nodiscard]] std::int64_t tell() const;\n- 214\n- 216\n- 217 std::int64_t seek_abs(std::int64_t offset = 0);\n+ 154\n+ 156 [[deprecated(\"Use transaction_base::stream instead.\")]] stream_from(\n+ 157 transaction_base &, from_table_t, std::string_view table);\n+ 158\n+ 160\n+ 162 template\n+ 163 [[deprecated(\"Use transaction_base::stream instead.\")]] stream_from(\n+ 164 transaction_base &, from_table_t, std::string_view table,\n+ 165 Iter columns_begin, Iter columns_end);\n+ 166\n+ 168\n+ 170 template\n+ 171 [[deprecated(\"Use transaction_base::stream() instead.\")]] stream_from(\n+ 172 transaction_base &tx, from_table_t, std::string_view table,\n+ 173 Columns const &columns);\n+ 174\n+ 175#include \"pqxx/internal/ignore-deprecated-pre.hxx\"\n+177 [[deprecated(\"Use transaction_base::stream instead.\")]] stream_from(\n+ 178 transaction_base &tx, std::string_view table) :\n+ 179 stream_from{tx, from_table, table}\n+ 180 {}\n+ 181#include \"pqxx/internal/ignore-deprecated-post.hxx\"\n+ 182\n+ 184 template\n+185 [[deprecated(\"Use transaction_base::stream instead.\")]] stream_from(\n+ 186 transaction_base &tx, std::string_view table, Columns const &columns) :\n+ 187 stream_from{tx, from_table, table, columns}\n+ 188 {}\n+ 189\n+ 191 template\n+192 [[deprecated(\"Use transaction_base::stream instead.\")]] stream_from(\n+ 193 transaction_base &, std::string_view table, Iter columns_begin,\n+ 194 Iter columns_end);\n+ 195\n+ 196 ~stream_from() noexcept;\n+ 197\n+199 [[nodiscard]] constexpr operator bool() const noexcept\n+ 200 {\n+ 201 return not m_finished;\n+ 202 }\n+204 [[nodiscard]] constexpr bool operator!() const noexcept\n+ 205 {\n+ 206 return m_finished;\n+ 207 }\n+ 208\n+ 210\n+ 216 void complete();\n+ 217\n 219\n- 223 std::int64_t seek_rel(std::int64_t offset = 0);\n- 225\n- 229 std::int64_t seek_end(std::int64_t offset = 0);\n- 230\n- 232\n- 235 static oid from_buf(\n- 236 dbtransaction &tx, std::basic_string_view data, oid id = 0);\n- 237\n- 239\n- 241 static void append_from_buf(\n- 242 dbtransaction &tx, std::basic_string_view data, oid id);\n+ 226 template stream_from &operator>>(Tuple &);\n+ 227\n+ 229 template\n+230 stream_from &operator>>(std::variant &) = delete;\n+ 231\n+ 233\n+237 template [[nodiscard]] auto iter() &\n+ 238 {\n+ 239 return pqxx::internal::stream_input_iteration{*this};\n+ 240 }\n+ 241\n 243\n- 245 [[nodiscard]] static oid from_file(dbtransaction &, char const path[]);\n- 246\n- 247#if defined(PQXX_HAVE_PATH) && !defined(_WIN32)\n- 249\n- 252 [[nodiscard]] static oid\n- 253 from_file(dbtransaction &tx, std::filesystem::path const &path)\n- 254 {\n- 255 return from_file(tx, path.c_str());\n- 256 }\n- 257#endif\n- 258\n+ 259 std::vector const *read_row() &;\n 260\n- 263 static oid from_file(dbtransaction &, char const path[], oid);\n+ 262\n+ 263 raw_line get_raw_line();\n 264\n- 265#if defined(PQXX_HAVE_PATH) && !defined(_WIN32)\n- 267\n- 273 static oid\n- 274 from_file(dbtransaction &tx, std::filesystem::path const &path, oid id)\n- 275 {\n- 276 return from_file(tx, path.c_str(), id);\n- 277 }\n- 278#endif\n- 279\n- 281\n- 284 static void to_buf(\n- 285 dbtransaction &, oid, std::basic_string &,\n- 286 std::size_t max_size);\n- 287\n- 289\n- 295 static std::size_t append_to_buf(\n- 296 dbtransaction &tx, oid id, std::int64_t offset,\n- 297 std::basic_string &buf, std::size_t append_max);\n+ 265private:\n+ 266 // TODO: Clean up this signature once we cull the deprecated constructors.\n+ 268 stream_from(\n+ 269 transaction_base &tx, std::string_view table, std::string_view columns,\n+ 270 from_table_t);\n+ 271\n+ 272 // TODO: Clean up this signature once we cull the deprecated constructors.\n+ 274 stream_from(\n+ 275 transaction_base &, std::string_view unquoted_table,\n+ 276 std::string_view columns, from_table_t, int);\n+ 277\n+ 278 template\n+ 279 void extract_fields(Tuple &t, std::index_sequence) const\n+ 280 {\n+ 281 (extract_value(t), ...);\n+ 282 }\n+ 283\n+ 284 pqxx::internal::char_finder_func *m_char_finder;\n+ 285\n+ 287 std::string m_row;\n+ 288\n+ 290 std::vector m_fields;\n+ 291\n+ 292 bool m_finished = false;\n+ 293\n+ 294 void close();\n+ 295\n+ 296 template\n+ 297 void extract_value(Tuple &) const;\n 298\n- 300 static void to_file(dbtransaction &, oid, char const path[]);\n- 301\n- 302#if defined(PQXX_HAVE_PATH) && !defined(_WIN32)\n- 304\n- 307 static void\n- 308 to_file(dbtransaction &tx, oid id, std::filesystem::path const &path)\n- 309 {\n- 310 to_file(tx, id, path.c_str());\n- 311 }\n- 312#endif\n- 313\n- 315\n- 326 void close();\n- 327\n- 328private:\n- 329 PQXX_PRIVATE blob(connection &conn, int fd) noexcept :\n- 330 m_conn{&conn}, m_fd{fd}\n- 331 {}\n- 332 static PQXX_PRIVATE blob open_internal(dbtransaction &, oid, int);\n- 333 static PQXX_PRIVATE pqxx::internal::pq::PGconn *\n- 334 raw_conn(pqxx::connection *) noexcept;\n- 335 static PQXX_PRIVATE pqxx::internal::pq::PGconn *\n- 336 raw_conn(pqxx::dbtransaction const &) noexcept;\n- 337 static PQXX_PRIVATE std::string errmsg(connection const *);\n- 338 static PQXX_PRIVATE std::string errmsg(dbtransaction const &tx)\n- 339 {\n- 340 return errmsg(&tx.conn());\n- 341 }\n- 342 PQXX_PRIVATE std::string errmsg() const { return errmsg(m_conn); }\n- 343 PQXX_PRIVATE std::int64_t seek(std::int64_t offset, int whence);\n- 344 std::size_t raw_read(std::byte buf[], std::size_t size);\n- 345 void raw_write(std::byte const buf[], std::size_t size);\n- 346\n- 347 connection *m_conn = nullptr;\n- 348 int m_fd = -1;\n- 349};\n- 350} // namespace pqxx\n- 351#endif\n+ 300 void parse_line();\n+ 301};\n+ 302\n+ 303\n+ 304template\n+305inline stream_from::stream_from(\n+ 306 transaction_base &tx, from_table_t, std::string_view table_name,\n+ 307 Columns const &columns) :\n+ 308 stream_from{\n+ 309 tx, from_table, table_name, std::begin(columns), std::end(columns)}\n+ 310{}\n+ 311\n+ 312\n+ 313template\n+314inline stream_from::stream_from(\n+ 315 transaction_base &tx, from_table_t, std::string_view table,\n+ 316 Iter columns_begin, Iter columns_end) :\n+ 317 stream_from{\n+ 318 tx, table, separated_list(\",\", columns_begin, columns_end),\n+ 319 from_table, 1}\n+ 320{}\n+ 321\n+ 322\n+323template inline stream_from &stream_from::operator>>(Tuple\n+&t)\n+ 324{\n+ 325 if (m_finished)\n+ 326 PQXX_UNLIKELY return *this;\n+ 327 static constexpr auto tup_size{std::tuple_size_v};\n+ 328 m_fields.reserve(tup_size);\n+ 329 parse_line();\n+ 330 if (m_finished)\n+ 331 PQXX_UNLIKELY return *this;\n+ 332\n+ 333 if (std::size(m_fields) != tup_size)\n+ 334 throw usage_error{internal::concat(\n+ 335 \"Tried to extract \", tup_size, \" field(s) from a stream of \",\n+ 336 std::size(m_fields), \".\")};\n+ 337\n+ 338 extract_fields(t, std::make_index_sequence{});\n+ 339 return *this;\n+ 340}\n+ 341\n+ 342\n+ 343template\n+ 344inline void stream_from::extract_value(Tuple &t) const\n+ 345{\n+ 346 using field_type = strip_t(t))>;\n+ 347 using nullity = nullness;\n+ 348 assert(index < std::size(m_fields));\n+ 349 if constexpr (nullity::always_null)\n+ 350 {\n+ 351 if (std::data(m_fields[index]) != nullptr)\n+ 352 throw conversion_error{\"Streaming non-null value into null field.\"};\n+ 353 }\n+ 354 else if (std::data(m_fields[index]) == nullptr)\n+ 355 {\n+ 356 if constexpr (nullity::has_null)\n+ 357 std::get(t) = nullity::null();\n+ 358 else\n+ 359 internal::throw_null_conversion(type_name);\n+ 360 }\n+ 361 else\n+ 362 {\n+ 363 // Don't ever try to convert a non-null value to nullptr_t!\n+ 364 std::get(t) = from_string(m_fields[index]);\n+ 365 }\n+ 366}\n+ 367} // namespace pqxx\n+ 368#endif\n pqxx\n The home of all libpqxx classes, functions, templates, etc.\n Definition array.hxx:33\n-pqxx::blob\n-Definition blob.hxx:53\n-pqxx::blob::write\n-void write(DATA const &data)\n-Write data large object, at the current position.\n-Definition blob.hxx:197\n-pqxx::blob::blob\n-blob(blob const &)=delete\n-pqxx::blob::blob\n-blob()=default\n-You can default-construct a blob, but it won't do anything useful.\n-pqxx::blob::read\n-std::basic_string_view< std::byte > read(std::vector< std::byte, ALLOC > &buf)\n-Read up to std::size(buf) bytes from the object.\n-Definition blob.hxx:147\n-pqxx::blob::operator=\n-blob & operator=(blob const &)=delete\n-pqxx::connection\n-Connection to a database.\n-Definition connection.hxx:253\n-pqxx::dbtransaction\n-Abstract transaction base class: bracket transactions on the database.\n-Definition dbtransaction.hxx:54\n+pqxx::separated_list\n+std::string separated_list(std::string_view sep, ITER begin, ITER end, ACCESS\n+access)\n+Represent sequence of values as a string, joined by a given separator.\n+Definition separated_list.hxx:44\n+pqxx::strip_t\n+std::remove_cv_t< std::remove_reference_t< TYPE > > strip_t\n+Remove any constness, volatile, and reference-ness from a type.\n+Definition types.hxx:91\n+pqxx::from_query\n+constexpr from_query_t from_query\n+Pass this to a stream_from constructor to stream query results.\n+Definition stream_from.hxx:44\n+pqxx::from_table\n+constexpr from_table_t from_table\n+Pass this to a stream_from constructor to stream table contents.\n+Definition stream_from.hxx:40\n+pqxx::table_path\n+std::initializer_list< std::string_view > table_path\n+Representation of a PostgreSQL table path.\n+Definition connection.hxx:188\n+pqxx::internal::throw_null_conversion\n+void PQXX_COLD throw_null_conversion(std::string const &type)\n+Definition strconv.cxx:253\n+pqxx::usage_error\n+Error in usage of libpqxx library, similar to std::logic_error.\n+Definition except.hxx:249\n+pqxx::conversion_error\n+Value conversion failed, e.g. when converting \"Hello\" to int.\n+Definition except.hxx:283\n+pqxx::nullness\n+Traits describing a type's \"null value,\" if any.\n+Definition strconv.hxx:93\n+pqxx::stream_from\n+Stream data from the database.\n+Definition stream_from.hxx:79\n+pqxx::stream_from::query\n+static stream_from query(transaction_base &tx, std::string_view q)\n+Factory: Execute query, and stream the results.\n+Definition stream_from.hxx:98\n+pqxx::stream_from::operator>>\n+stream_from & operator>>(std::variant< Vs... > &)=delete\n+Doing this with a std::variant is going to be horrifically borked.\n+pqxx::stream_from::operator>>\n+stream_from & operator>>(Tuple &)\n+Read one row into a tuple.\n+Definition stream_from.hxx:323\n+pqxx::stream_from::stream_from\n+stream_from(transaction_base &tx, std::string_view table, Columns const\n+&columns)\n+Definition stream_from.hxx:185\n+pqxx::stream_from::raw_line\n+std::pair< std::unique_ptr< char, void(*)(void const *)>, std::size_t >\n+raw_line\n+Definition stream_from.hxx:82\n+pqxx::stream_from::stream_from\n+stream_from(stream_from &&)=delete\n+pqxx::stream_from::stream_from\n+stream_from(transaction_base &, std::string_view table, Iter columns_begin,\n+Iter columns_end)\n+pqxx::stream_from::operator=\n+stream_from & operator=(stream_from &&)=delete\n+pqxx::stream_from::stream_from\n+stream_from(transaction_base &tx, std::string_view table)\n+Definition stream_from.hxx:177\n+pqxx::stream_from::iter\n+auto iter() &\n+Iterate over this stream. Supports range-based \"for\" loops.\n+Definition stream_from.hxx:237\n+pqxx::stream_from::operator!\n+constexpr bool operator!() const noexcept\n+Has this stream produced all the data it is going to produce?\n+Definition stream_from.hxx:204\n+pqxx::transaction_base\n+Interface definition (and common code) for \"transaction\" classes.\n+Definition transaction_base.hxx:88\n+pqxx::transaction_focus\n+Base class for things that monopolise a transaction's attention.\n+Definition transaction_focus.hxx:29\n+pqxx::from_table_t\n+Marker for stream_from constructors: \"stream from table.\".\n+Definition types.hxx:68\n+pqxx::from_query_t\n+Marker for stream_from constructors: \"stream from query.\".\n+Definition types.hxx:74\n * include\n * pqxx\n- * blob.hxx\n+ * stream_from.hxx\n * Generated by [doxygen] 1.9.8\n"}]}, {"source1": "./usr/share/doc/libpqxx-doc/html/a00005_source.html", "source2": "./usr/share/doc/libpqxx-doc/html/a00005_source.html", "unified_diff": "@@ -1,15 +1,15 @@\n \n \n \n \n \n \n \n-libpqxx: except.hxx Source File \n+libpqxx: pipeline.hxx Source File \n \n \n \n \n \n \n \n@@ -60,938 +60,199 @@\n \n
\n \n-\n+\n \n-\n+\n \n \n \n \n \n \n \n-\n-\n+\n+\n \n \n \n \n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n \n \n-\n-\n-
\n \n \n \n \n", "details": [{"source1": "html2text {}", "source2": "html2text {}", "unified_diff": "@@ -1,235 +1,344 @@\n \n \n \n \n \n libpqxx\u00a07.8.1\n \n-blob.hxx\n- 1/* Binary Large Objects interface.\n+stream_from.hxx\n+ 1/* Definition of the pqxx::stream_from class.\n 2 *\n- 3 * Read or write large objects, stored in their own storage on the server.\n+ 3 * pqxx::stream_from enables optimized batch reads from a database table.\n 4 *\n- 5 * DO NOT INCLUDE THIS FILE DIRECTLY; include pqxx/largeobject instead.\n+ 5 * DO NOT INCLUDE THIS FILE DIRECTLY; include pqxx/stream_from instead.\n 6 *\n 7 * Copyright (c) 2000-2023, Jeroen T. Vermeulen.\n 8 *\n 9 * See COPYING for copyright license. If you did not receive a file called\n 10 * COPYING with this source code, please notify the distributor of this\n 11 * mistake, or contact the author.\n 12 */\n- 13#ifndef PQXX_H_BLOB\n- 14#define PQXX_H_BLOB\n+ 13#ifndef PQXX_H_STREAM_FROM\n+ 14#define PQXX_H_STREAM_FROM\n 15\n 16#if !defined(PQXX_HEADER_PRE)\n 17# error \"Include libpqxx headers as \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+
\n \n+\n+\n+\n+\n+\n+\n+\n+\n \n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n
\n-\n-\n-\n-\n+\n+
\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n
\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+
\n+\n+\n+\n+\n+\n+\n+\n+\n+
\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+
\n+\n+\n+\n+\n+\n+
\n+\n+\n+\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+
\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n+\n \n-\n+\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+
\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+
\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n
\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n \n-Definition blob.hxx:53
void write(DATA const &data)
Write data large object, at the current position.
Definition blob.hxx:197
blob(blob const &)=delete
std::basic_string_view< std::byte > read(std::vector< std::byte, ALLOC > &buf)
Read up to std::size(buf) bytes from the object.
Definition blob.hxx:147
blob & operator=(blob const &)=delete
Abstract transaction base class: bracket transactions on the database.
Definition dbtransaction.hxx:54
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
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
constexpr from_query_t from_query
Pass this to a stream_from constructor to stream query results.
Definition stream_from.hxx:44
constexpr from_table_t from_table
Pass this to a stream_from constructor to stream table contents.
Definition stream_from.hxx:40
std::initializer_list< std::string_view > table_path
Representation of a PostgreSQL table path.
Definition connection.hxx:188
void PQXX_COLD throw_null_conversion(std::string const &type)
Definition strconv.cxx:253
Error in usage of libpqxx library, similar to std::logic_error.
Definition except.hxx:249
Value conversion failed, e.g. when converting "Hello" to int.
Definition except.hxx:283
static stream_from query(transaction_base &tx, std::string_view q)
Factory: Execute query, and stream the results.
Definition stream_from.hxx:98
stream_from & operator>>(std::variant< Vs... > &)=delete
Doing this with a std::variant is going to be horrifically borked.
stream_from & operator>>(Tuple &)
Read one row into a tuple.
Definition stream_from.hxx:323
stream_from(transaction_base &tx, std::string_view table, Columns const &columns)
Definition stream_from.hxx:185
std::pair< std::unique_ptr< char, void(*)(void const *)>, std::size_t > raw_line
Definition stream_from.hxx:82
stream_from(stream_from &&)=delete
stream_from(transaction_base &, std::string_view table, Iter columns_begin, Iter columns_end)
stream_from & operator=(stream_from &&)=delete
stream_from(transaction_base &tx, std::string_view table)
Definition stream_from.hxx:177
auto iter() &
Iterate over this stream. Supports range-based "for" loops.
Definition stream_from.hxx:237
constexpr bool operator!() const noexcept
Has this stream produced all the data it is going to produce?
Definition stream_from.hxx:204
Interface definition (and common code) for "transaction" classes.
Definition transaction_base.hxx:88
Base class for things that monopolise a transaction's attention.
Definition transaction_focus.hxx:29
![\"doxygen\"/](\"doxygen.svg\")
\n
\n- \n+ \n
\n except.hxx
pipeline.hxx
\n-, not .\"\n 18#endif\n 19\n- 20#if pqxx_have_source_location\n- 21# include \n- 22#endif\n+ 20#include \n+ 21#include
\n+
\n \n \n \n \n", "details": [{"source1": "html2text {}", "source2": "html2text {}", "unified_diff": "@@ -1,941 +1,208 @@\n \n \n \n \n \n libpqxx\u00a07.8.1\n \n-except.hxx\n- 1/* Definition of libpqxx exception classes.\n+pipeline.hxx\n+ 1/* Definition of the pqxx::pipeline class.\n 2 *\n- 3 * pqxx::sql_error, pqxx::broken_connection, pqxx::in_doubt_error, ...\n+ 3 * Throughput-optimized mechanism for executing queries.\n 4 *\n- 5 * DO NOT INCLUDE THIS FILE DIRECTLY; include pqxx/except instead.\n+ 5 * DO NOT INCLUDE THIS FILE DIRECTLY; include pqxx/pipeline instead.\n 6 *\n 7 * Copyright (c) 2000-2023, Jeroen T. Vermeulen.\n 8 *\n 9 * See COPYING for copyright license. If you did not receive a file called\n 10 * COPYING with this source code, please notify the distributor of this\n 11 * mistake, or contact the author.\n 12 */\n- 13#ifndef PQXX_H_EXCEPT\n- 14#define PQXX_H_EXCEPT\n+ 13#ifndef PQXX_H_PIPELINE\n+ 14#define PQXX_H_PIPELINE\n 15\n 16#if !defined(PQXX_HEADER_PRE)\n 17# error \"Include libpqxx headers as \n \n-\n+\n \n-\n+\n \n \n \n \n \n \n \n-\n-\n+\n+\n \n \n \n \n \n-\n-\n-\n+\n+\n+\n \n-\n-\n+\n+\n \n-\n-\n-\n-
\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n+\n+\n+\n+\n+\n+
\n+\n+\n+\n+\n+\n+\n+
\n+\n+\n+\n+\n+\n+\n+\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+
\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n+\n+\n+\n+\n+\n+\n+\n+\n+\n+\n \n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-\n-
\n-\n-\n-\n+\n+\n \n-\n-\n-\n-\n-\n-\n-
\n-\n-\n+\n+\n+\n+\n+\n+\n+\n+\n+\n Run-time failure encountered by libpqxx, similar to std::runtime_error.
Definition except.hxx:48
Exception class for lost or failed backend connection.
Definition except.hxx:81
Exception class for micommunication with the server.
Definition except.hxx:103
The caller attempted to set a variable to null, which is not allowed.
Definition except.hxx:116
virtual ~sql_error() noexcept override
"Help, I don't know whether transaction was committed successfully!"
Definition except.hxx:165
The backend saw itself forced to roll back the ongoing transaction.
Definition except.hxx:178
Transaction failed to serialize. Please retry it.
Definition except.hxx:200
We can't tell whether our last statement succeeded.
Definition except.hxx:214
The ongoing transaction has deadlocked. Retrying it may help.
Definition except.hxx:228
Error in usage of libpqxx library, similar to std::logic_error.
Definition except.hxx:249
Invalid argument passed to libpqxx, similar to std::invalid_argument.
Definition except.hxx:266
Value conversion failed, e.g. when converting "Hello" to int.
Definition except.hxx:283
Could not convert null value: target type does not support null.
Definition except.hxx:300
Could not convert value to string: not enough buffer space.
Definition except.hxx:313
unexpected_rows(std::string const &msg)
Definition except.hxx:351
Database feature not supported in current setup.
Definition except.hxx:358
feature_not_supported(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:367
data_exception(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:386
Definition except.hxx:395
integrity_constraint_violation(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:404
Definition except.hxx:413
restrict_violation(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:422
Definition except.hxx:431
not_null_violation(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:440
Definition except.hxx:449
foreign_key_violation(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:458
Definition except.hxx:467
unique_violation(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:476
Definition except.hxx:485
check_violation(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:494
Definition except.hxx:503
invalid_cursor_state(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:512
Definition except.hxx:521
invalid_sql_statement_name(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:530
Definition except.hxx:539
invalid_cursor_name(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:548
Definition except.hxx:557
syntax_error(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr, int pos=-1)
Definition except.hxx:569
int const error_position
Approximate position in string where error occurred, or -1 if unknown.
Definition except.hxx:559
Definition except.hxx:578
undefined_column(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:588
Definition except.hxx:597
undefined_function(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:607
Definition except.hxx:616
undefined_table(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:626
Definition except.hxx:635
insufficient_privilege(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:644
insufficient_resources(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:663
Definition except.hxx:672
disk_full(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:681
Definition except.hxx:690
out_of_memory(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:699
Definition except.hxx:708
too_many_connections(std::string const &err)
Definition except.hxx:716
plpgsql_error(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:735
plpgsql_raise(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:754
Definition except.hxx:763
plpgsql_no_data_found(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:772
Definition except.hxx:781
plpgsql_too_many_rows(std::string const &err, std::string const &Q="", char const sqlstate[]=nullptr)
Definition except.hxx:790
Processes several queries in FIFO manner, optimized for high throughput.
Definition pipeline.hxx:51
pipeline & operator=(pipeline &&)=delete
pipeline & operator=(pipeline const &)=delete
pipeline(transaction_base &t, std::string_view tname)
Start a pipeline. Assign it a name, for more helpful error messages.
Definition pipeline.hxx:68
pipeline(pipeline &&)=delete
pipeline(pipeline const &)=delete
Interface definition (and common code) for "transaction" classes.
Definition transaction_base.hxx:88
Base class for things that monopolise a transaction's attention.
Definition transaction_focus.hxx:29