diff options
author | S. Solomon Darnell | 2025-03-28 21:52:21 -0500 |
---|---|---|
committer | S. Solomon Darnell | 2025-03-28 21:52:21 -0500 |
commit | 4a52a71956a8d46fcb7294ac71734504bb09bcc2 (patch) | |
tree | ee3dc5af3b6313e921cd920906356f5d4febc4ed /.venv/lib/python3.12/site-packages/pgvector/psycopg/halfvec.py | |
parent | cc961e04ba734dd72309fb548a2f97d67d578813 (diff) | |
download | gn-ai-4a52a71956a8d46fcb7294ac71734504bb09bcc2.tar.gz |
Diffstat (limited to '.venv/lib/python3.12/site-packages/pgvector/psycopg/halfvec.py')
-rw-r--r-- | .venv/lib/python3.12/site-packages/pgvector/psycopg/halfvec.py | 53 |
1 files changed, 53 insertions, 0 deletions
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) |