diff options
author | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-02-01 02:36:54 +0000 |
---|---|---|
committer | Daniele Varrazzo <daniele.varrazzo@gmail.com> | 2017-02-01 02:36:54 +0000 |
commit | 2e2dcd536bb06c07747e28ad98f4fb8e3053748e (patch) | |
tree | 4d8babf5760b29e3ecb96212f56b7f63da168647 /lib/extras.py | |
parent | a95fd3df1abc0282f1c47fa2170191f037c3c8de (diff) | |
download | psycopg2-2e2dcd536bb06c07747e28ad98f4fb8e3053748e.tar.gz |
Fixed fast execute functions with Python 3
Diffstat (limited to 'lib/extras.py')
-rw-r--r-- | lib/extras.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/lib/extras.py b/lib/extras.py index 85963c9..2636655 100644 --- a/lib/extras.py +++ b/lib/extras.py @@ -1177,7 +1177,7 @@ def execute_batch(cur, sql, argslist, page_size=100): """ for page in _paginate(argslist, page_size=page_size): sqls = [cur.mogrify(sql, args) for args in page] - cur.execute(";".join(sqls)) + cur.execute(b";".join(sqls)) def execute_values(cur, sql, argslist, template=None, page_size=100): @@ -1219,5 +1219,7 @@ def execute_values(cur, sql, argslist, template=None, page_size=100): for page in _paginate(argslist, page_size=page_size): if template is None: template = '(%s)' % ','.join(['%s'] * len(page[0])) - values = ",".join(cur.mogrify(template, args) for args in page) + values = b",".join(cur.mogrify(template, args) for args in page) + if isinstance(values, bytes) and _sys.version_info[0] > 2: + values = values.decode(_ext.encodings[cur.connection.encoding]) cur.execute(sql % (values,)) |