summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/databases/oracle.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2008-05-24 23:34:04 +0000
committerMike Bayer <mike_mp@zzzcomputing.com>2008-05-24 23:34:04 +0000
commitfa42abd21323f9be5bbf9f8744e02271c9834691 (patch)
tree70753d805701adef2de94d3e69235531d89e32b1 /lib/sqlalchemy/databases/oracle.py
parent6510bfbcf785f38e7b4a3b2a9022c2ca7a780d31 (diff)
downloadsqlalchemy-fa42abd21323f9be5bbf9f8744e02271c9834691.tar.gz
oracle dialect takes schema name into account when checking for existing tables
of the same name. [ticket:709]
Diffstat (limited to 'lib/sqlalchemy/databases/oracle.py')
-rw-r--r--lib/sqlalchemy/databases/oracle.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/lib/sqlalchemy/databases/oracle.py b/lib/sqlalchemy/databases/oracle.py
index ed1778a6f..355012a1d 100644
--- a/lib/sqlalchemy/databases/oracle.py
+++ b/lib/sqlalchemy/databases/oracle.py
@@ -358,7 +358,9 @@ class OracleDialect(default.DefaultDialect):
return OracleExecutionContext(self, *args, **kwargs)
def has_table(self, connection, table_name, schema=None):
- cursor = connection.execute("""select table_name from all_tables where table_name=:name""", {'name':self._denormalize_name(table_name)})
+ if not schema:
+ schema = self.get_default_schema_name(connection)
+ cursor = connection.execute("""select table_name from all_tables where table_name=:name and owner=:schema_name""", {'name':self._denormalize_name(table_name), 'schema_name':self._denormalize_name(schema)})
return cursor.fetchone() is not None
def has_sequence(self, connection, sequence_name):