Infinidat/infi.clickhouse_orm
1
1
Fork 0
mirror of https://github.com/Infinidat/infi.clickhouse_orm.git synced 2024-11-25 10:13:45 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fixed bug with StringIO import, incompatible with python 3

Browse Source
This commit is contained in:
M1ha 2017-04-06 10:54:00 +05:00
parent 9bca42fe7e
commit 76718426bf
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -50,7 +50,7 @@ class Database(object):
def insert(self, model_instances, batch_size=1000): def insert(self, model_instances, batch_size=1000):
from six import next from six import next
from cStringIO import StringIO from io import BytesIO
i = iter(model_instances) i = iter(model_instances)
try: try:
first_instance = next(i) first_instance = next(i)
@ -62,7 +62,7 @@ class Database(object):
raise DatabaseException("You can't insert into read only table") raise DatabaseException("You can't insert into read only table")
def gen(): def gen():
buf = StringIO() buf = BytesIO()
buf.write(self._substitute('INSERT INTO $table FORMAT TabSeparated\n', model_class).encode('utf-8')) buf.write(self._substitute('INSERT INTO $table FORMAT TabSeparated\n', model_class).encode('utf-8'))
first_instance.set_database(self) first_instance.set_database(self)
buf.write(first_instance.to_tsv(include_readonly=False).encode('utf-8')) buf.write(first_instance.to_tsv(include_readonly=False).encode('utf-8'))
@ -78,7 +78,7 @@ class Database(object):
# Return the current batch of lines # Return the current batch of lines
yield buf.getvalue() yield buf.getvalue()
# Start a new batch # Start a new batch
buf = StringIO() buf = BytesIO()
lines = 0 lines = 0
# Return any remaining lines in partial batch # Return any remaining lines in partial batch
if lines: if lines: