pgsql: Wait till completion on database connection reset.

parent f224e2c5
......@@ -504,13 +504,15 @@ protected void _destruct() {
resync();
}
private void textquery(string q) {
private .pgsql_util.Result textquery(string q) {
.pgsql_util.Result res;
#if 1
foreach (q / ";"; ; string sq)
big_query(sq);
res = big_query(sq);
#else // textqueries and portals do not mix well
big_query(q, (["_text":1]));
res = big_query(q, (["_text":1]));
#endif
return res;
}
private void resyncdone() {
......@@ -521,7 +523,9 @@ private void resyncdone() {
private void reset_dbsession() {
proxy.statementsinflight->wait_till_drained();
error(1);
textquery("ROLLBACK;RESET ALL;CLOSE ALL;DISCARD TEMP");
.pgsql_util.Result res
= textquery("ROLLBACK;RESET ALL;CLOSE ALL;DISCARD TEMP");
while (res->fetch_row());
resyncdone();
}
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment