Used during CLI execution.
(self, text)
| 1228 | return output, meta_query |
| 1229 | |
| 1230 | def _handle_server_closed_connection(self, text): |
| 1231 | """Used during CLI execution.""" |
| 1232 | try: |
| 1233 | click.secho("Reconnecting...", fg="green") |
| 1234 | self.pgexecute.connect() |
| 1235 | click.secho("Reconnected!", fg="green") |
| 1236 | except OperationalError as e: |
| 1237 | click.secho("Reconnect Failed", fg="red") |
| 1238 | click.secho(str(e), err=True, fg="red") |
| 1239 | else: |
| 1240 | retry = self.auto_retry_closed_connection or confirm("Run the query from before reconnecting?") |
| 1241 | if retry: |
| 1242 | click.secho("Running query...", fg="green") |
| 1243 | # Don't get stuck in a retry loop |
| 1244 | self.execute_command(text, handle_closed_connection=False) |
| 1245 | |
| 1246 | def refresh_completions(self, history=None, persist_priorities="all"): |
| 1247 | """Refresh outdated completions |
no test coverage detected