File tree Expand file tree Collapse file tree 1 file changed +19
-0
lines changed Expand file tree Collapse file tree 1 file changed +19
-0
lines changed Original file line number Diff line number Diff line change 22from pgvector .psycopg2 import register_vector , HalfVector , SparseVector
33import psycopg2
44from psycopg2 .extras import DictCursor , RealDictCursor , NamedTupleCursor
5+ from psycopg2 .pool import ThreadedConnectionPool
56
67conn = psycopg2 .connect (dbname = 'pgvector_python_test' )
78conn .autocommit = True
@@ -94,3 +95,21 @@ def test_cursor_factory_connection(self):
9495 conn = psycopg2 .connect (dbname = 'pgvector_python_test' , cursor_factory = cursor_factory )
9596 register_vector (conn , globally = False )
9697 conn .close ()
98+
99+ def test_pool (self ):
100+ pool = ThreadedConnectionPool (1 , 3 , dbname = 'pgvector_python_test' )
101+
102+ conn = pool .getconn ()
103+ try :
104+ cur = conn .cursor ()
105+
106+ # use globally=True for apps
107+ register_vector (cur , globally = False )
108+
109+ cur .execute ("SELECT '[1,2,3]'::vector" )
110+ res = cur .fetchone ()
111+ assert np .array_equal (res [0 ], np .array ([1 , 2 , 3 ]))
112+ finally :
113+ pool .putconn (conn )
114+
115+ pool .closeall ()
You can’t perform that action at this time.
0 commit comments