Add pg reconnection loop (#731)

Signed-off-by: Fedor Muratov <muratovfyodor@yandex.ru>
SOCI · May 9, 2019 · a47fd69 · a47fd69
1 parent 64e917c
commit a47fd69
Showing 1 changed file with 16 additions and 14 deletions.
diff --git a/src/backends/postgresql/error.cpp b/src/backends/postgresql/error.cpp
@@ -95,20 +95,22 @@ details::postgresql_result::check_for_data(char const* errMsg) const
                         callback->started();
 
                         bool retry = false;
-                        std::string newTarget;
-
-                        callback->failed(retry, newTarget);
-
-                        if (retry)
-                        {
-                            connection_parameters parameters("postgresql", newTarget);
-
-                            sessionBackend_.clean_up();
-
-                            sessionBackend_.connect(parameters);
-
-                            reconnected = true;
-                        }
+                        do {
+                            std::string newTarget;
+
+                            callback->failed(retry, newTarget);
+
+                            if (retry)
+                            {
+                                connection_parameters parameters("postgresql", newTarget);
+
+                                sessionBackend_.clean_up();
+
+                                sessionBackend_.connect(parameters);
+
+                                reconnected = true;
+                            }
+                        } while (retry && !reconnected);
                     }
                     catch (...)
                     {