carrotquest/django-clickhouse
1
1
Fork 0
mirror of https://github.com/carrotquest/django-clickhouse.git synced 2025-05-01 22:23:50 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix choosing connection on syncing

Browse Source
This commit is contained in:
M1ha 2018-12-19 12:37:05 +05:00
parent 0829e5bacd
commit 2dc8e7a270
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/django_clickhouse/clickhouse_models.py
View File

@ -54,7 +54,6 @@ class ClickHouseModel(with_metaclass(ClickHouseModelMeta, InfiModel)):
sync_batch_size = None sync_batch_size = None
sync_storage = None sync_storage = None
sync_delay = None sync_delay = None
sync_database_alias = None
sync_lock_timeout = None sync_lock_timeout = None
# This attribute is initialized in metaclass, as it must get model class as a parameter # This attribute is initialized in metaclass, as it must get model class as a parameter
@ -174,8 +173,7 @@ class ClickHouseModel(with_metaclass(ClickHouseModelMeta, InfiModel)):
:return: :return:
""" """
if batch: if batch:
conn = connections[cls.sync_database_alias] cls.get_database(for_write=True).insert(batch)
conn.insert(batch)
@classmethod @classmethod
def sync_batch_from_storage(cls): def sync_batch_from_storage(cls):