]> git.ipfire.org Git - thirdparty/psycopg.git/commitdiff
feat(crdb): add psycopg.crdb.connect() function
authorDaniele Varrazzo <daniele.varrazzo@gmail.com>
Tue, 24 May 2022 08:50:17 +0000 (10:50 +0200)
committerDaniele Varrazzo <daniele.varrazzo@gmail.com>
Tue, 12 Jul 2022 11:58:34 +0000 (12:58 +0100)
psycopg/psycopg/crdb.py
tests/crdb/test_connection.py

index 051e74075e272c535c36f886c9e06bed8ad1a86e..5fa3492be60348581da3b1ff638962ab6718ffa3 100644 (file)
@@ -66,6 +66,9 @@ class AsyncCrdbConnection(_CrdbConnectionMixin, AsyncConnection[Row]):
     pass
 
 
+connect = CrdbConnection.connect
+
+
 class CrdbConnectionInfo(ConnectionInfo):
     @property
     def vendor(self) -> str:
index 9c169e3a3ccdc48ccfe074e86f93d0df6d737782..1f1f64d287a08a84a4b0d4c6268e7b333152d2cf 100644 (file)
@@ -1,3 +1,4 @@
+import psycopg.crdb
 from psycopg.crdb import CrdbConnection
 
 import pytest
@@ -8,3 +9,8 @@ pytestmark = pytest.mark.crdb
 def test_is_crdb(conn):
     assert CrdbConnection.is_crdb(conn)
     assert CrdbConnection.is_crdb(conn.pgconn)
+
+
+def test_connect(dsn):
+    with psycopg.crdb.connect(dsn) as conn:
+        assert isinstance(conn, CrdbConnection)