- Table.create() and Table.drop() no longer apply metadata-

level create/drop events.  [ticket:1771]

2 files changed, 12 insertions, 6 deletions

diff --git a/lib/sqlalchemy/engine/base.py b/lib/sqlalchemy/engine/base.py
index d35796063..5068167c3 100644
--- a/lib/sqlalchemy/engine/base.py
+++ b/lib/sqlalchemy/engine/base.py
@@ -1497,14 +1497,14 @@ class Engine(Connectable, log.Identified):
         self.pool = self.pool.recreate()
 
     def create(self, entity, connection=None, **kwargs):
-        """Create a table or index within this engine's database connection given a schema.Table object."""
+        """Create a table or index within this engine's database connection given a schema object."""
 
         from sqlalchemy.engine import ddl
 
         self._run_visitor(ddl.SchemaGenerator, entity, connection=connection, **kwargs)
 
     def drop(self, entity, connection=None, **kwargs):
-        """Drop a table or index within this engine's database connection given a schema.Table object."""
+        """Drop a table or index within this engine's database connection given a schema object."""
 
         from sqlalchemy.engine import ddl
 
diff --git a/lib/sqlalchemy/engine/ddl.py b/lib/sqlalchemy/engine/ddl.py
index ef10aa5ea..74205dbb0 100644
--- a/lib/sqlalchemy/engine/ddl.py
+++ b/lib/sqlalchemy/engine/ddl.py
@@ -39,12 +39,15 @@ class SchemaGenerator(DDLBase):
             listener('before-create', metadata, self.connection, tables=collection)
             
         for table in collection:
-            self.traverse_single(table)
+            self.traverse_single(table, create_ok=True)
 
         for listener in metadata.ddl_listeners['after-create']:
             listener('after-create', metadata, self.connection, tables=collection)
 
-    def visit_table(self, table):
+    def visit_table(self, table, create_ok=False):
+        if not create_ok and not self._can_create(table):
+            return
+            
         for listener in table.ddl_listeners['before-create']:
             listener('before-create', table, self.connection)
 
@@ -92,7 +95,7 @@ class SchemaDropper(DDLBase):
             listener('before-drop', metadata, self.connection, tables=collection)
         
         for table in collection:
-            self.traverse_single(table)
+            self.traverse_single(table, drop_ok=True)
 
         for listener in metadata.ddl_listeners['after-drop']:
             listener('after-drop', metadata, self.connection, tables=collection)
@@ -106,7 +109,10 @@ class SchemaDropper(DDLBase):
     def visit_index(self, index):
         self.connection.execute(schema.DropIndex(index))
 
-    def visit_table(self, table):
+    def visit_table(self, table, drop_ok=False):
+        if not drop_ok and not self._can_drop(table):
+            return
+            
         for listener in table.ddl_listeners['before-drop']:
             listener('before-drop', table, self.connection)