Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
27 changes: 25 additions & 2 deletions django_ormql/columns.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,10 +10,17 @@

class BaseColumn:
def __init__(
self, *, source=None, nullable=None, enum_options=None, model_field=None
self,
*,
source=None,
nullable=None,
sql_type=None,
enum_options=None,
model_field=None,
):
self.source = source
self._nullable = nullable
self._sql_type = sql_type
self.enum_options = enum_options

def bind(self, field_name, parent):
Expand All @@ -29,9 +36,16 @@ def resolve_column_path(self, remaining_path):
)
return F(self.source)

def resolve_column_type(self, remaining_path):
if remaining_path:
raise QueryNotSupported(
f"Column '{self.field_name}' is not a related field"
)
return self.sql_type

@property
def sql_type(self):
return ""
return self._sql_type

@property
def nullable(self):
Expand Down Expand Up @@ -177,6 +191,15 @@ def resolve_column_path(self, remaining_path):
else:
return F("__".join([self.source, "pk"]))

def resolve_column_type(self, remaining_path):
if len(remaining_path) > 20:
raise QueryNotSupported("Upper limit of JOINs reached.")
rt = self.related_table(is_related=True)
if remaining_path:
return rt.resolve_column_type(remaining_path)
else:
return "INT"


class GeneratedColumn(BaseColumn):
nullable = True
Expand Down
Loading
Loading