blob: d4af37fb07b3e0bf20658c4463415da4becd4e47 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
/** Definition of the pqxx::stream_base class.
*
* pqxx::stream_base provides optimized batch access to a database table.
*
* DO NOT INCLUDE THIS FILE DIRECTLY; include pqxx/stream_base instead.
*
* Copyright (c) 2000-2019, Jeroen T. Vermeulen.
*
* See COPYING for copyright license. If you did not receive a file called
* COPYING with this source code, please notify the distributor of this mistake,
* or contact the author.
*/
#ifndef PQXX_H_STREAM_BASE
#define PQXX_H_STREAM_BASE
#include "pqxx/compiler-public.hxx"
#include "pqxx/compiler-internal-pre.hxx"
#include "pqxx/transaction_base.hxx"
#include "pqxx/util.hxx"
#include <string>
namespace pqxx
{
class PQXX_LIBEXPORT PQXX_NOVTABLE stream_base :
public internal::transactionfocus
{
public:
explicit stream_base(transaction_base &);
// TODO: Can we get rid of the vtable?
virtual ~stream_base() noexcept =default;
virtual void complete() = 0;
operator bool() const noexcept;
bool operator!() const noexcept;
protected:
bool m_finished;
virtual void close();
template<typename C> static std::string columnlist(const C &);
template<typename I> static std::string columnlist(I begin, I end);
private:
stream_base();
stream_base(const stream_base&);
stream_base & operator=(const stream_base &);
};
template<typename C> std::string stream_base::columnlist(const C &c)
{
return columnlist(std::begin(c), std::end(c));
}
template<typename I> std::string stream_base::columnlist(I begin, I end)
{
return separated_list(",", begin, end);
}
} // namespace pqxx
#include "pqxx/compiler-internal-post.hxx"
#endif
|
