#include <pgstream.hpp>
List of all members.
Protected Member Functions |
| void | init (const char *query, int prepare_mode, unsigned int cursor_step) |
| | pg_stream (pg_cnx &db) |
Static Private Attributes |
| static int | m_uniq_cnt = 0 |
Detailed Description
pg_stream class. Allows the parametrized execution of a query and retrieval of results in a stream
Definition at line 206 of file pgstream.hpp.
Constructor & Destructor Documentation
| pgs::pg_stream::pg_stream |
( |
const char * |
query, |
|
|
pg_cnx & |
db, |
|
|
int |
prepare_mode = 2 |
|
) |
| |
| pgs::pg_stream::pg_stream |
( |
const std::string |
query, |
|
|
pg_cnx & |
db, |
|
|
int |
prepare_mode = 2 |
|
) |
| |
| pgs::pg_stream::~pg_stream |
( |
| ) |
|
|
virtual |
| pgs::pg_stream::pg_stream |
( |
pg_cnx & |
db | ) |
|
|
inlineprotected |
Member Function Documentation
| int pgs::pg_stream::affected_rows |
( |
| ) |
const |
|
inline |
| void pgs::pg_stream::check_binds |
( |
| ) |
|
|
private |
| void pgs::pg_stream::check_eof |
( |
| ) |
|
|
private |
| bool pgs::pg_stream::check_null |
( |
| ) |
|
|
private |
| void pgs::pg_stream::create_cursor |
( |
| ) |
|
|
private |
| void pgs::pg_stream::cursor_fetch |
( |
| ) |
|
|
private |
| void pgs::pg_stream::do_prepare |
( |
| ) |
|
|
private |
| int pgs::pg_stream::eof |
( |
| ) |
|
returns true if there are no more results to read from the stream,
or false otherwise
Definition at line 790 of file pgstream.cpp.
| int pgs::pg_stream::eos |
( |
| ) |
|
|
inline |
| void pgs::pg_stream::execute |
( |
| ) |
|
|
private |
| void pgs::pg_stream::init |
( |
const char * |
query, |
|
|
int |
prepare_mode, |
|
|
unsigned int |
cursor_step |
|
) |
| |
|
protected |
| void pgs::pg_stream::next_bind |
( |
| ) |
|
|
private |
| void pgs::pg_stream::next_result |
( |
| ) |
|
|
private |
| pg_stream & pgs::pg_stream::operator<< |
( |
const char * |
p | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
const std::string & |
s | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
int |
i | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
unsigned int |
i | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
long |
l | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
unsigned long |
l | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
long long |
l | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
unsigned long long |
l | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
short |
s | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
unsigned short |
s | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
double |
d | ) |
|
| pg_stream & pgs::pg_stream::operator<< |
( |
bool |
b | ) |
|
| pg_stream & pgs::pg_stream::operator>> |
( |
short & |
s | ) |
|
| pg_stream & pgs::pg_stream::operator>> |
( |
unsigned short & |
s | ) |
|
| pg_stream & pgs::pg_stream::operator>> |
( |
int & |
i | ) |
|
| pg_stream & pgs::pg_stream::operator>> |
( |
unsigned int & |
i | ) |
|
| pg_stream & pgs::pg_stream::operator>> |
( |
char * |
p | ) |
|
| pg_stream & pgs::pg_stream::operator>> |
( |
std::string & |
s | ) |
|
| pg_stream & pgs::pg_stream::operator>> |
( |
double & |
d | ) |
|
| pg_stream & pgs::pg_stream::operator>> |
( |
bool & |
b | ) |
|
| void pgs::pg_stream::prepare |
( |
bool |
prep = true | ) |
|
|
inline |
| void pgs::pg_stream::query_make_space |
( |
int |
len | ) |
|
|
private |
| void pgs::pg_stream::replace_placeholder |
( |
unsigned int |
argpos, |
|
|
const char * |
buf, |
|
|
int |
size, |
|
|
bool |
binary = false |
|
) |
| |
|
private |
| void pgs::pg_stream::reset_results |
( |
| ) |
|
|
private |
| void pgs::pg_stream::set_cursor |
( |
unsigned int |
step | ) |
|
|
inline |
| void pgs::pg_stream::use_bind_variables |
( |
bool |
u = true | ) |
|
|
inline |
| bool pgs::pg_stream::val_is_null |
( |
| ) |
const |
|
inline |
Member Data Documentation
| int pgs::pg_stream::m_affected_rows |
|
private |
| unsigned int pgs::pg_stream::m_argpos |
|
private |
| int pgs::pg_stream::m_chunk_size |
|
private |
| int pgs::pg_stream::m_col_number |
|
private |
| std::string pgs::pg_stream::m_cursor_name |
|
private |
| int pgs::pg_stream::m_cursor_step |
|
private |
| int pgs::pg_stream::m_executed |
|
private |
| int pgs::pg_stream::m_initial_query_len |
|
private |
| bool pgs::pg_stream::m_inline_params |
|
private |
| char pgs::pg_stream::m_localQueryBuf[1024+1] |
|
private |
| PGresult* pgs::pg_stream::m_pg_res |
|
private |
| std::string pgs::pg_stream::m_prepare_name |
|
private |
| bool pgs::pg_stream::m_prepare_wanted |
|
private |
| char* pgs::pg_stream::m_query_buf |
|
private |
| int pgs::pg_stream::m_query_bufsize |
|
private |
| std::string pgs::pg_stream::m_query_fmt |
|
private |
| unsigned int pgs::pg_stream::m_query_hash |
|
private |
| int pgs::pg_stream::m_query_len |
|
private |
| int pgs::pg_stream::m_row_number |
|
private |
| int pgs::pg_stream::m_uniq_cnt = 0 |
|
staticprivate |
| bool pgs::pg_stream::m_val_null |
|
private |
The documentation for this class was generated from the following files: