rearchitect reflection for batched performance

Rearchitected the schema reflection API to allow some dialects to make use
of high performing batch queries to reflect the schemas of many tables at
once using much fewer queries. The new performance features are targeted
first at the PostgreSQL and Oracle backends, and may be applied to any
dialect that makes use of SELECT queries against system catalog tables to
reflect tables (currently this omits the MySQL and SQLite dialects which
instead make use of parsing the "CREATE TABLE" statement, however these
dialects do not have a pre-existing performance issue with reflection. MS
SQL Server is still a TODO).

The new API is backwards compatible with the previous system, and should
require no changes to third party dialects to retain compatibility;
third party dialects can also opt into the new system by implementing
batched queries for schema reflection.

Along with this change is an updated reflection API that is fully
:pep:`484` typed, features many new methods and some changes.

Fixes: #4379
Change-Id: I897ec09843543aa7012bcdce758792ed3d415d08

1 files changed, 17 insertions, 16 deletions

diff --git a/lib/sqlalchemy/testing/suite/test_sequence.py b/lib/sqlalchemy/testing/suite/test_sequence.py
index eae051992..e15fad642 100644
--- a/lib/sqlalchemy/testing/suite/test_sequence.py
+++ b/lib/sqlalchemy/testing/suite/test_sequence.py
@@ -194,16 +194,23 @@ class HasSequenceTest(fixtures.TablesTest):
         )
 
     def test_has_sequence(self, connection):
-        eq_(
-            inspect(connection).has_sequence("user_id_seq"),
-            True,
-        )
+        eq_(inspect(connection).has_sequence("user_id_seq"), True)
+
+    def test_has_sequence_cache(self, connection, metadata):
+        insp = inspect(connection)
+        eq_(insp.has_sequence("user_id_seq"), True)
+        ss = Sequence("new_seq", metadata=metadata)
+        eq_(insp.has_sequence("new_seq"), False)
+        ss.create(connection)
+        try:
+            eq_(insp.has_sequence("new_seq"), False)
+            insp.clear_cache()
+            eq_(insp.has_sequence("new_seq"), True)
+        finally:
+            ss.drop(connection)
 
     def test_has_sequence_other_object(self, connection):
-        eq_(
-            inspect(connection).has_sequence("user_id_table"),
-            False,
-        )
+        eq_(inspect(connection).has_sequence("user_id_table"), False)
 
     @testing.requires.schemas
     def test_has_sequence_schema(self, connection):
@@ -215,10 +222,7 @@ class HasSequenceTest(fixtures.TablesTest):
         )
 
     def test_has_sequence_neg(self, connection):
-        eq_(
-            inspect(connection).has_sequence("some_sequence"),
-            False,
-        )
+        eq_(inspect(connection).has_sequence("some_sequence"), False)
 
     @testing.requires.schemas
     def test_has_sequence_schemas_neg(self, connection):
@@ -240,10 +244,7 @@ class HasSequenceTest(fixtures.TablesTest):
 
     @testing.requires.schemas
     def test_has_sequence_remote_not_in_default(self, connection):
-        eq_(
-            inspect(connection).has_sequence("schema_seq"),
-            False,
-        )
+        eq_(inspect(connection).has_sequence("schema_seq"), False)
 
     def test_get_sequence_names(self, connection):
         exp = {"other_seq", "user_id_seq"}