pawelsocha
diff --git a/‎MySQLdb/connections.py
Copy file name to clipboardExpand all lines: MySQLdb/connections.py
+7-1Lines changed: 7 additions & 1 deletion b/‎MySQLdb/connections.py
Copy file name to clipboardExpand all lines: MySQLdb/connections.py
+7-1Lines changed: 7 additions & 1 deletion
diff --git a/‎MySQLdb/cursors.py
Copy file name to clipboardExpand all lines: MySQLdb/cursors.py
+10-16Lines changed: 10 additions & 16 deletions b/‎MySQLdb/cursors.py
Copy file name to clipboardExpand all lines: MySQLdb/cursors.py
+10-16Lines changed: 10 additions & 16 deletions
@@ -13,6 +13,9 @@
      NotSupportedError, ProgrammingError
 import _mysql
 import re
+import sys
+
+PY2 = sys.version_info[0] == 2
 
 
 def defaulterrorhandler(connection, cursor, errorclass, errorvalue):
@@ -280,7 +283,10 @@ def literal(self, o):
         applications.
 
         """
-        return self.escape(o, self.encoders)
+        s = self.escape(o, self.encoders)
+        if not PY2 and isinstance(s, bytes):
+            return s.decode('ascii', 'surrogateescape')
+        return s
 
     def begin(self):
         """Explicitly begin a connection. Non-standard.
 
@@ -11,7 +11,7 @@
 
 from MySQLdb.compat import unicode
 
-restr = br"""
+restr = r"""
     \s
     values
     \s*
@@ -179,23 +179,12 @@ def execute(self, query, args=None):
         db = self._get_db()
         if PY2 and isinstance(query, unicode):
             query = query.encode(db.unicode_literal.charset)
-        else:
-            def decode(x):
-                if isinstance(x, bytes):
-                    x = x.decode('ascii', 'surrogateescape')
-                return x
 
         if args is not None:
             if isinstance(args, dict):
-                if PY2:
-                    args = dict((key, db.literal(item)) for key, item in args.iteritems())
-                else:
-                    args = dict((key, decode(db.literal(item))) for key, item in args.items())
+                args = dict((key, db.literal(item)) for key, item in args.iteritems())
             else:
-                if PY2:
-                    args = tuple(map(db.literal, args))
-                else:
-                    args = tuple([decode(db.literal(x)) for x in args])
+                args = tuple(map(db.literal, args))
             if not PY2 and isinstance(query, bytes):
                 query = query.decode(db.unicode_literal.charset)
             query = query % args
@@ -246,8 +235,10 @@ def executemany(self, query, args):
         del self.messages[:]
         db = self._get_db()
         if not args: return
-        if isinstance(query, unicode):
+        if PY2 and isinstance(query, unicode):
             query = query.encode(db.unicode_literal.charset)
+        elif not PY2 and isinstance(query, bytes):
+            query = query.decode(db.unicode_literal.charset)
         m = insert_values.search(query)
         if not m:
             r = 0
@@ -277,7 +268,10 @@ def executemany(self, query, args):
             exc, value, tb = sys.exc_info()
             del tb
             self.errorhandler(self, exc, value)
-        r = self._query('\n'.join([query[:p], ',\n'.join(q), query[e:]]))
+        qs = '\n'.join([query[:p], ',\n'.join(q), query[e:]])
+        if not PY2:
+            qs = qs.encode(db.unicode_literal.charset, 'surrogateescape')
+        r = self._query(qs)
         if not self._defer_warnings: self._warning_check()
         return r