/usr/include/pqxx/tablestream.hxx is in libpqxx3-dev 3.1-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 | /*-------------------------------------------------------------------------
*
* FILE
* pqxx/tablestream.hxx
*
* DESCRIPTION
* definition of the pqxx::tablestream class.
* pqxx::tablestream provides optimized batch access to a database table
* DO NOT INCLUDE THIS FILE DIRECTLY; include pqxx/tablestream instead.
*
* Copyright (c) 2001-2008, Jeroen T. Vermeulen <jtv@xs4all.nl>
*
* 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_TABLESTREAM
#define PQXX_H_TABLESTREAM
#include "pqxx/compiler-public.hxx"
#include "pqxx/compiler-internal-pre.hxx"
#include "pqxx/transaction_base"
/* Methods tested in eg. self-test program test001 are marked with "//[t1]"
*/
namespace pqxx
{
class transaction_base;
/// Base class for streaming data to/from database tables.
/** A Tablestream enables optimized batch read or write access to a database
* table using PostgreSQL's <tt>COPY TO STDOUT</tt> and <tt>COPY FROM STDIN</tt>
* commands, respectively. These capabilities are implemented by its subclasses
* tablereader and tablewriter.
*
* A Tablestream exists in the context of a transaction, and no other streams
* or queries may be applied to that transaction as long as the stream remains
* open.
*/
class PQXX_LIBEXPORT PQXX_NOVTABLE tablestream :
public internal::transactionfocus
{
public:
explicit tablestream(transaction_base &Trans,
const PGSTD::string &Null=PGSTD::string()); //[t6]
virtual ~tablestream() throw () =0; //[t6]
/// Finish stream action, check for errors, and detach from transaction
/** It is recommended that you call this function before the tablestream's
* destructor is run. This function will check for any final errors which may
* not become apparent until the transaction is committed otherwise.
*
* As an added benefit, this will free up the transaction while the
* tablestream object itself still exists.
*/
virtual void complete() =0;
protected:
const PGSTD::string &NullStr() const { return m_Null; }
bool is_finished() const throw () { return m_Finished; }
void base_close();
/// Construct a comma-separated column list from given sequence
template<typename ITER>
static PGSTD::string columnlist(ITER colbegin, ITER colend);
private:
PGSTD::string m_Null;
bool m_Finished;
// Not allowed:
tablestream();
tablestream(const tablestream &);
tablestream &operator=(const tablestream &);
};
template<typename ITER> inline
PGSTD::string tablestream::columnlist(ITER colbegin, ITER colend)
{
return separated_list(",", colbegin, colend);
}
} // namespace pqxx
#include "pqxx/compiler-internal-post.hxx"
#endif
|