Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion aiomysql/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
from .cursors import Cursor, SSCursor, DictCursor, SSDictCursor
from .pool import create_pool, Pool

__version__ = '0.0.20'
__version__ = '0.0.21'

__all__ = [

Expand Down
4 changes: 2 additions & 2 deletions aiomysql/connection.py
Original file line number Diff line number Diff line change
Expand Up @@ -224,7 +224,7 @@ def __init__(self, host="localhost", user=None, password="",
#: specified autocommit mode. None means use server default.
self.autocommit_mode = autocommit

self.encoders = encoders # Need for MySQLdb compatibility.
self.encoders = conv # Need for MySQLdb compatibility.
self.decoders = conv
self.sql_mode = sql_mode
self.init_command = init_command
Expand Down Expand Up @@ -375,7 +375,7 @@ def escape(self, obj):
return "'" + self.escape_string(obj) + "'"
if isinstance(obj, bytes):
return escape_bytes_prefixed(obj)
return escape_item(obj, self._charset)
return escape_item(obj, self._charset, mapping=self.encoders)

def literal(self, obj):
"""Alias for escape()"""
Expand Down