We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cfcc2ea commit 95403d5Copy full SHA for 95403d5
1 file changed
tests/test_sqlalchemy.py
@@ -34,11 +34,21 @@
34
35
36
@event.listens_for(psycopg2_array_engine, "connect")
37
-def connect(dbapi_connection, connection_record):
+def psycopg2_connect(dbapi_connection, connection_record):
38
from pgvector.psycopg2 import register_vector
39
register_vector(dbapi_connection, globally=False, arrays=True)
40
41
42
+if sqlalchemy_version > 1:
43
+ psycopg_array_engine = create_engine('postgresql+psycopg://localhost/pgvector_python_test')
44
+ array_engines.append(psycopg_array_engine)
45
+
46
+ @event.listens_for(psycopg_array_engine, "connect")
47
+ def psycopg_connect(dbapi_connection, connection_record):
48
+ from pgvector.psycopg import register_vector
49
+ register_vector(dbapi_connection)
50
51
52
Base = declarative_base()
53
54
0 commit comments