From 4a52a71956a8d46fcb7294ac71734504bb09bcc2 Mon Sep 17 00:00:00 2001 From: S. Solomon Darnell Date: Fri, 28 Mar 2025 21:52:21 -0500 Subject: two version of R2R are here --- .../site-packages/pgvector/psycopg/halfvec.py | 53 ++++++++++++++++++++++ 1 file changed, 53 insertions(+) create mode 100644 .venv/lib/python3.12/site-packages/pgvector/psycopg/halfvec.py (limited to '.venv/lib/python3.12/site-packages/pgvector/psycopg/halfvec.py') diff --git a/.venv/lib/python3.12/site-packages/pgvector/psycopg/halfvec.py b/.venv/lib/python3.12/site-packages/pgvector/psycopg/halfvec.py new file mode 100644 index 00000000..351d2cb7 --- /dev/null +++ b/.venv/lib/python3.12/site-packages/pgvector/psycopg/halfvec.py @@ -0,0 +1,53 @@ +from psycopg.adapt import Loader, Dumper +from psycopg.pq import Format +from ..utils import HalfVector + + +class HalfVectorDumper(Dumper): + + format = Format.TEXT + + def dump(self, obj): + return HalfVector._to_db(obj).encode('utf8') + + +class HalfVectorBinaryDumper(HalfVectorDumper): + + format = Format.BINARY + + def dump(self, obj): + return HalfVector._to_db_binary(obj) + + +class HalfVectorLoader(Loader): + + format = Format.TEXT + + def load(self, data): + if isinstance(data, memoryview): + data = bytes(data) + return HalfVector._from_db(data.decode('utf8')) + + +class HalfVectorBinaryLoader(HalfVectorLoader): + + format = Format.BINARY + + def load(self, data): + if isinstance(data, memoryview): + data = bytes(data) + return HalfVector._from_db_binary(data) + + +def register_halfvec_info(context, info): + info.register(context) + + # add oid to anonymous class for set_types + text_dumper = type('', (HalfVectorDumper,), {'oid': info.oid}) + binary_dumper = type('', (HalfVectorBinaryDumper,), {'oid': info.oid}) + + adapters = context.adapters + adapters.register_dumper(HalfVector, text_dumper) + adapters.register_dumper(HalfVector, binary_dumper) + adapters.register_loader(info.oid, HalfVectorLoader) + adapters.register_loader(info.oid, HalfVectorBinaryLoader) -- cgit v1.2.3