Version 0.1.7

Author: lovelydinosaur

databases/backends/mysql.py

@@ -26,16 +26,16 @@ def _get_connection_kwargs(self) -> dict:
         options = self._database_url.options
 
         kwargs = {}
-        min_size = options.get('min_size')
-        max_size = options.get('max_size')
-        ssl = options.get('ssl')
+        min_size = options.get("min_size")
+        max_size = options.get("max_size")
+        ssl = options.get("ssl")
 
         if min_size is not None:
-            kwargs['minsize'] = int(min_size)
+            kwargs["minsize"] = int(min_size)
         if max_size is not None:
-            kwargs['maxsize'] = int(max_size)
+            kwargs["maxsize"] = int(max_size)
         if ssl is not None:
-            kwargs['ssl'] = {'true': True, 'false': False}[ssl.lower()]
+            kwargs["ssl"] = {"true": True, "false": False}[ssl.lower()]
         return kwargs
 
     async def connect(self) -> None:
@@ -48,7 +48,7 @@ async def connect(self) -> None:
             password=self._database_url.password,
             db=self._database_url.database,
             autocommit=True,
-            **kwargs
+            **kwargs,
         )
 
     async def disconnect(self) -> None:

databases/backends/postgres.py

@@ -37,16 +37,16 @@ def _get_connection_kwargs(self) -> dict:
         options = self._database_url.options
 
         kwargs = {}
-        min_size = options.get('min_size')
-        max_size = options.get('max_size')
-        ssl = options.get('ssl')
+        min_size = options.get("min_size")
+        max_size = options.get("max_size")
+        ssl = options.get("ssl")
 
         if min_size is not None:
-            kwargs['min_size'] = int(min_size)
+            kwargs["min_size"] = int(min_size)
         if max_size is not None:
-            kwargs['max_size'] = int(max_size)
+            kwargs["max_size"] = int(max_size)
         if ssl is not None:
-            kwargs['ssl'] = {'true': True, 'false': False}[ssl.lower()]
+            kwargs["ssl"] = {"true": True, "false": False}[ssl.lower()]
         return kwargs
 
     async def connect(self) -> None:

databases/core.py

@@ -3,7 +3,7 @@
 import sys
 import typing
 from types import TracebackType
-from urllib.parse import SplitResult, urlsplit, parse_qsl
+from urllib.parse import SplitResult, parse_qsl, urlsplit
 
 from sqlalchemy.engine import RowProxy
 from sqlalchemy.sql import ClauseElement

tests/test_connection_options.py

@@ -9,32 +9,22 @@
 def test_postgres_pool_size():
     backend = PostgresBackend("postgres://localhost/database?min_size=1&max_size=20")
     kwargs = backend._get_connection_kwargs()
-    assert kwargs == {
-        'min_size': 1,
-        'max_size': 20
-    }
+    assert kwargs == {"min_size": 1, "max_size": 20}
 
 
 def test_postgres_ssl():
     backend = PostgresBackend("postgres://localhost/database?ssl=true")
     kwargs = backend._get_connection_kwargs()
-    assert kwargs == {
-        'ssl': True,
-    }
+    assert kwargs == {"ssl": True}
 
 
 def test_mysql_pool_size():
     backend = MySQLBackend("mysql://localhost/database?min_size=1&max_size=20")
     kwargs = backend._get_connection_kwargs()
-    assert kwargs == {
-        'minsize': 1,
-        'maxsize': 20
-    }
+    assert kwargs == {"minsize": 1, "maxsize": 20}
 
 
 def test_mysql_ssl():
     backend = MySQLBackend("postgres://localhost/database?ssl=true")
     kwargs = backend._get_connection_kwargs()
-    assert kwargs == {
-        'ssl': True,
-    }
+    assert kwargs == {"ssl": True}