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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
#include <iostream>
#include "test_helpers.hxx"
using namespace PGSTD;
using namespace pqxx;
// Test program for libpqxx. Attempt to perform nested queries on various types
// of connections.
namespace
{
void do_test(connection_base &C, const string &desc)
{
cout << "Testing " << desc << ":" << endl;
// Trivial test: create subtransactions, and commit/abort
work T0(C, "T0");
cout << T0.exec("SELECT 'T0 starts'")[0][0].c_str() << endl;
subtransaction T0a(T0, "T0a");
T0a.commit();
subtransaction T0b(T0, "T0b");
T0b.abort();
cout << T0.exec("SELECT 'T0 ends'")[0][0].c_str() << endl;
T0.commit();
// Basic functionality: perform query in subtransaction; abort, continue
work T1(C, "T1");
cout << T1.exec("SELECT 'T1 starts'")[0][0].c_str() << endl;
subtransaction T1a(T1, "T1a");
cout << T1a.exec("SELECT ' a'")[0][0].c_str() << endl;
T1a.commit();
subtransaction T1b(T1, "T1b");
cout << T1b.exec("SELECT ' b'")[0][0].c_str() << endl;
T1b.abort();
subtransaction T1c(T1, "T1c");
cout << T1c.exec("SELECT ' c'")[0][0].c_str() << endl;
T1c.commit();
cout << T1.exec("SELECT 'T1 ends'")[0][0].c_str() << endl;
T1.commit();
}
bool test_and_catch(connection_base &C, const string &desc)
{
bool ok = false;
try
{
do_test(C,desc);
ok = true;
}
catch (const broken_connection &)
{
throw;
}
catch (const logic_error &)
{
throw;
}
catch (const exception &)
{
if (C.supports(connection_base::cap_nested_transactions))
throw feature_not_supported(
"Backend does not support nested transactions.");
throw;
}
return ok;
}
void test_089(transaction_base &)
{
asyncconnection A1;
bool ok = test_and_catch(A1, "asyncconnection (virgin)");
asyncconnection A2;
A2.activate();
if (!A2.supports(connection_base::cap_nested_transactions))
{
if (ok)
{
/* A1 supported nested transactions but A2 says it doesn't. What may
* have happened is we weren't able to establish the connections'
* capabilities, and the capability for nested transactions was deduced
* from the fact that that first subtransaction actually worked.
* If so, try that again.
*/
try
{
work W(A2);
subtransaction s(W);
s.commit();
}
catch (const exception &)
{
PQXX_CHECK_NOTREACHED(
"First asyncconnection supported nested "
"transactions, but second one doesn't!");
}
}
else
{
throw feature_not_supported(
"Backend does not support nested transactions.");
}
}
PQXX_CHECK(
ok,
"Virgin asyncconnection supports nested transactions, "
"but initialized one doesn't!");
do_test(A2, "asyncconnection (initialized)");
lazyconnection L1;
do_test(L1, "lazyconnection (virgin)");
lazyconnection L2;
L2.activate();
do_test(L2, "lazyconnection (initialized)");
connection C;
C.activate();
C.deactivate();
do_test(C, "connection (deactivated)");
}
} // namespace
PQXX_REGISTER_TEST_NODB(test_089)
|
