Fixed mysql FK reflection for the edge case where a Table has expicitly provided a schema= that matches the connection's default schema.

1 files changed, 9 insertions, 0 deletions

diff --git a/lib/sqlalchemy/databases/mysql.py b/lib/sqlalchemy/databases/mysql.py
index f1187b8ac..743ec96ea 100644
--- a/lib/sqlalchemy/databases/mysql.py
+++ b/lib/sqlalchemy/databases/mysql.py
@@ -2334,11 +2334,20 @@ class MySQLSchemaReflector(object):
     def _set_constraints(self, table, constraints, connection, only):
         """Apply constraints to a ``Table``."""
 
+        default_schema = None
+
         for spec in constraints:
             # only FOREIGN KEYs
             ref_name = spec['table'][-1]
             ref_schema = len(spec['table']) > 1 and spec['table'][-2] or None
 
+            if not ref_schema:
+                if default_schema is None:
+                    default_schema = connection.dialect.get_default_schema_name(
+                        connection)
+                if table.schema == default_schema:
+                    ref_schema = table.schema
+
             loc_names = spec['local']
             if only and not set(loc_names).issubset(only):
                 self.logger.info(