summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy
diff options
context:
space:
mode:
authorGord Thompson <gord@gordthompson.com>2020-09-18 16:33:17 -0600
committerGord Thompson <gord@gordthompson.com>2020-09-19 10:18:52 -0600
commitcec14b77e62d301540a29e5a81a671231239849d (patch)
tree16afd857ccc8a9184b4f5480dbafc22f2488019f /lib/sqlalchemy
parent29575552b04f4d4e4f7373a8ddcaa2572046029e (diff)
downloadsqlalchemy-cec14b77e62d301540a29e5a81a671231239849d.tar.gz
Fix has_table() for mssql temporary tables
Fixes: #5597 Fixes the issue where :meth:`_reflection.has_table` always returns ``False`` for temporary tables. Change-Id: I03ab04c849a157ce8fd28c07ec3bf4407b0f2c94
Diffstat (limited to 'lib/sqlalchemy')
-rw-r--r--lib/sqlalchemy/dialects/mssql/base.py41
1 files changed, 27 insertions, 14 deletions
diff --git a/lib/sqlalchemy/dialects/mssql/base.py b/lib/sqlalchemy/dialects/mssql/base.py
index 7564536a5..2cbdc19aa 100644
--- a/lib/sqlalchemy/dialects/mssql/base.py
+++ b/lib/sqlalchemy/dialects/mssql/base.py
@@ -2756,21 +2756,34 @@ class MSDialect(default.DefaultDialect):
@_db_plus_owner
def has_table(self, connection, tablename, dbname, owner, schema):
- tables = ischema.tables
+ if tablename.startswith("#"): # temporary table
+ tables = ischema.mssql_temp_table_columns
+ result = connection.execute(
+ sql.select(tables.c.table_name)
+ .where(
+ tables.c.table_name.like(
+ self._temp_table_name_like_pattern(tablename)
+ )
+ )
+ .limit(1)
+ )
+ return result.scalar() is not None
+ else:
+ tables = ischema.tables
- s = sql.select(tables.c.table_name).where(
- sql.and_(
- tables.c.table_type == "BASE TABLE",
- tables.c.table_name == tablename,
+ s = sql.select(tables.c.table_name).where(
+ sql.and_(
+ tables.c.table_type == "BASE TABLE",
+ tables.c.table_name == tablename,
+ )
)
- )
- if owner:
- s = s.where(tables.c.table_schema == owner)
+ if owner:
+ s = s.where(tables.c.table_schema == owner)
- c = connection.execute(s)
+ c = connection.execute(s)
- return c.first() is not None
+ return c.first() is not None
@_db_plus_owner
def has_sequence(self, connection, sequencename, dbname, owner, schema):
@@ -2937,6 +2950,9 @@ class MSDialect(default.DefaultDialect):
view_def = rp.scalar()
return view_def
+ def _temp_table_name_like_pattern(self, tablename):
+ return tablename + (("___%") if not tablename.startswith("##") else "")
+
def _get_internal_temp_table_name(self, connection, tablename):
# it's likely that schema is always "dbo", but since we can
# get it here, let's get it.
@@ -2950,10 +2966,7 @@ class MSDialect(default.DefaultDialect):
"from tempdb.information_schema.tables "
"where table_name like :p1"
),
- {
- "p1": tablename
- + (("___%") if not tablename.startswith("##") else "")
- },
+ {"p1": self._temp_table_name_like_pattern(tablename)},
).one()
except exc.MultipleResultsFound as me:
util.raise_(