add on_connect to MySQLDialect_pyodbc

Fixes: #4876

diff --git a/lib/sqlalchemy/dialects/mysql/pyodbc.py b/lib/sqlalchemy/dialects/mysql/pyodbc.py
index e8d2034a1744ce80c0ab21c9dff69b2416a7cb56..889996b8a24205d3d89a60719a90eb53dc5cd4ba 100644 (file)
--- a/lib/sqlalchemy/dialects/mysql/pyodbc.py
+++ b/lib/sqlalchemy/dialects/mysql/pyodbc.py
@@ -79,5 +79,18 @@ class MySQLDialect_pyodbc(PyODBCConnector, MySQLDialect):
         else:
             return None
 
+    def on_connect(self):
+        super_ = super(MySQLDialect_pyodbc, self).on_connect()
+
+        def on_connect(conn):
+            if super_ is not None:
+                super_(conn)
+
+            conn.setdecoding(1, encoding='utf-8')  # pyodbc.SQL_CHAR
+            conn.setdecoding(-8, encoding='utf-8')  # pyodbc.SQL_WCHAR
+            conn.setencoding(encoding='utf-8')
+
+        return on_connect
+
 
 dialect = MySQLDialect_pyodbc