Skip to content

Commit 7423dc4

Browse files
committed
Renamed utils methods
1 parent 0c3f781 commit 7423dc4

File tree

4 files changed

+14
-14
lines changed

4 files changed

+14
-14
lines changed

pgvector/django/__init__.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
from django.contrib.postgres.operations import CreateExtension
22
from django.contrib.postgres.indexes import PostgresIndex
33
from django.db.models import Field, FloatField, Func
4-
from ..utils import cast_vector, quote_vector
4+
from ..utils import from_db, to_db
55

66
__all__ = ['VectorExtension', 'VectorField', 'IvfflatIndex', 'L2Distance', 'MaxInnerProduct', 'CosineDistance']
77

@@ -31,13 +31,13 @@ def db_type(self, connection):
3131
return 'vector(%d)' % self.dimensions
3232

3333
def from_db_value(self, value, expression, connection):
34-
return cast_vector(value)
34+
return from_db(value)
3535

3636
def to_python(self, value):
37-
return cast_vector(value)
37+
return from_db(value)
3838

3939
def get_prep_value(self, value):
40-
return quote_vector(value)
40+
return to_db(value)
4141

4242

4343
class IvfflatIndex(PostgresIndex):

pgvector/psycopg2/__init__.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import numpy as np
22
import psycopg2
33
from psycopg2.extensions import adapt, new_type, register_adapter, register_type
4-
from ..utils import cast_vector, quote_vector
4+
from ..utils import from_db, to_db
55

66
__all__ = ['register_vector']
77

@@ -11,11 +11,11 @@ def __init__(self, vector):
1111
self._vector = vector
1212

1313
def getquoted(self):
14-
return adapt(quote_vector(self._vector)).getquoted()
14+
return adapt(to_db(self._vector)).getquoted()
1515

1616

17-
def cast_vector_type(value, cur):
18-
return cast_vector(value)
17+
def cast_vector(value, cur):
18+
return from_db(value)
1919

2020

2121
def register_vector(conn_or_curs=None):
@@ -27,6 +27,6 @@ def register_vector(conn_or_curs=None):
2727
except psycopg2.errors.UndefinedObject:
2828
raise psycopg2.ProgrammingError('vector type not found in the database')
2929

30-
vector = new_type((oid,), 'VECTOR', cast_vector_type)
30+
vector = new_type((oid,), 'VECTOR', cast_vector)
3131
register_type(vector)
3232
register_adapter(np.ndarray, VectorAdapter)

pgvector/sqlalchemy/__init__.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
from sqlalchemy.types import UserDefinedType
2-
from ..utils import cast_vector, quote_vector
2+
from ..utils import from_db, to_db
33

44
__all__ = ['Vector']
55

@@ -16,12 +16,12 @@ def get_col_spec(self, **kw):
1616

1717
def bind_processor(self, dialect):
1818
def process(value):
19-
return quote_vector(value, self.dim)
19+
return to_db(value, self.dim)
2020
return process
2121

2222
def result_processor(self, dialect, coltype):
2323
def process(value):
24-
return cast_vector(value)
24+
return from_db(value)
2525
return process
2626

2727
class comparator_factory(UserDefinedType.Comparator):

pgvector/utils/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,15 @@
11
import numpy as np
22

33

4-
def cast_vector(value):
4+
def from_db(value):
55
# could be ndarray if already cast by lower-level driver
66
if value is None or isinstance(value, np.ndarray):
77
return value
88

99
return np.array(value[1:-1].split(','), dtype=np.float32)
1010

1111

12-
def quote_vector(value, dim=None):
12+
def to_db(value, dim=None):
1313
if value is None:
1414
return value
1515

0 commit comments

Comments
 (0)