@@ 87-94 (lines=8) @@ | ||
84 | try { |
|
85 | $stmt = $this->stmt->execute($params); |
|
86 | } catch (DBALException $e) { |
|
87 | if ($this->conn->validateReconnectAttempt($e, $attempt)) { |
|
88 | $this->conn->close(); |
|
89 | $this->createStatement(); |
|
90 | $attempt++; |
|
91 | $retry = true; |
|
92 | } else { |
|
93 | throw $e; |
|
94 | } |
|
95 | } |
|
96 | } |
|
97 |
@@ 123-130 (lines=8) @@ | ||
120 | $stmt = parent::query(); |
|
121 | } |
|
122 | } catch (DBALException $e) { |
|
123 | if ($this->validateReconnectAttempt($e, $attempt)) { |
|
124 | $this->close(); |
|
125 | $attempt++; |
|
126 | sleep(1); |
|
127 | $retry = true; |
|
128 | } else { |
|
129 | throw $e; |
|
130 | } |
|
131 | } |
|
132 | } |
|
133 | ||
@@ 150-157 (lines=8) @@ | ||
147 | try { |
|
148 | $stmt = parent::executeUpdate($query, $params, $types); |
|
149 | } catch (DBALException $e) { |
|
150 | if ($this->validateReconnectAttempt($e, $attempt)) { |
|
151 | $this->close(); |
|
152 | $attempt++; |
|
153 | sleep(1); |
|
154 | $retry = true; |
|
155 | } else { |
|
156 | throw $e; |
|
157 | } |
|
158 | } |
|
159 | } |
|
160 |