- wip for #3336fix_mysqlconnector

1 files changed, 3 insertions, 3 deletions

diff --git a/lib/sqlalchemy/dialects/mysql/base.py b/lib/sqlalchemy/dialects/mysql/base.py
index a74b20ac4..43553a69c 100644
--- a/lib/sqlalchemy/dialects/mysql/base.py
+++ b/lib/sqlalchemy/dialects/mysql/base.py
@@ -2449,7 +2449,7 @@ class MySQLDialect(default.DefaultDialect):
         cursor.execute('SELECT @@tx_isolation')
         val = cursor.fetchone()[0]
         cursor.close()
-        if util.py3k and isinstance(val, bytes):
+        if util.py3k and isinstance(val, util.all_binary_types):
             val = val.decode()
         return val.upper().replace("-", " ")
 
@@ -3358,7 +3358,7 @@ class _DecodingRowProxy(object):
         if isinstance(item, _array):
             item = item.tostring()
 
-        if self.charset and isinstance(item, util.binary_type):
+        if self.charset and isinstance(item, util.all_binary_types):
             return item.decode(self.charset)
         else:
             return item
@@ -3367,7 +3367,7 @@ class _DecodingRowProxy(object):
         item = getattr(self.rowproxy, attr)
         if isinstance(item, _array):
             item = item.tostring()
-        if self.charset and isinstance(item, util.binary_type):
+        if self.charset and isinstance(item, util.all_binary_types):
             return item.decode(self.charset)
         else:
             return item