Infinidat/infi.clickhouse_orm
1
1
Fork 0
mirror of https://github.com/Infinidat/infi.clickhouse_orm.git synced 2025-07-23 14:29:47 +03:00
Code Issues Packages Projects Releases Wiki Activity

Add disabler for the timezone getting

Browse Source
This commit is contained in:
Понаревский Владимир 2018-05-08 13:19:45 +03:00
parent 2499a3f42a
commit a5c93dc176
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/infi/clickhouse_orm/database.py
View File

@ -72,7 +72,8 @@ class Database(object):
''' '''
def __init__(self, db_name, db_url='http://localhost:8123/', def __init__(self, db_name, db_url='http://localhost:8123/',
username=None, password=None, readonly=False, autocreate=True): username=None, password=None, readonly=False, autocreate=True,
get_timezone=True):
''' '''
Initializes a database instance. Unless it's readonly, the database will be Initializes a database instance. Unless it's readonly, the database will be
created on the ClickHouse server if it does not already exist. created on the ClickHouse server if it does not already exist.
@ -83,6 +84,7 @@ class Database(object):
- `password`: optional connection credentials. - `password`: optional connection credentials.
- `readonly`: use a read-only connection. - `readonly`: use a read-only connection.
- `autocreate`: automatically create the database if does not exist (unless in readonly mode). - `autocreate`: automatically create the database if does not exist (unless in readonly mode).
- `get_timezone`: automatically detect the server timezone.
''' '''
self.db_name = db_name self.db_name = db_name
self.db_url = db_url self.db_url = db_url
@ -96,7 +98,8 @@ class Database(object):
elif autocreate: elif autocreate:
self.db_exists = False self.db_exists = False
self.create_database() self.create_database()
self.server_timezone = self._get_server_timezone()
self.server_timezone = self._get_server_timezone() if get_timezone else pytz.utc
self.server_version = self._get_server_version() self.server_version = self._get_server_version()
def create_database(self): def create_database(self):