summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/databases/mssql.py
diff options
context:
space:
mode:
authorPaul Johnston <paj@pajhome.org.uk>2008-07-15 09:15:59 +0000
committerPaul Johnston <paj@pajhome.org.uk>2008-07-15 09:15:59 +0000
commit16e8d446866d5fc250fa287ea6881903661a00b0 (patch)
tree1806fb312b3753184ec157dc6d67b3f233d0ce23 /lib/sqlalchemy/databases/mssql.py
parent44aa875212bfe01882f2a24bfb01cba833d3574b (diff)
downloadsqlalchemy-16e8d446866d5fc250fa287ea6881903661a00b0.tar.gz
Fix reflection where the table name has a duplicate name in a different schema
Diffstat (limited to 'lib/sqlalchemy/databases/mssql.py')
-rw-r--r--lib/sqlalchemy/databases/mssql.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/sqlalchemy/databases/mssql.py b/lib/sqlalchemy/databases/mssql.py
index 40c7903a8..ce9ca441e 100644
--- a/lib/sqlalchemy/databases/mssql.py
+++ b/lib/sqlalchemy/databases/mssql.py
@@ -638,7 +638,8 @@ class MSSQLDialect(default.DefaultDialect):
# Primary key constraints
s = sql.select([C.c.column_name, TC.c.constraint_type], sql.and_(TC.c.constraint_name == C.c.constraint_name,
- C.c.table_name == table.name))
+ C.c.table_name == table.name,
+ C.c.table_schema == table.schema))
c = connection.execute(s)
for row in c:
if 'PRIMARY' in row[TC.c.constraint_type.name]: