carrotquest/django-clickhouse
1
1
Fork 0
mirror of https://github.com/carrotquest/django-clickhouse.git synced 2024-11-25 18:43:46 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fixed getting final versions if DateTimeField is used

Browse Source
This commit is contained in:
M1ha 2019-01-14 10:56:54 +05:00
parent 1f3dcedf55
commit ba3f2f6c1b
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/django_clickhouse/engines.py
View File

@ -8,9 +8,8 @@ from infi.clickhouse_orm import engines as infi_engines
from infi.clickhouse_orm.models import Model as InfiModel from infi.clickhouse_orm.models import Model as InfiModel
from statsd.defaults.django import statsd from statsd.defaults.django import statsd
from django_clickhouse.database import connections
from .configuration import config from .configuration import config
from .utils import lazy_class_import from .utils import format_datetime
T = TypeVar('T') T = TypeVar('T')
@ -48,6 +47,10 @@ class CollapsingMergeTree(InsertOnlyEngineMixin, infi_engines.CollapsingMergeTre
super(CollapsingMergeTree, self).__init__(*args, **kwargs) super(CollapsingMergeTree, self).__init__(*args, **kwargs)
def _get_final_versions_by_version(self, model_cls, min_date, max_date, object_pks): def _get_final_versions_by_version(self, model_cls, min_date, max_date, object_pks):
db = model_cls.get_database()
min_date = format_datetime(min_date, 0, db_alias=db.db_alias)
max_date = format_datetime(min_date, 0, day_end=True, db_alias=db.db_alias)
query = """ query = """
SELECT * FROM $table WHERE (`{pk_column}`, `{version_col}`) IN ( SELECT * FROM $table WHERE (`{pk_column}`, `{version_col}`) IN (
SELECT `{pk_column}`, MAX(`{version_col}`) SELECT `{pk_column}`, MAX(`{version_col}`)
@ -59,10 +62,14 @@ class CollapsingMergeTree(InsertOnlyEngineMixin, infi_engines.CollapsingMergeTre
""".format(version_col=self.version_col, date_col=self.date_col, pk_column=self.pk_column, """.format(version_col=self.version_col, date_col=self.date_col, pk_column=self.pk_column,
min_date=min_date.isoformat(), max_date=max_date.isoformat(), object_pks=','.join(object_pks)) min_date=min_date.isoformat(), max_date=max_date.isoformat(), object_pks=','.join(object_pks))
qs = model_cls.get_database().select(query, model_class=model_cls) qs = db.select(query, model_class=model_cls)
return list(qs) return list(qs)
def _get_final_versions_by_final(self, model_cls, min_date, max_date, object_pks): def _get_final_versions_by_final(self, model_cls, min_date, max_date, object_pks):
db = model_cls.get_database()
min_date = format_datetime(min_date, 0, db_alias=db.db_alias)
max_date = format_datetime(min_date, 0, day_end=True, db_alias=db.db_alias)
query = """ query = """
SELECT * FROM $table FINAL SELECT * FROM $table FINAL
WHERE `{date_col}` >= '{min_date}' AND `{date_col}` <= '{max_date}' WHERE `{date_col}` >= '{min_date}' AND `{date_col}` <= '{max_date}'
@ -70,7 +77,7 @@ class CollapsingMergeTree(InsertOnlyEngineMixin, infi_engines.CollapsingMergeTre
""" """
query = query.format(date_col=self.date_col, pk_column=self.pk_column, min_date=min_date.isoformat(), query = query.format(date_col=self.date_col, pk_column=self.pk_column, min_date=min_date.isoformat(),
max_date=max_date.isoformat(), object_pks=','.join(object_pks)) max_date=max_date.isoformat(), object_pks=','.join(object_pks))
qs = model_cls.get_database().select(query, model_class=model_cls) qs = db.select(query, model_class=model_cls)
return list(qs) return list(qs)
def get_final_versions(self, model_cls, objects): def get_final_versions(self, model_cls, objects):