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
|
#include "test_helpers.hxx"
using namespace PGSTD;
using namespace pqxx;
// Example/test program for libpqxx. Perform a query and enumerate its output
// using array indexing.
namespace
{
void bad_connect()
{
connection C("totally#invalid@connect$string!?");
}
void test_002(transaction_base &)
{
// Before we really connect, test the expected behaviour of the default
// connection type, where a failure to connect results in an immediate
// exception rather than a silent retry.
PQXX_CHECK_THROWS(
bad_connect(),
exception,
"Invalid connection string did not cause exception.");
// Set up connection to database
string ConnectString = "";
connection C(ConnectString);
// Start transaction within context of connection
work T(C, "test2");
// Perform query within transaction
result R( T.exec("SELECT * FROM pg_tables") );
// Let's keep the database waiting as briefly as possible: commit now,
// before we start processing results. We could do this later, or since
// we're not making any changes in the database that need to be committed,
// we could in this case even omit it altogether.
T.commit();
// Since we don't need the database anymore, we can be even more
// considerate and close the connection now. This is optional.
C.disconnect();
// Ah, this version of postgres will tell you which table a column in a
// result came from. Let's just test that functionality...
const oid rtable = R.column_table(0);
PQXX_CHECK_EQUAL(
rtable,
R.column_table(pqxx::tuple::size_type(0)),
"Inconsistent answers from column_table()");
const string rcol = R.column_name(0);
const oid crtable = R.column_table(rcol);
PQXX_CHECK_EQUAL(
crtable,
rtable,
"Field looked up by name gives different origin.");
// Now we've got all that settled, let's process our results.
for (result::size_type i = 0; i < R.size(); ++i)
{
const oid ftable = R[i][0].table();
PQXX_CHECK_EQUAL(ftable, rtable, "field::table() is broken.");
const oid ttable = R[i].column_table(0);
PQXX_CHECK_EQUAL(
ttable,
R[i].column_table(pqxx::tuple::size_type(0)),
"Inconsistent pqxx::tuple::column_table().");
PQXX_CHECK_EQUAL(ttable, rtable, "Inconsistent result::column_table().");
const oid cttable = R[i].column_table(rcol);
PQXX_CHECK_EQUAL(
cttable,
rtable,
"pqxx::tuple::column_table() is broken.");
}
}
} // namespace
PQXX_REGISTER_TEST_NODB(test_002)
|
