Skip to content
This repository was archived by the owner on Aug 19, 2025. It is now read-only.

Commit ee05aec

Browse files
Colourize connect/disconnect messages
1 parent 4d87d76 commit ee05aec

1 file changed

Lines changed: 18 additions & 2 deletions

File tree

databases/core.py

Lines changed: 18 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,16 @@
2323
LOG_EXTRA = {
2424
"color_message": "Query: " + click.style("%s", bold=True) + " Args: %s"
2525
}
26+
CONNECT_EXTRA = {
27+
"color_message": "Connected to database " + click.style("%s", bold=True)
28+
}
29+
DISCONNECT_EXTRA = {
30+
"color_message": "Disconnected from database " + click.style("%s", bold=True)
31+
}
2632
except ImportError: # pragma: no cover
2733
LOG_EXTRA = {}
34+
CONNECT_EXTRA = {}
35+
DISCONNECT_EXTRA = {}
2836

2937

3038
logger = logging.getLogger("databases")
@@ -76,7 +84,11 @@ async def connect(self) -> None:
7684
assert not self.is_connected, "Already connected."
7785

7886
await self._backend.connect()
79-
logger.info("Connected to database %s" % repr(self.url.obscure_password))
87+
logger.info(
88+
"Connected to database %s",
89+
repr(self.url.obscure_password),
90+
extra=CONNECT_EXTRA,
91+
)
8092
self.is_connected = True
8193

8294
if self._force_rollback:
@@ -94,7 +106,11 @@ async def disconnect(self) -> None:
94106
await self._global_transaction.__aexit__()
95107

96108
await self._backend.disconnect()
97-
logger.info("Disconnected from database %s" % repr(self.url.obscure_password))
109+
logger.info(
110+
"Disconnected from database %s",
111+
repr(self.url.obscure_password),
112+
extra=DISCONNECT_EXTRA,
113+
)
98114
self.is_connected = False
99115

100116
async def __aenter__(self) -> "Database":

0 commit comments

Comments
 (0)